森数据DIX说明文档

# 共济科技

共济数据集成

# 共济-restful 告警配置

页面选择 事件-restful，如下图所示。

选择DIP实例实例类型图

# 属性配置

DIP实例实例配置

  • 名称：输入DIP实例名称。

# IN配置

DIP实例配置

  • 主机：共济restful服务器的主机IP
  • 端口：共济restful服务器的端口
  • 登录URL：登录共济restful系统的URL
  • 用户名：登录共济restful系统所需的用户名
  • 密码：登录共济restful系统所需的密码
  • 数据库IP：产品数据库的IP
  • 数据库用户名：产品数据库的用户名
  • 数据库密码：产品数据库的密码
  • 数据库端口号：产品数据库的端口号
  • 告警URL：查询共济restful告警的URL
  • 配置文件：共济提供的测点表，格式如下图所示： 配置文件图
    • 其中tag_no为测点编号，dev_name为设备名称，tag_name为指标名称，工作表名称为xbrother
  • 轮询间隔：告警数据采集时间间隔 默认60秒
  • 告警源：EMV中定义的告警源，项目通常要对接来自不同系统的告警，依照该字段来区分不同系统的告警

注：共济restful推过来的告警都是实时告警，故需要在数据库db_vmdb下创建一个数据表缓存告警数据，数据库字段包括dipId，SourceCIName，SourceAlertKey，SourceEventID，SourceSeverity，Summary，Severity， SourceID， Status， LastOccurrence，SourceIdentifier，类型为varchar，长度255，数据表名称为CachedEvents，编码格式为utf-8

# 级别映射

重要

共济restful的默认告警级别，与森数据DIX告警级别不匹配，需要通过映射来进行匹配

  • 从：共济restful的告警级别
  • 到：森数据DIX的告警级别（1为最高级别）

级别映射配置，若无特殊需求，无需更改

从 到
1 1
2 2
3 3
4 4
5 4

# Out配置

告警的发送方式选择：点击添加，选择对应的发送方式将数据进行发送

输出方式选择


  • MYSQL

选择此项会将数据保存至mysql库，配置项如下：

MysqlOut

配置项名称 配置项描述 示例
URL（必填项） 数据库地址 jdbc:mysql://0.0.0.0:3306/db_vmdb?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2b8
用户名（必填项） 数据库用户名 username
密码（必填项） 数据库密码 password
是否保存历史数据（必填项） 默认为是，保存历史数据 是

  • ES

选择此项会将数据保存至ES库，配置项如下：

EsOut

配置项名称 配置项描述 示例
ES请求地址（必填项） 数据库地址 0.0.0.0:9200
用户名 数据库用户名 username
密码 数据库密码 password
ES性能数据保留天数（必填项） 默认为7，保存7天内的性能数据 7
数据域 ThingJS-X数据域ID （可选）

  • ACTIVEMQ

选择此项会将数据发送至ActiveMQ，配置项如下：

ActivemqOut

配置项名称 配置项描述 示例
URL（必填项） ActiveMQ地址 failover://(tcp://0.0.0.0:61616,tcp://0.0.0.0:61616)?randomize=false&timeout=5000&maxReconnectAttempts=-1
队列名（必填项） ActiveMQ队列名称 queue
用户名 ActiveMQ用户名 username
密码 ActiveMQ密码 password

  • RABBITMQ

选择此项会将数据发送至RabbitMQ，配置项如下：

RabbitmqOut

配置项名称 配置项描述 示例
URL（必填项） RabbitMQ地址 0.0.0.0
端口（必填项） RabbitMQ端口号 12000
用户名 RabbitMQ用户名 username
密码 RabbitMQ密码 password
RabbitMq工作模式（必填项） 共有：简单模式，订阅模式，路由模式和Topic四种模式；默认为简单模式 简单模式
RabbitMq交换机或队列名称以及路由键（必填项） 根据工作模式填写json数据 如下表所示
交换机或队列是否持久化（必填项） 默认为否，不支持持久化 否
无服务时是否自动删除队列或者交换机（必填项） 默认为否，不会自动删除队列或交换机 否
RabbitMq工作模式 对应json
简单模式 {"name":"交换机名称"}
订阅模式 {"name":"交换机名称"}
路由模式 {"name":"交换机名称","routingKey":"路由键"}
Topic模式 {"name":"交换机名称","routingKey":"路由键"}

