资源管理 ¶
平台提供多种消息通信中间件资源，资源可作为规则引擎的消息目的地，通过创建资源快速将数据推送至应用平台。
平台提供5种通讯中间件资源。
HTTP推送 ¶
该动作用于将输出消息发布到 RESTful API 中。
| 属性名称 | 是否可选 | 说明 |
|---|---|---|
| 实例名称 | 否 | 实例名称，请保证该参数的唯一性。 |
| method | 是 | RESTful API 的 HTTP 方法。 这是一个不区分大小写的字符串，其值范围为"get"，"post"，"put"，"patch"，"delete" 和 "head"。 默认值为 "get"。 |
| url | 否 | RESTful API 终端地址，例如 https://www.example.com/api/dummy。 |
| bodyType | 是 | 消息体的类型。 当前，支持以下类型："none", "json", "text", "html", "xml", "javascript" 和 "form"。 对于 "get" 和 "head"，不需要正文，因此默认值为 "none"。 对于其他 http 方法，默认值为 "json"。对于 "html"，"xml" 和 "javascript"，必须仔细设置 dataTemplate 以确保格式正确。支持动态获取。 |
| timeout | 是 | HTTP 请求超时的时间（毫秒），默认为5000毫秒 |
| headers | 是 | 要为 HTTP 请求设置的其它 HTTP 头。 |
消息队列MQTT ¶
该操作用于将输出消息发布到 MQTT 服务器中。
| 属性名称 | 是否可选 | 说明 |
|---|---|---|
| 实例名称 | 否 | 实例名称，请保证该参数的唯一性。 |
| mqtt broker | 否 | MQTT 服务器地址，例如 tcp://127.0.0.1:1883 |
| topic | 否 | MQTT 主题，例如 analysis/result |
| clientId | 是 | MQTT 连接的客户端 ID。 如果未指定，将使用一个 uuid |
| protocolVersion | 是 | MQTT 协议版本。3.1 (也被称为 MQTT 3) 或者 3.1.1 (也被称为 MQTT 4)。 如果未指定，缺省值为 3.1。 |
| qos | 是 | 消息转发的服务质量 |
| username | 是 | 连接用户名 |
| password | 是 | 连接密码 |
消息队列Kafka ¶
该操作用于将输出消息发布到 Kafka 服务器中。
| 属性名称 | 是否可选 | 说明 |
|---|---|---|
| 实例名称 | 否 | 实例名称，请保证该参数的唯一性。 |
| brokers | 否 | broker地址列表 ,用 "," 分割 |
| topic | 否 | kafka 主题 |
| saslAuthType | 否 | sasl 认证类型 , 支持none，plain，scram |
| saslUserName | 是 | sasl 用户名 |
| saslPassword | 是 | sasl 密码 |
InfluxDB ¶
该操作用于将输出消息发布到 InfluxDB 服务器中。
| 属性名称 | 会否可选 | 说明 |
|---|---|---|
| 实例名称 | 否 | 实例名称，请保证该参数的唯一性。 |
| addr | 是 | InfluxDB 的地址 |
| measurement | 是 | InfluxDb 的测量（如表名） |
| username | 否 | InfluxDB 登陆用户名 |
| password | 否 | InfluxDB 登陆密码 |
| databasename | 是 | InfluxDB 数据库名称 |
| tagkey | 是 | InfluxDB 的标签键 |
| tagvalue | 是 | InfluxDB 的标签值 |
TDengine ¶
该操作用于将输出消息发布到 TDengine 服务器中。
| 名称 | 是否必填 | 说明 |
|---|---|---|
| 实例名称 | 否 | 实例名称，请保证该参数的唯一性。 |
| host | 否 | 数据库域名，其值必须为域名，即 FQDN，不能为 IP 地址。其默认值为 localhost。 |
| port | 是 | 数据库端口 |
| user | 否 | 用户名，默认值为 root 。 |
| password | 否 | 密码，默认值为 taosdata 。 |
| database | 是 | 数据库名 |
| table | 是 | 表名。 |
| fields | 否 | 将要插入的表字段集合。sink 收到的数据和数据库表中均有该字段。若未设置，则所有结果字段写入数据库。 |
| provideTs | 否 | 用户是否提供时间戳字段，默认为否。 |
| tsFieldName | 是 | 时间戳字段名称 |
| sTable | 否 | 使用的超级表。 |
| tagFields | 否 | 结果中作为标签的字段。若设置 sTable 属性，则该属性必填。 |
| tableDataField | 否 | 将 tableDataField 的嵌套值写入数据库。 |