Изменение входных данных в 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-запрос для получения вышеуказанного результата?

Ответы на вопрос(1)

Ваш ответ на вопрос