RabbitMq流转参数

参数说明

数据源

• 数据流转数据源选择
• 全部设备产品、选择的产品下所有设备、产品和设备
• 必选

描述

• 声明此数据流转相关信息
• 非必填

名称

• 定义数据流转名称
• 必填
• 支持输入的长度限制：32个字符
• 支持输入的格式：中英文、字符、数字

交换名称模式

• 传输模式
• 非必填

路由密匙模式

• 传输模式
• 非必填

消息属性

• 消息属性选择方式
• 非必选

主机、端口、虚拟端口

• 服务器主机、端口、自定义虚拟端口
• 主机与端口必填，虚拟端口非必填

用户名、密码

• Rabbit配置用户名和密码
• 非必须

连接超时、握手超时

• 超时时间
• 非必填

客户端属性

• key和value形式
• 非必填

说明

• 该传输方式的说明
• 非必填

REST_API流转参数

参数说明

数据源

• 数据流转数据源选择
• 全部设备产品、选择的产品下所有设备、产品和设备

• 必选

描述

• 声明此数据流转相关信息
• 非必填

名称

• 定义数据流转名称
• 支持输入长度限制：32个字符
• 支持输入的格式：中英文、字符、数字
• 必填

端点URL模式、请求方式

• 请求URL地址和请求方式
• URL必填，请求方式不必选

代理请求、系统代理属性、请求正文

• 是否选择代理进行配置
• 非必填

读取超时、最大并行请求数

• 超时时间和最大并行请求数
• 必填

Headers

• 请求头数据格式
• 非必填

redis队列进行消息持久性

• 消息队列持久是否启用
• 非必填

凭据类型

• Anymous、Basic、PEM凭据
• 非必选

说明

• 该传输方式的说明
• 非必填

MQTT流转参数

参数说明

数据源

• 数据流转数据源选择
• 全部设备产品、选择的产品下所有设备、产品和设备
• 必选

描述

• 声明此数据流转相关信息
• 非必填

名称

• 定义数据流转名称
• 必填
• 支持输入长度限制：32个字符
• 支持输入的格式：中英文、字符、数字

主题模式

• 订阅消息主题
• 必填

主机、端口

• 服务器主机地址和端口
• 必填

连接超时

• 连接超时时间
• 必填

客户端ID

• 唯一ID配置，不必填
• 非必填

清除会话、启用SSL

• 清除当前会话和安全协议启用
• 非必填

凭据类型

• Anymous、Basic、PEM凭据
• 选择Basic时必填，其余非必填

说明

• 该传输方式的说明
• 非必填

Kafka流转参数

参数说明

数据源

• 数据流转数据源选择
• 全部设备产品、选择的产品下所有设备、产品和设备
• 必选

描述

• 声明此数据流转相关信息
• 非必填

名称

• 定义数据流转名称
• 支持输入长度限制：32个字符
• 支持输入的格式：中英文、字符、数字
• 必填

消息主题

• 订阅消息主题
• 必填

服务器

• 服务器地址和端口
• 必填

重连次数

• 定义重连次数
• 非必填

生产者并发

• 并发量
• 非必填

缓存时间、最大缓存

• 时间设置和最大缓存设置
• 非必填

响应码

• 响应码设置
• 非必选

键序列化、值序列化

• 键值对序列化数据
• 必填

其他属性

• 增加其他Key，value属性
• 非必填

将消息的元数据以键值对的方式添加到Kafka消息头中

• 是否启用该功能
• 非必填

说明

• 该传输方式的说明
• 非必填

功能模块

属性名称

属性值说明

SSL

ssl.keystore.certificate.chain

ssl.keystore.key

ssl.truststore.certificates

Kafka鉴权

ssl.endpoint.identification.algorithm

Kafka Broker是否验证主机名，例如：http

security.protocol

Kafka Broker与客户端的通信安全协议，例如：SASL_PLAINTEXT

sasl.mechanism

Kafka Broker的认证机制，例如：SCRAM-SHA-512

sasl.jaas.config

Kafka Broker的JAAS 认证信息，例如：org.apache.kafka.common.security.scram.ScramLoginModule required username="账号" password="密码";