如何在LogStash中进行多个输入流？
我的用例是：
- 我需要数据库A的时间戳
- ，然后在数据库B上进行查询
- ，然后输出该数据库B查询的结果，
这意味着（理论上）看起来像是这样的logstash文件，
input {
jdbc {
get the timestamp
}
jdbc {
Do the SQL that gets lots of data with the timestamp above
}
}
output {
elasticsearch {
spew the data from that second jdbc query
}
}
当然是不起作用的，当然是不起作用的。 ，但它给出了用例的想法。如何解决这种情况？
My use case is:
- I need a timestamp from database A
- Then do a query on database B
- Then output the results of that Database B query
Which means a logstash file that (theoretically) would look something like:
input {
jdbc {
get the timestamp
}
jdbc {
Do the SQL that gets lots of data with the timestamp above
}
}
output {
elasticsearch {
spew the data from that second jdbc query
}
}
That doesn't work, of course, but it gives the idea of the use case. How can I make solve this scenario?
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
使用
Use a jdbc_streaming filter, which is designed for exactly this use-case.