Изменение входных данных в logstash с помощью фильтра
У меня есть входные данные из таблицы. Данные таблицы выглядят как<Customer_id> <Item_id> <Item name>
, Для каждого предмета, привезенного клиентом, в таблице есть отдельная строка. Например, если c1 покупает i1, i2, i3, i4, i5, в таблице будет 5 строк.
Теперь данные, которые я хочу вставить вasticsearch, таковы:
{
"c1": [
{
"item_id": "i1",
"item_name": "ABC"
},
{
"item_id": "i2",
"item_name": "XYZ"
},
.....
],
"c2": [
{
"item_id": 4,
"item_name": "PQR"
}
]
}
Как я могу изменить ввод, как указано выше в logstash?
Также моя схема выглядит так:
Item: item_id, item_name
Купить: cust_id, item_id
Также не могли бы вы предложить SQL-запрос для получения вышеуказанного результата?