注：此处的交换机名称和路由键按照实际情况填写


  • ROCKETMQ

选择此项会将数据发送至RocketMQ，配置项如下：

RocketmqOut

配置项名称 配置项描述 示例
请求地址（必填项） RocketMQ地址 0.0.0.0:9876;0.0.0.0:9876
生产者组别 RocketMQ生产者组别 producerGroup
消息发送主题 消息发送主题 topicA
消息标签 消息标签 tagA
超时时间 消息发送超时时间，单位为毫秒 30000
字符集 字符编码集，默认UTF-8 UTF-8
消息发送类型 分为：异步发送，单向发送，同步发送共三种；默认为异步发送 异步发送

  • KAFKA

选择此项会将数据发送至kafka，配置项如下：

KafkaOut

配置项名称 配置项描述 示例
请求地址（必填项） kafka地址 0.0.0.0:9092;0.0.0.0:9092
消息发送主题（必填项） 消息发送主题 topicA
sasl静态认证文件地址（非必填） sasl conf认证文件位置 /uinnova/dix/kafka_sasl_jaas.conf
用户名（非必填） Kafka动态认证用户名 username
密码（非必填） Kafka动态认证密码 password
密码加密算法（非必填） 对密码进行加密的算法，下拉框中二选一 SCRAM-SHA-256 或 SCRAM-SHA-512
延迟（非必填） 消息发送延迟，单位为秒 1

  • MQTT

选择此项会将数据发送至mqtt，配置项如下：

MqttOut

配置项名称 配置项描述 示例
URL（必填项） mqtt地址 tcp://127.0.0.0:1883
MQTT客户端ID（必填项） mqtt客户端ID clientID101
用户名 mqtt用户名 username
密码 mqtt密码 password
消息发送主题 消息发送主题 topicA
消息发送质量 分为：仅分发一次，至少分发一次，最多分发一次共三种；默认仅分发一次 仅分发一次
字符集 字符编码集，默认UTF-8 UTF-8

  • HTTPPOST

选择此项会将数据通过post请求发送至http服务，配置项如下：

HttppostOut

配置项名称 配置项描述 示例
http服务路径（必填项） http服务地址 http://0.0.0.0:0000
请求头 填写json格式的参数 {"key":"value"}
字符集 字符编码集，默认utf-8 utf-8

  • HTTPSPOST

选择此项会将数据通过post请求发送至https服务，配置项如下：

HttpspostOut

配置项名称 配置项描述 示例
http服务路径（必填项） https服务地址 https://0.0.0.0:0000
请求头 填写json格式的参数 {"key":"value"}
字符集 字符编码集，默认utf-8 utf-8

  • DIP实例的保存与启动

    • 配置信息填写完成后，点击保存，成功保存后会在森数据DIX的数据集成页面看到新建的DIP实例

    新建DIP实例

    • 点击开始/启动按钮。

    新建DIP实例

    名词解释

    已接入：当前数据接口接入到的总数据量
    处理中：当前数据接口正在进行处理的数据量
    发送中：当前数据接口正在向外部发送的数据量
    已发送：当前数据接口发送到外部的总数据量

    待启动成功之后，点击日志按钮，查看数据是否能正常接入






# 共济-restful 性能配置

页面选择 性能-restful，如下图所示。

选择DIP实例类型图

# 属性配置

DIP实例配置

  • 名称：输入DIP实例名称。

# IN配置

