Logstash：使用 aggregate filter 处理 N:N 关系

在 Logstash 中有一个叫做 aggregate 的 filter。此过滤器的目的是聚合属于同一任务的多个事件（通常是日志行）中的可用信息，最后将聚合的信息推送到最终任务事件中。你应该非常小心地将 Logstash 过滤器工作程序设置为 1（-w 1 标志），此过滤器才能正常工作，否则事件可能会被按顺序处理，并且会发生意外的结果。在 Elastic 的官方文档中，你可以看到很多相应的例子。

在今天的例子中，我们将以一个关系数据库的例子为例来讲述如何把一个关系数据库中的数据导入到 Elasticsearch 中，并形成 nested 数据类型。这个对于很多的数据库搜索是非常有用的。在我们的例子中，一个关系数据库是这样的：

https://elasticstack.blog.csdn ... 21821