oracle - 如何在使用 Logstash 和 Elasticsearch 更新数据库数据后仅删除某些行

Question

我有一些行需要插入行并在它们更改时删除它们。

我以这种方式从 Oracle 行中推入：

• 请求号（键）
• 请求状态（数量）
• last_update（时间）

如果请求是状态 1（PENDING REQUEST），我必须索引它。如果请求是状态 10（OK REQUEST），我必须跳过它。

之后，我必须分析请求：如果请求从 PENDING 变为 OK，我必须将其删除。如果请求停留在 PENDING 中，我必须将其保存到 ELK 堆栈中。

我想我可以使用 upsert 功能，但我不知道如何管理这种情况。有人能帮我吗？

标签： oracleelasticsearchlogstashkibana