DIP实例 IN配置

  • IP：共济restful服务器的主机IP
  • 端口：部署共济restful服务器的端口
  • 登录URL：登录共济restful系统的URL
  • 用户名：登录共济系统的用户名
  • 密码：登录共济系统的密码
  • 性能URL：获取详细性能指标的URL
  • 配置文件：共济提供的测点表，格式如下图所示： 配置文件图
    • 其中tag_no为测点编号，dev_name为设备名称，tag_name为指标名称，工作表名称为xbrother
  • 轮询周期：性能数据采集周期 默认600秒

# Out配置

告警的发送方式选择：点击添加，选择对应的发送方式将数据进行发送

输出方式选择


  • MYSQL

选择此项会将数据保存至mysql库，配置项如下：

MysqlOut

配置项名称 配置项描述 示例
URL（必填项） 数据库地址 jdbc:mysql://0.0.0.0:3306/db_vmdb?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2b8
用户名（必填项） 数据库用户名 username
密码（必填项） 数据库密码 password
是否保存历史数据（必填项） 默认为是，保存历史数据 是

  • ES

选择此项会将数据保存至ES库，配置项如下：

EsOut

配置项名称 配置项描述 示例
ES请求地址（必填项） 数据库地址 0.0.0.0:9200
用户名 数据库用户名 username
密码 数据库密码 password
ES性能数据保留天数（必填项） 默认为7，保存7天内的性能数据 7
数据域 ThingJS-X数据域ID （可选）

  • ACTIVEMQ

选择此项会将数据发送至ActiveMQ，配置项如下：

ActivemqOut

配置项名称 配置项描述 示例
URL（必填项） ActiveMQ地址 failover://(tcp://0.0.0.0:61616,tcp://0.0.0.0:61616)?randomize=false&timeout=5000&maxReconnectAttempts=-1
队列名（必填项） ActiveMQ队列名称 queue
用户名 ActiveMQ用户名 username
密码 ActiveMQ密码 password

  • RABBITMQ

选择此项会将数据发送至RabbitMQ，配置项如下：

RabbitmqOut

配置项名称 配置项描述 示例
URL（必填项） RabbitMQ地址 0.0.0.0
端口（必填项） RabbitMQ端口号 12000
用户名 RabbitMQ用户名 username
密码 RabbitMQ密码 password
RabbitMq工作模式（必填项） 共有：简单模式，订阅模式，路由模式和Topic四种模式；默认为简单模式 简单模式
RabbitMq交换机或队列名称以及路由键（必填项） 根据工作模式填写json数据 如下表所示
交换机或队列是否持久化（必填项） 默认为否，不支持持久化 否
无服务时是否自动删除队列或者交换机（必填项） 默认为否，不会自动删除队列或交换机 否
RabbitMq工作模式 对应json
简单模式 {"name":"交换机名称"}
订阅模式 {"name":"交换机名称"}
路由模式 {"name":"交换机名称","routingKey":"路由键"}
Topic模式 {"name":"交换机名称","routingKey":"路由键"}

注：此处的交换机名称和路由键按照实际情况填写


  • ROCKETMQ

选择此项会将数据发送至RocketMQ，配置项如下：

RocketmqOut

配置项名称 配置项描述 示例
请求地址（必填项） RocketMQ地址 0.0.0.0:9876;0.0.0.0:9876
生产者组别 RocketMQ生产者组别 producerGroup
消息发送主题 消息发送主题 topicA
消息标签 消息标签 tagA
超时时间 消息发送超时时间，单位为毫秒 30000
字符集 字符编码集，默认UTF-8 UTF-8
消息发送类型 分为：异步发送，单向发送，同步发送共三种；默认为异步发送 异步发送

  • KAFKA

选择此项会将数据发送至kafka，配置项如下：

KafkaOut

配置项名称 配置项描述 示例
请求地址（必填项） kafka地址 0.0.0.0:9092;0.0.0.0:9092
消息发送主题（必填项） 消息发送主题 topicA
sasl静态认证文件地址（非必填） sasl conf认证文件位置 /uinnova/dix/kafka_sasl_jaas.conf
用户名（非必填） Kafka动态认证用户名 username
密码（非必填） Kafka动态认证密码 password
密码加密算法（非必填） 对密码进行加密的算法，下拉框中二选一 SCRAM-SHA-256 或 SCRAM-SHA-512
延迟（非必填） 消息发送延迟，单位为秒 1

  • MQTT

