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

Question

我在 node-red 中有下面的流程，我需要将 msg 对象存储在 influxdb 中 -

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

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

Answer 1

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