重新排队 Logstash 事件

Question

是否可以重新排队 Logstash 事件以在一段时间内再次处理？

为了说明我的意思，我将解释我的用例：我有一个自定义 Logstash 过滤器，它在应用程序启动时从日志中提取应用程序版本，然后将正确的版本附加到每个日志事件。然而，在一开始，当应用程序版本尚未写入文件时，可能会发生竞争条件，但 Logstash 过滤器无论如何都会尝试读取数据（因为它同时处理日志行）。这会导致应用程序版本为空。以防万一，Logstash 从 Filebeat 获取输入。

当应用程序版本保存到磁盘后，我想将这些事件重新排队，以便在几秒钟（或几毫秒）后完全重新处理。

然而，这让我想到了一个更广泛的问题，即您能否告诉 Logstash 事件重新排队，或者是否有替代解决方案来解决这种情况？

感谢您的帮助！

Answer 1

处理数据并附加到一个新文件中，然后使用该文件进一步处理数据。

• Lo​​gstash 处理器 - 1 个 Geat 数据处理数据并附加到文件中。
• Lo​​gstash 处理器 - 2 从第二个文件中获取数据并执行任何操作 想做。