问题描述
我想用logstash解析日志,并通过rabbitmq发送结果.使用这些结果的应用程序正在等待content_type设置为"application/json"的消息.目前,我的消息没有任何属性,我的应用程序无法处理该消息.
I want to parse logs with logstash and sends the results via rabbitmq. The application using these results is waiting for a message with content_type set to "application/json". For now, my messages have no properties and my application is not able to process the message.
您能告诉我logstash如何将属性"content_type"设置为"application/json"的消息发送到rabbitmq吗?
Could you please tell me how logstash sends a message to rabbitmq with a property "content_type" set to "application/json"?
预先感谢&最好的问候,
Thanks beforehand & best regards,
罗曼.
推荐答案
对不起,目前无法实现.我已经提交了 github.com/logstash-plugins/logstash-output-rabbitmq错误#6 为您.
Sorry, this is currently not possible. I've filed github.com/logstash-plugins/logstash-output-rabbitmq bug #6 for you.
在解决该错误之前,也许您可以编写一个简单的微服务,该微服务使用无内容类型的消息,然后将其重新发布到另一个主题上,以正确的内容类型声明交换或排队.
Until that bug has been addressed, perhaps you can write a simple microservice that consumes the content-type-less messages and republishes them on another topic, exchange, or queue with the correct content type declare.
这篇关于如何使用Logstash&设置内容类型rabbitmq输出?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!