emqxwriter.md

Emqx Writer

一、插件名称

名称：emqxwriter

二、支持的数据源版本

Emqx 4.0及以上

三、参数说明

• broker

  • 描述：连接URL信息。
  • 必选：是
  • 默认值：无

• topic

  • 描述：订阅主题
  • 必选：是
  • 默认值：无

• username

  • 描述：认证用户名
  • 必选：否
  • 默认值：无

• password

  • 描述：认证密码
  • 必选：否
  • 默认值：无

• isCleanSession

  • 描述：是否清除session
    • false：MQTT服务器保存于客户端会话的的主题与确认位置
    • true：MQTT服务器不保存于客户端会话的的主题与确认位置
  • 必选：否
  • 默认值：true

• qos

  • 描述：服务质量
    • 0：AT_MOST_ONCE，至多一次；
    • 1：AT_LEAST_ONCE，至少一次；
    • 2：EXACTLY_ONCE，精准一次；
  • 必选：否
  • 默认值：2

四、配置示例

{
  "job": {
    "content": [{
      "reader": {
          "name": "streamreader",
          "parameter": {
            "column": [
              {
                "name": "id",
                "type": "id"
              },
              {
                "name": "user_id",
                "type": "int"
              },
              {
                "name": "name",
                "type": "string"
              }
            ],
            "sliceRecordCount" : [ "100"]
          }
        },
      "writer": {
        "writer" : {
          "parameter" : {
            "broker" : "tcp://0.0.0.1:1883",
            "topic" : "test",
            "username" : "username",
            "password" : "password",
            "isCleanSession": true,
            "qos": 2
          },
          "name" : "emqxwriter"
        }
      }
    }
    ],
    "setting": {
      "speed": {
        "channel": 1,
        "bytes": 0
      },
      "errorLimit": {
        "record": 100
      },
      "restore": {
        "maxRowNumForCheckpoint": 0,
        "isRestore": false,
        "restoreColumnName": "",
        "restoreColumnIndex": 0
      },
      "log" : {
        "isLogger": false,
        "level" : "debug",
        "path" : "",
        "pattern":""
      }
    }
  }
}