选择此项会将数据发送至mqtt，配置项如下：

MqttOut

配置项名称 配置项描述 示例
URL（必填项） mqtt地址 tcp://127.0.0.0:1883
MQTT客户端ID（必填项） mqtt客户端ID clientID101
用户名 mqtt用户名 username
密码 mqtt密码 password
消息发送主题 消息发送主题 topicA
消息发送质量 分为：仅分发一次，至少分发一次，最多分发一次共三种；默认仅分发一次 仅分发一次
字符集 字符编码集，默认UTF-8 UTF-8

  • HTTPPOST

选择此项会将数据通过post请求发送至http服务，配置项如下：

HttppostOut

配置项名称 配置项描述 示例
http服务路径（必填项） http服务地址 http://0.0.0.0:0000
请求头 填写json格式的参数 {"key":"value"}
字符集 字符编码集，默认utf-8 utf-8

  • HTTPSPOST

选择此项会将数据通过post请求发送至https服务，配置项如下：

HttpspostOut

配置项名称 配置项描述 示例
http服务路径（必填项） https服务地址 https://0.0.0.0:0000
请求头 填写json格式的参数 {"key":"value"}
字符集 字符编码集，默认utf-8 utf-8

  • DIP实例的保存与启动

    • 配置信息填写完成后，点击保存，成功保存后会在森数据DIX的数据集成页面看到新建的DIP实例

    新建DIP实例

    • 点击开始/启动按钮。

    新建DIP实例

    名词解释

    已接入：当前数据接口接入到的总数据量
    处理中：当前数据接口正在进行处理的数据量
    发送中：当前数据接口正在向外部发送的数据量
    已发送：当前数据接口发送到外部的总数据量

    待启动成功之后，点击日志按钮，查看数据是否能正常接入

# 共济-socket 告警配置

# 适用范围

仅支持共济V6版本的socket接口，项目现场负责人员，在做调研时需找厂商了解清楚。

页面选择 事件，如下图所示。

选择DIP实例类型图

# 属性配置

DIP实例配置

  • 名称：输入DIP名称。

# IN配置

DIP实例配置

  • 主机：共济服务端程序的主机IP
  • 端口：共济服务端程序占用的端口
  • 告警源：EMV中定义的告警源，项目通常要对接来自不同系统的告警，依照该字段来区分不同系统的告警，默认为23
  • 配置文件：Excel文件，需共济厂商提供，如下图所示 共济配置文件
    • 文件sheet名称必须是xbrother
    • tag_no：测点编号，即为指标编号
    • dev_name：设备名称，该名称要与DCV中Visio中配置的独立设备的ID保持一致
    • tag_name：测点名称，即为指标名称，该数据可用共济提供的名称，也可以自己根据需要进行修改

# 数据映射

从列表下的是共济的数据属性名称，到列表下的是映射的tarsier中的数据属性名称。

# 级别映射

重要

共济的默认告警级别，与森数据DIX告警级别不匹配，需要通过映射来进行匹配

  • 从：共济的告警级别
  • 到：森数据DIX的告警级别（1为最高级别）

级别映射配置，若无特殊需求，无需更改

从 到
10 1
9 2
8 3
7 4
6 5
5 6
4 6
3 6
2 6
1 6

# Out配置

告警的发送方式选择：点击添加，选择对应的发送方式将数据进行发送

输出方式选择


  • MYSQL

选择此项会将数据保存至mysql库，配置项如下：

MysqlOut

配置项名称 配置项描述 示例
URL（必填项） 数据库地址 jdbc:mysql://0.0.0.0:3306/db_vmdb?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2b8
用户名（必填项） 数据库用户名 username
密码（必填项） 数据库密码 password
是否保存历史数据（必填项） 默认为是，保存历史数据 是

  • ES

