Как удалить только определенные строки после обновления данных БД с помощью Logstash и Elasticsearch - PullRequest
0 голосов
/ 19 февраля 2019

У меня есть несколько строк, которые мне нужны, чтобы вставить строки и удалить их, если они изменятся.

Я выталкиваю из строк Oracle данные, сделанные следующим образом:

  • номер запроса (ключ)
  • статус запроса (номер)
  • last_update (время)

Если запрос имеет статус 1 (ЗАЯВКА НА ОЖИДАНИЕ), я должен его проиндексировать.Если запрос имеет статус 10 (ОК, ЗАПРОС), я должен пропустить его.

После этого я должен проанализировать запросы: если запрос переходит от ОЖИДАНИЯ к ОК, я должен удалить его.Если запрос остается в состоянии PENDING, я должен сохранить его в стеке ELK.

Я думаю, что могу использовать функцию upsert, но я не знаю точно, как управлять ситуацией.Кто-нибудь может мне помочь?

...