Zmq 目标(Sink)

目标(Sink)会将结果发布到 Zero Mq 主题中。

编译和部署插件

  1. # cd $kuiper_src
  2. # go build -trimpath --buildmode=plugin -o plugins/sinks/Zmq.so plugins/sinks/zmq/zmq.go
  3. # cp plugins/sinks/Zmq.so $kuiper_install/plugins/sinks

重新启动 Kuiper 服务器以激活插件。

属性

属性名称OptionalDescription
serverfalseZero Mq 服务器的 URL
topictrueThe topic to publish to

使用示例

下面是一个选择温度大于50度的示例,并将结果发布到 Zero Mq 主题 “temp”。

  1. {
  2. "sql": "SELECT * from demo where temperature>50",
  3. "actions": [
  4. {
  5. "zmq": {
  6. "server": "tcp://127.0.0.1:5563",
  7. "topic": "temp"
  8. }
  9. }
  10. ]
  11. }