选择此项会将数据保存至ES库，配置项如下：

EsOut

配置项名称 配置项描述 示例
ES请求地址（必填项） 数据库地址 0.0.0.0:9200
用户名 数据库用户名 username
密码 数据库密码 password
ES性能数据保留天数（必填项） 默认为7，保存7天内的性能数据 7
数据域 ThingJS-X数据域ID （可选）

  • ACTIVEMQ

选择此项会将数据发送至ActiveMQ，配置项如下：

ActivemqOut

配置项名称 配置项描述 示例
URL（必填项） ActiveMQ地址 failover://(tcp://0.0.0.0:61616,tcp://0.0.0.0:61616)?randomize=false&timeout=5000&maxReconnectAttempts=-1
队列名（必填项） ActiveMQ队列名称 queue
用户名 ActiveMQ用户名 username
密码 ActiveMQ密码 password

  • RABBITMQ

选择此项会将数据发送至RabbitMQ，配置项如下：

RabbitmqOut

配置项名称 配置项描述 示例
URL（必填项） RabbitMQ地址 0.0.0.0
端口（必填项） RabbitMQ端口号 12000
用户名 RabbitMQ用户名 username
密码 RabbitMQ密码 password
RabbitMq工作模式（必填项） 共有：简单模式，订阅模式，路由模式和Topic四种模式；默认为简单模式 简单模式
RabbitMq交换机或队列名称以及路由键（必填项） 根据工作模式填写json数据 如下表所示
交换机或队列是否持久化（必填项） 默认为否，不支持持久化 否
无服务时是否自动删除队列或者交换机（必填项） 默认为否，不会自动删除队列或交换机 否
RabbitMq工作模式 对应json
简单模式 {"name":"交换机名称"}
订阅模式 {"name":"交换机名称"}
路由模式 {"name":"交换机名称","routingKey":"路由键"}
Topic模式 {"name":"交换机名称","routingKey":"路由键"}

注：此处的交换机名称和路由键按照实际情况填写


  • ROCKETMQ

选择此项会将数据发送至RocketMQ，配置项如下：

RocketmqOut

配置项名称 配置项描述 示例
请求地址（必填项） RocketMQ地址 0.0.0.0:9876;0.0.0.0:9876
生产者组别 RocketMQ生产者组别 producerGroup
消息发送主题 消息发送主题 topicA
消息标签 消息标签 tagA
超时时间 消息发送超时时间，单位为毫秒 30000
字符集 字符编码集，默认UTF-8 UTF-8
消息发送类型 分为：异步发送，单向发送，同步发送共三种；默认为异步发送 异步发送

  • KAFKA

选择此项会将数据发送至kafka，配置项如下：

KafkaOut

配置项名称 配置项描述 示例
请求地址（必填项） kafka地址 0.0.0.0:9092;0.0.0.0:9092
消息发送主题（必填项） 消息发送主题 topicA
sasl静态认证文件地址（非必填） sasl conf认证文件位置 /uinnova/dix/kafka_sasl_jaas.conf
用户名（非必填） Kafka动态认证用户名 username
密码（非必填） Kafka动态认证密码 password
密码加密算法（非必填） 对密码进行加密的算法，下拉框中二选一 SCRAM-SHA-256 或 SCRAM-SHA-512
延迟（非必填） 消息发送延迟，单位为秒 1

  • MQTT

选择此项会将数据发送至mqtt，配置项如下：

MqttOut

配置项名称 配置项描述 示例
URL（必填项） mqtt地址 tcp://127.0.0.0:1883
MQTT客户端ID（必填项） mqtt客户端ID clientID101
用户名 mqtt用户名 username
密码 mqtt密码 password
消息发送主题 消息发送主题 topicA
消息发送质量 分为：仅分发一次，至少分发一次，最多分发一次共三种；默认仅分发一次 仅分发一次
字符集 字符编码集，默认UTF-8 UTF-8

  • HTTPPOST

