Как проиндексировать вложенный объект mysql в elasticsearch с помощью logstash?

Question

Я пытаюсь индексировать базу данных mysql с помощью elasticsearch. Рассмотрим пример отображения:

{"blog": 
    {"properties": 
    {"id": "string"} 
    {"author": "string"} 
    {"time_created": } 
    {"author_info": 
     {"author_name":} 
     {"author_sex":} 
    } 
    {"posts": 
     {"post_author":} 
     {"post_time":} 
    } 
    } 
} 

У меня есть три таблицы, которые являются author_info, блогами и сообщениями. Как я могу индексировать эти записи в эластичные с вложенной структурой? Я не могу найти документы об этом. Спасибо

Answer 1

В sql-части входа в logstash вы можете попытаться выбрать поля с вложенными именами, которые вы хотите найти в elasticsearch. Ниже приведен небольшой пример того, как он может выглядеть.

вход { {

JDBC

statement => "SELECT id as blog.properties.id, author as blog.properties.author,..... from blog inner join properties inner join posts" 

}}