如何使用 Logstash 和 rabbitmq 输出设置内容类型？

Posted 2023-02-21

【中文标题】如何使用 Logstash 和 rabbitmq 输出设置内容类型？

【英文标题】：How to set content type with Logstash & rabbitmq output?

【发布时间】：2015-05-26 17:35:54

【问题描述】：

我想用 logstash 解析日志并通过 rabbitmq 发送结果。使用这些结果的应用程序正在等待 content_type 设置为“application/json”的消息。目前，我的消息没有属性，我的应用程序无法处理该消息。

您能告诉我logstash 是如何将属性“content_type”设置为“application/json”的消息发送到rabbitmq 的吗？

在此先感谢并致以最诚挚的问候，

罗曼。

【参考方案1】：

抱歉，目前无法执行此操作。我已经为你提交了github.com/logstash-plugins/logstash-output-rabbitmq bug #6。

在解决该错误之前，也许您可​​以编写一个简单的微服务来使用无内容类型的消息，并使用正确的内容类型声明将它们重新发布到另一个主题、交换或队列。

【参考方案2】：

就像@Magnus Bäck 所说，开箱即用是不可能的。但是如果你真的需要它，你可以 fork rabbitmq 插件。并将:content_type => 'application/json' 之类的内容添加到this line