选择此项会将数据通过post请求发送至http服务，配置项如下：

HttppostOut

配置项名称 配置项描述 示例
http服务路径（必填项） http服务地址 http://0.0.0.0:0000
请求头 填写json格式的参数 {"key":"value"}
字符集 字符编码集，默认utf-8 utf-8

  • HTTPSPOST

选择此项会将数据通过post请求发送至https服务，配置项如下：

HttpspostOut

配置项名称 配置项描述 示例
http服务路径（必填项） https服务地址 https://0.0.0.0:0000
请求头 填写json格式的参数 {"key":"value"}
字符集 字符编码集，默认utf-8 utf-8

  • DIP实例的保存与启动

    • 配置信息填写完成后，点击保存，成功保存后会在森数据DIX的数据集成页面看到新建的DIP实例

    新建DIP实例

    • 点击开始/启动按钮。

    新建DIP实例

    名词解释

    已接入：当前数据接口接入到的总数据量
    处理中：当前数据接口正在进行处理的数据量
    发送中：当前数据接口正在向外部发送的数据量
    已发送：当前数据接口发送到外部的总数据量

    待启动成功之后，点击日志按钮，查看数据是否能正常接入






# 共济-socket 性能配置

# 适用范围

仅支持共济V6版本的socket接口，项目现场负责人员，在做调研时需找厂商了解清楚。

页面选择 性能，如下图所示。

选择DIP实例类型图

# 属性配置

DIP实例配置

  • 名称：输入DIP实例名称。

# IN配置

DIP实例配置

  • 主机：共济服务端程序的主机IP
  • 端口：共济服务端程序占用的端口
  • 配置文件：Excel文件，需共济厂商提供，如下图所示 共济配置文件
    • 文件sheet名称必须是xbrother
    • tag_no：测点编号，即为指标编号
    • dev_name：设备名称，该名称要与DCV中Visio中配置的独立设备的ID保持一致。
    • tag_name：测点名称，即为指标名称，该数据可用共济提供的名称，也可以自己根据需要进行修改

# 数据映射

从列表下的是共济的数据属性名称，到列表下的是映射的tarsier中的数据属性名称。

# Out配置

告警的发送方式选择：点击添加，选择对应的发送方式将数据进行发送

输出方式选择


  • MYSQL

选择此项会将数据保存至mysql库，配置项如下：

MysqlOut

配置项名称 配置项描述 示例
URL（必填项） 数据库地址 jdbc:mysql://0.0.0.0:3306/db_vmdb?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2b8
用户名（必填项） 数据库用户名 username
密码（必填项） 数据库密码 password
是否保存历史数据（必填项） 默认为是，保存历史数据 是

  • ES

选择此项会将数据保存至ES库，配置项如下：

EsOut

配置项名称 配置项描述 示例
ES请求地址（必填项） 数据库地址 0.0.0.0:9200
用户名 数据库用户名 username
密码 数据库密码 password
ES性能数据保留天数（必填项） 默认为7，保存7天内的性能数据 7
数据域 ThingJS-X数据域ID （可选）

  • ACTIVEMQ

选择此项会将数据发送至ActiveMQ，配置项如下：

ActivemqOut

配置项名称 配置项描述 示例
URL（必填项） ActiveMQ地址 failover://(tcp://0.0.0.0:61616,tcp://0.0.0.0:61616)?randomize=false&timeout=5000&maxReconnectAttempts=-1
队列名（必填项） ActiveMQ队列名称 queue
用户名 ActiveMQ用户名 username
密码 ActiveMQ密码 password

  • RABBITMQ

选择此项会将数据发送至RabbitMQ，配置项如下：

RabbitmqOut

