# MQTT动作

该操作用于将输出消息发布到 MQTT 服务器中。

属性名称是否可选说明
serverMQTT 服务器地址,例如 tcp://127.0.0.1:1883
topicMQTT 主题,例如 analysis/result
clientIdMQTT 连接的客户端 ID。 如果未指定,将使用一个 uuid
protocolVersionMQTT 协议版本。3.1 (也被称为 MQTT 3) 或者 3.1.1 (也被称为 MQTT 4)。 如果未指定,缺省值为 3.1。
qos消息转发的服务质量
username连接用户名
password连接密码
certificationPath证书路径。可以为绝对路径,也可以为相对路径。如果指定的是相对路径,那么父目录为执行 kuiperd 命令的路径。比如,如果你在 /var/kuiper 中运行 bin/kuiperd ,那么父目录为 /var/kuiper; 如果运行从 /var/kuiper/bin 中运行./kuiperd,那么父目录为 /var/kuiper/bin
privateKeyPath私钥路径。可以为绝对路径,也可以为相对路径,相对路径的用法与 certificationPath 类似。
insecureSkipVerifytrue如果 InsecureSkipVerify 设置为 true, TLS接受服务器提供的任何证书以及该证书中的任何主机名。 在这种模式下,TLS容易受到中间人攻击。默认值为false。配置项只能用于TLS连接。
retainedtrue如果 retained 设置为 true,Broker会存储每个Topic的最后一条保留消息及其Qos。默认值是 false

以下为使用 SAS 连接到 Azure IoT Hub 的样例。

    {
      "mqtt": {
        "server": "ssl://xyz.azure-devices.net:8883",
        "topic": "devices/demo_001/messages/events/",
        "protocolVersion": "3.1.1",
        "qos": 1,
        "clientId": "demo_001",
        "username": "xyz.azure-devices.net/demo_001/?api-version=2018-06-30",
        "password": "SharedAccessSignature sr=*******************",
        "retained": false
      }
    }
1
2
3
4
5
6
7
8
9
10
11
12

以下为使用证书和私钥连接到 AWS IoT的另一个样例。

    {
      "mqtt": {
        "server": "ssl://xyz-ats.iot.us-east-1.amazonaws.com:8883",
        "topic": "devices/result",
        "qos": 1,
        "clientId": "demo_001",
        "certificationPath": "keys/d3807d9fa5-certificate.pem",
        "privateKeyPath": "keys/d3807d9fa5-private.pem.key",
        "retained": false
      }
    }
1
2
3
4
5
6
7
8
9
10
11