logstash 利用filter 将nested嵌套格式的数据导入es，但es中mapping并没有nested类型

filter {

     aggregate {

        task_id => "%{id}"

        code => "

            map['id'] = event.get('id')

            map['register_name'] = event.get('register_name')

            map['mobile'] = event.get('mobile')

            map['avatar'] = event.get('avatar')

            map['pet_list'] ||=[]

            map['pets'] ||=[]

            if (event.get('pet_id') != nil)

                if !(map['pet_list'].include? event.get('pet_id'))  

                    map['pet_list'] << event.get('pet_id')        

                    map['pets'] << {

                        'pet_id' => event.get('pet_id'),

                        'name' => event.get('name'),

                        'images' => event.get('images'),

                        'breed_id' => event.get('breed_id'),

                        'breed_name' => event.get('breed_name'),

                        'birthday' => event.get('birthday')

                    }

                end

            end



            event.cancel()

        "

        

        push_previous_map_as_event => true

        timeout => 5

    }

    json {

        source => "message"

        remove_field => ["message"]

        #remove_field => ["message", "type", "@timestamp", "@version"]

    }

    mutate  {

        #将不需要的JSON字段过滤，且不会被存入 ES 中

        remove_field => ["tags", "@timestamp", "@version"]

    }

}