配置项名称 配置项描述 示例
URL（必填项） RabbitMQ地址 0.0.0.0
端口（必填项） RabbitMQ端口号 12000
用户名 RabbitMQ用户名 username
密码 RabbitMQ密码 password
RabbitMq工作模式（必填项） 共有：简单模式，订阅模式，路由模式和Topic四种模式；默认为简单模式 简单模式
RabbitMq交换机或队列名称以及路由键（必填项） 根据工作模式填写json数据 如下表所示
交换机或队列是否持久化（必填项） 默认为否，不支持持久化 否
无服务时是否自动删除队列或者交换机（必填项） 默认为否，不会自动删除队列或交换机 否
RabbitMq工作模式 对应json
简单模式 {"name":"交换机名称"}
订阅模式 {"name":"交换机名称"}
路由模式 {"name":"交换机名称","routingKey":"路由键"}
Topic模式 {"name":"交换机名称","routingKey":"路由键"}

注：此处的交换机名称和路由键按照实际情况填写


  • ROCKETMQ

选择此项会将数据发送至RocketMQ，配置项如下：

RocketmqOut

配置项名称 配置项描述 示例
请求地址（必填项） RocketMQ地址 0.0.0.0:9876;0.0.0.0:9876
生产者组别 RocketMQ生产者组别 producerGroup
消息发送主题 消息发送主题 topicA
消息标签 消息标签 tagA
超时时间 消息发送超时时间，单位为毫秒 30000
字符集 字符编码集，默认UTF-8 UTF-8
消息发送类型 分为：异步发送，单向发送，同步发送共三种；默认为异步发送 异步发送

  • KAFKA

选择此项会将数据发送至kafka，配置项如下：

KafkaOut

配置项名称 配置项描述 示例
请求地址（必填项） kafka地址 0.0.0.0:9092;0.0.0.0:9092
消息发送主题（必填项） 消息发送主题 topicA
sasl静态认证文件地址（非必填） sasl conf认证文件位置 /uinnova/dix/kafka_sasl_jaas.conf
用户名（非必填） Kafka动态认证用户名 username
密码（非必填） Kafka动态认证密码 password
密码加密算法（非必填） 对密码进行加密的算法，下拉框中二选一 SCRAM-SHA-256 或 SCRAM-SHA-512
延迟（非必填） 消息发送延迟，单位为秒 1

  • MQTT

选择此项会将数据发送至mqtt，配置项如下：

MqttOut

配置项名称 配置项描述 示例
URL（必填项） mqtt地址 tcp://127.0.0.0:1883
MQTT客户端ID（必填项） mqtt客户端ID clientID101
用户名 mqtt用户名 username
密码 mqtt密码 password
消息发送主题 消息发送主题 topicA
消息发送质量 分为：仅分发一次，至少分发一次，最多分发一次共三种；默认仅分发一次 仅分发一次
字符集 字符编码集，默认UTF-8 UTF-8

  • HTTPPOST

选择此项会将数据通过post请求发送至http服务，配置项如下：

HttppostOut

配置项名称 配置项描述 示例
http服务路径（必填项） http服务地址 http://0.0.0.0:0000
请求头 填写json格式的参数 {"key":"value"}
字符集 字符编码集，默认utf-8 utf-8

  • HTTPSPOST

选择此项会将数据通过post请求发送至https服务，配置项如下：

HttpspostOut

配置项名称 配置项描述 示例
http服务路径（必填项） https服务地址 https://0.0.0.0:0000
请求头 填写json格式的参数 {"key":"value"}
字符集 字符编码集，默认utf-8 utf-8

  • DIP实例的保存与启动

    • 配置信息填写完成后，点击保存，成功保存后会在森数据DIX的数据集成页面看到新建的DIP实例

    新建DIP实例

    • 点击开始/启动按钮。

    新建DIP实例

    名词解释

    已接入：当前数据接口接入到的总数据量
    处理中：当前数据接口正在进行处理的数据量
    发送中：当前数据接口正在向外部发送的数据量
    已发送：当前数据接口发送到外部的总数据量

    待启动成功之后，点击日志按钮，查看数据是否能正常接入

上次更新时间: 3/20/2023, 9:06:32 AM

← 盈泽世纪 →