apache-kafka - 序列化来自 Kafka Producer 的 msg 对象并存储在 Node-Red 流中的 influxdb 中

Question

我有以下节点红色的流程，我需要将 msg 对象存储在 influxdb 中-

正如您在来自 kafka 消费者的调试节点中看到的那样，有效负载作为 [object Object] 存储在 Influxdb 中，而不是以每列分开的序列化方式存储。如果我将 msg 对象直接存储到 influxdb 中（中间没有 kafka 生产者和消费者），那么它会根据需要存储在 db 中。

有没有办法将 msg 对象正确存储在 influxdb 中，而 kafka 生产者和消费者是流程的一部分？

标签： apache-kafkainfluxdbnode-red

Answer 1

如评论中所述，您需要在 Kafka Producer 节点之前包含一个 JSON 节点，因为它需要一个字符串作为输入而不是 JavaScript 对象，并且 JSON 节点会将对象序列化为 JSON 字符串。