使用过滤器更改Logstash中的输入数据

我采用的方法是创建一个SQL查询，将这些行

Customer_ID

GROUP_CONCAT

然后，您可以将logstash jdbc输入与上面提出的SQL查询一起使用，您应该会很好。

更新

我对您的SQL查询进行了如下修改：

SELECt CONCAt('{"',cust_id,'": [',GROUP_CONCAt(CONCAt('{"item_id":',buy.item_id,','),CONCAt('"item_name": "',item.item_name,'"}')), ']}') FROM item, buyWHERe buy.item_id = item.item_id GROUP BY cust_id

这样会产生类似您需要的行的行：

{"1": [{"item_id":1,"item_name": "abc"},{"item_id":2,"item_name": "xyz"}]}{"2": [{"item_id":4,"item_name": "pqr"}]}