526互联

ThingsKit物联网平台产品规则引擎操作之数据流转

发布时间 2023-08-16 10:01:25作者: ThingsKit物联网平台

将物联网平台数据流转到其他第三方平台或中间件，进行应用开发或实现平台数据共享。

新增流转

点击添加流转，转换方式可以选择四种传输方式：Kafka、RabbitMq、Mqtt、Rest_Api。
:::info
? 提示
数据源可以选择三种：1.全部，2.产品：然后所有设备配置此产品都生效 3.也可以选择产品后选择关联的设备来实现流转。
:::

RabbitMQ

数据流转新增Gif.gif

RabbitMq流转参数 参数说明
数据源
  • 数据流转数据源选择
  • 全部设备产品、选择的产品下所有设备、产品和设备
  • 必选
    |
    | 描述 |
  • 声明此数据流转相关信息
  • 非必填
    |
    | 名称 |
  • 定义数据流转名称
  • 必填
  • 支持输入的长度限制：32个字符
  • 支持输入的格式：中英文、字符、数字
    |
    | 交换名称模式 |
  • 传输模式
  • 非必填
    |
    | 路由密匙模式 |
  • 传输模式
  • 非必填
    |
    | 消息属性 |
  • 消息属性选择方式
  • 非必选
    |
    | 主机、端口、虚拟端口 |
  • 服务器主机、端口、自定义虚拟端口
  • 主机与端口必填，虚拟端口非必填
    |
    | 用户名、密码 |
  • Rabbit配置用户名和密码
  • 非必须
    |
    | 连接超时、握手超时 |
  • 超时时间
  • 非必填
    |
    | 客户端属性 |
  • key和value形式
  • 非必填
    |
    | 说明 |
  • 该传输方式的说明
  • 非必填
    |

REST_API

数据流转新增APIGif.gif

REST_API流转参数 参数说明
数据源
  • 数据流转数据源选择
  • 全部设备产品、选择的产品下所有设备、产品和设备
  • 必选
    |
    | 描述 |
  • 声明此数据流转相关信息
  • 非必填
    |
    | 名称 |
  • 定义数据流转名称
  • 支持输入长度限制：32个字符
  • 支持输入的格式：中英文、字符、数字
  • 必填
    |
    | 端点URL模式、请求方式 |
  • 请求URL地址和请求方式
  • URL必填，请求方式不必选
    |
    | 代理请求、系统代理属性、请求正文 |
  • 是否选择代理进行配置
  • 非必填
    |
    | 读取超时、最大并行请求数 |
  • 超时时间和最大并行请求数
  • 必填
    |
    | Headers |
  • 请求头数据格式
  • 非必填
    |
    | redis队列进行消息持久性 |
  • 消息队列持久是否启用
  • 非必填
    |
    | 凭据类型 |
  • Anymous、Basic、PEM凭据
  • 非必选
    |
    | 说明 |
  • 该传输方式的说明
  • 非必填
    |

MQTT

数据流转新增MQTTGif.gif

MQTT流转参数 参数说明
数据源
  • 数据流转数据源选择
  • 全部设备产品、选择的产品下所有设备、产品和设备
  • 必选
    |
    | 描述 |
  • 声明此数据流转相关信息
  • 非必填
    |
    | 名称 |
  • 定义数据流转名称
  • 必填
  • 支持输入长度限制：32个字符
  • 支持输入的格式：中英文、字符、数字
    |
    | 主题模式 |
  • 订阅消息主题
  • 必填
    |
    | 主机、端口 |
  • 服务器主机地址和端口
  • 必填
    |
    | 连接超时 |
  • 连接超时时间
  • 必填
    |
    | 客户端ID |
  • 唯一ID配置，不必填
  • 非必填
    |
    | 清楚会话、启用SSL |
  • 清楚当前会话和安全协议启用
  • 非必填
    |
    | 凭据类型 |
  • Anymous、Basic、PEM凭据
  • 选择Basic时必填，其余非必填
    |
    | 说明 |
  • 该传输方式的说明
  • 非必填
    |

Kafka

数据流转新增kafkaGif.gif

Kafka流转参数 参数说明
数据源
  • 数据流转数据源选择
  • 全部设备产品、选择的产品下所有设备、产品和设备
  • 必选
    |
    | 描述 |
  • 声明此数据流转相关信息
  • 非必填
    |
    | 名称 |
  • 定义数据流转名称
  • 支持输入长度限制：32个字符
  • 支持输入的格式：中英文、字符、数字
  • 必填
    |
    | 消息主题 |
  • 订阅消息主题
  • 必填
    |
    | 服务器 |
  • 服务器地址和端口
  • 必填
    |
    | 重连次数 |
  • 定义重连次数
  • 非必填
    |
    | 生产者并发 |
  • 并发量
  • 非必填
    |
    | 缓存时间、最大缓存 |
  • 时间设置和最大缓存设置
  • 非必填
    |
    | 响应码 |
  • 响应码设置
  • 非必选
    |
    | 键序列化、值序列化 |
  • 键值对序列化数据
  • 必填
    |
    | 其他属性 |
  • 增加其他Key，value属性
  • 非必填
    |
    | 将消息的元数据以键值对的方式添加到Kafka消息头中 |
  • 是否启用该功能
  • 非必填
    |
    | 说明 |
  • 该传输方式的说明
  • 非必填
    |

编辑

选择流转数据进行编辑，点击确认编辑成功。
数据流转编辑kafkaGif.gif

启用

点击状态栏启用禁用按钮，启用数据流转才会生效。
数据流转启用Gif.gif

搜索

输入数据流转名称和根据状态进行搜索数据。
数据流转搜索Gif.gif

批量启用

选择左边方框，勾中数据进行批量启用功能。
数据流转批量启用Gif.gif

删除

对数据流转进行删除或者批量删除。
数据流转删除Gif.gif
:::info
? 提示
数据流转启用状态无法编辑和删除，只可查看。
:::

文章来源（首发地址）：ThingsKit物联网平台