logstash将Oracle中数据导入es 如何导为nested类型

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

    }