# SNMP
简述
SNMP DIP插件主要适用于采用snmp方式的数据对接场景,现有版本支持 snmp-get。snmp-trap,snmp-getBulk,snmp-getSubtree,snmp-getWalk。
# 告警-trap的配置
- 在配置页面选择告警-trap
# DIP实例配置
- 名称:DIP实例名称
# IN配置
- IP: 宿主机的IP
- 端口: 服务器的端口。可自定义,默认162
- 协议(udp/tcp): 接收数据的方式。根据需求任选其一
- 字符集: 默认utf-8
- 告警源: 根据实际情况到EMV中添加事件源获取编号
- SNMP版本: version1,version2c,version3根据需求选择
- 用户名: SNMP v3用户名
- 数据加密密码: SNMP v3数据加密密码
- 授权认证密码: SNMP V3授权认证密码
- 数据加密协议: SNMP V3数据加密时使用的协议
- 授权认证协议: SNMP V3授权认证时使用的协议
# OID映射
从
代表告警oid,到
代表oid对应的字段。
注意:到
的下方不用修改,使oid和字段一一对应即可。oid的填写样例:${2011.2.15.2.4.3.3.7.0}从 到 映射CI oid1 SourceCIName 映射CI oid1 Summary oid1 SourceAlertKey oid1 SourceSeverity oid1 Severity oid1 SourceEventID oid1 LastOccurrence oid1 Status _ SourceIdentifier
备注1
SourceCIName需要处理映射CI
- CI映射是为了告警挂载,将对方系统的告警匹配到发生该告警的设备(森数据DIX系统中的设备)上,此属性值有以下几种方式:
- 1)当${oid}在对方系统中具有唯一性,且${oid}是CI分类中的主键。此处不填任何内容,会默认按照主键查找。
- 2)当${oid}在对方系统中具有唯一性,但${oid}不是CI分类中的主键。此时填写分类名。属性名(CMV中的分类及属性名,该属性必须能够
唯一标识CI
)。如X86宿主机.机名
,即按照搜索分类的指定属性查找。 - 3)若对方系统的告警中没有属性来标识发生告警的设备,则可以用两个或多个属性来匹配到唯一的设备(这两个或多个属性在CI分类中必须存在),此时需要在NOAH中使用两个或多个属性建立规则索引。规则表达式的书写格式:$(属性1)_$(属性2),下划线可以用其他符号代替。在
映射CI字段
列填写rulecode=索引名称,此时按照按照在NOAH建立的规则索引查找,5.5版本后推荐使用下面的多分类多属性匹配
。 - 4)多分类多属性匹配。如:CIPropertys=[{"className":"ghws,ghw1","CIAttribute":[{"name":"id","opType": "1","value": "${oid}"}]}]
其中
CIPropertys=
为标识,必须填。CIPropertys=
后面的是匹配规则,为json格式。className
为CMV中CI的分类名称,可以填多个,多个分类名称之间使用英文逗号分隔,
,填入具体的分类会按照填写的分类进行匹配,不填则在全部分类中进行匹配CIAttribute
为匹配的CI属性是一个数组格式,如果多属性匹配可配置多个属性的规则,name
为属性名称,opType
匹配的方式,1
为精确匹配;2
为模糊匹配value
为属性值,${}是源数据中的值- 不同分类或全部分类下的相同属性匹配: 如
CIPropertys=[{"className":"","CIAttribute":[{"name":"id","opType": "1","value": "${oid}"}]}]
- 不同分类下的不同属性。如
CIPropertys=[{"className":"服务器","CIAttribute":[{"name":"配置项编码","opType": "1","value": "${oid1}"}]},{"className":"交换机","CIAttribute":[{"name":"IP地址","opType": "1","value": "${oid2}"}]}]
- 5)根据业务主键匹配。
5.6之后版本支持(包含5.6)
,可根据CMDB中设置的业务主键
做CI匹配。如:CMDB的A分类中设置了两个业务主键,匹配规则应这样填写hashCode=${oid1},${oid2}
。其中${oid1},${oid2}是源数据中的属性值(在这里使用${}
括起来表示变量,也可以是常量如:192.168.1.1
),这两个值分别对应CMDB的A分类中的两个业务主键的值。以下是项目中常见的几种匹配机制:- 相同个数业务主键匹配。规则代码的填写如
hashCode=${oid1},${oid2}
或hashCode=${oid}
;只有一个业务主键时填写如后者,多个业务主键时填写如前者,多个属性值之间用英文的逗号,
分隔 - 不同个数业务主键匹配。规则代码的填写如
hashCode=${oid1},${oid2}||${oid3}
,多个规则之前用||
分隔
- 相同个数业务主键匹配。规则代码的填写如
备注2
LastOccurrence
- 如果时间字段LastOccurrence的日期格式不是
yyyy-MM-dd HH:mm:ss
,需要转换日期格式,转换方法如下: 在从
一栏的填写方式有三种情况:- 1)当对方是13位时间戳即毫秒数。格式:
dateformat(${对方告警中代表最后发生时间的oid})
- 2)当对方是10位时间戳即秒数的时候首先要相应的补充000即调整为13位时间戳。格式:
dateformat({对方告警中代表最后发生时间的字段oid}000)
- 3)当对方是日期格式的时候,需要再加一个参数即指定当前对方时间的格式是什么。格式:
dateformat(${对方告警中代表最后发生时间的字段oid},对方的时间格式)
, 例如:dateformat(${对方的时间},yyyy/MM/dd HH:mm:ss)
- 1)当对方是13位时间戳即毫秒数。格式:
# 数据映射
原始告警级别映射
从
列代表原始告警级别,到
列代表映射的告警从 到 1 紧急 2 重要 3 次要 4 提示 5 不明确
告警级别映射
从
列代表原始告警级别,到
列代表tarsier中的告警级别(1是最高级别告警),两者的对应关系级别一一映射填写从 到 1 1 2 2 3 3 4 4 5 4
告警指标映射
从
列代表原始告警指标,到
列代表映射的告警指标。从 到 1 通信告警 2 设备告警 3 处理错误告警 4 业务质量告警 5 环境告警 6 完整性告警 7 操作告警 8 物理资源告警 9 安全告警 10 时间域告警 11 属性值改变告警 12 对象创建告警 13 对象删除告警 14 关系改变告警 15 状态改变告警 16 路由改变告警 17 保护倒换告警 18 越限告警 19 文件传输状态告警 20 备份状态告警 21 心跳告警
时区映射: 根据实际情况填写即可
告警开启关闭映射
从
列代表原始告警开启或关闭值,到
代表映射的tarsier告警开启或关闭。其中1:开启告警;2:关闭告警从 到 1 2 2 1
# Out配置
告警的发送方式选择:点击添加,选择对应的发送方式将数据进行发送
MYSQL
选择此项会将数据保存至mysql库,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
URL(必填项) | 数据库地址 | jdbc:mysql://0.0.0.0:3306/db_vmdb?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2b8 |
用户名(必填项) | 数据库用户名 | username |
密码(必填项) | 数据库密码 | password |
是否保存历史数据(必填项) | 默认为是,保存历史数据 | 是 |
ES
选择此项会将数据保存至ES库,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
ES请求地址(必填项) | 数据库地址 | 0.0.0.0:9200 |
用户名 | 数据库用户名 | username |
密码 | 数据库密码 | password |
ES性能数据保留天数(必填项) | 默认为7,保存7天内的性能数据 | 7 |
数据域 | ThingJS-X数据域ID (可选) |
ACTIVEMQ
选择此项会将数据发送至ActiveMQ,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
请求地址(必填项) | RocketMQ地址 | 0.0.0.0:9876;0.0.0.0:9876 |
生产者组别 | RocketMQ生产者组别 | producerGroup |
消息发送主题 | 消息发送主题 | topicA |
消息标签 | 消息标签 | tagA |
超时时间 | 消息发送超时时间,单位为毫秒 | 30000 |
字符集 | 字符编码集,默认UTF-8 | UTF-8 |
消息发送类型 | 分为:异步发送,单向发送,同步发送共三种;默认为异步发送 | 异步发送 |
KAFKA
选择此项会将数据发送至kafka,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
请求地址(必填项) | 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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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服务,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
http服务路径(必填项) | http服务地址 | http://0.0.0.0:0000 |
请求头 | 填写json格式的参数 | {"key":"value"} |
字符集 | 字符编码集,默认utf-8 | utf-8 |
HTTPSPOST
选择此项会将数据通过post请求发送至https服务,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
http服务路径(必填项) | https服务地址 | https://0.0.0.0:0000 |
请求头 | 填写json格式的参数 | {"key":"value"} |
字符集 | 字符编码集,默认utf-8 | utf-8 |
DIP实例的保存与启动
- 配置信息填写完成后,点击保存,成功保存后会在森数据DIX的数据集成页面看到新建的DIP实例。
- 点击开始/启动,开始接入告警数据
名词解释
已接入:当前数据接口接入到的总数据量
处理中:当前数据接口正在进行处理的数据量
发送中:当前数据接口正在向外部发送的数据量
已发送:当前数据接口发送到外部的总数据量
# 告警-get的配置
注意
- 该DIP实例用来获取具有告警量值的oid数据。
- 在配置页面选择告警-get
# DIP实例配置
- 名称:DIP实例名称
# IN配置
SNMP服务器IP: 服务的ip
SNMP端口: 服务的端口
团体字: 开放给uinnova的snmp团体字,即密码
SNMP版本: version1,version2c,version3根据需求选择
用户名: SNMP v3用户名
数据加密密码: SNMP v3数据加密密码
授权认证密码: SNMP V3授权认证密码
数据加密协议: SNMP V3数据加密时使用的协议
授权认证协议: SNMP V3授权认证时使用的协议
轮询间隔(秒): 获取告警数据的周期
配置文件: 通过Excel配置告警指标相关属性。oid根据snmp服务的mib库查找,其中sheet名称为分类名称。列标题定义如下:
列名称 是否必填 描述 Oid 是 告警指标对应的oid SourceCIName 是 告警指标oid对应的设备 SourceAlertKey 是 告警指标oid对应的告警指标名称 SourceSeverity 否 告警指标oid对应的告警级别。如果数据需要映射,数据类型为json,示例:{"0":"正常","1":"温度过高","2":"温度过低","3":"无效值"} Severity 否 SourceSeverity映射到tarsier告警级别,如果SourceSeverity为int类型,可不用映射,数据类型为json,示例:{"0":"4","1":"1","2":"1","3":"2"} SourceEventID 否 默认使用Oid Status 是 告警指标oid对应的告警状态,必须映射,数据类型为json,示例:{"0":"2","1":"1","2":"1","3":"2"} Summary 否 告警指标oid对应的告警描述,默认值(SourceCIName+SourceAlertKey+“发生告警”) SourceIdentifier 否 压缩标识字段,默认值 ”_“
- 告警源: 告警不同来源标识
# 数据映射
- CI映射是为了告警挂载。将对方系统的告警匹配到发生该告警的设备(tarsier系统中的设备)上,此属性值有以下几种填写方式:
特别注意,认真阅读以下内容,填写错误可能导致丰富CI失败
- 1)当SourceCIName在对方系统中具有唯一性,且SourceCIName是CI分类中的主键,此处不填任何内容,会默认按照主键查找。
- 2)当SourceCIName在对方系统中具有唯一性,但SourceCIName不是CI分类中的主键,此时填写分类名。属性名(CMV中的分类及属性名,该属性必须能够
唯一标识CI
),如X86宿主机.主机名
,即按照搜索分类的指定属性查找。 - 3)多分类多属性匹配。如:CIPropertys=[{"className":"ghws,ghw1","CIAttribute":[{"name":"id","opType": "1","value": "${oid}"}]}]其中
CIPropertys=
为标识,必须填,CIPropertys=
后面的是匹配规则,为json格式。className
为CMV中CI的分类名称,可以填多个,多个分类名称之间使用英文逗号分隔,
,填入具体的分类会按照填写的分类进行匹配,不填则在全部分类中进行匹配;CIAttribute
为匹配的CI属性是一个数组格式,如果多属性匹配可配置多个属性的规则,name
为属性名称,opType
匹配的方式,1
为精确匹配,2
为模糊匹配,value
为属性值,${}是源数据中的值;- 不同分类或全部分类下的相同属性匹配:如
CIPropertys=[{"className":"","CIAttribute":[{"name":"id","opType": "1","value": "${oid}"}]}]
- 不同分类下的不同属性,如
CIPropertys=[{"className":"服务器","CIAttribute":[{"name":"配置项编码","opType": "1","value": "${oid1}"}]},{"className":"交换机","CIAttribute":[{"name":"IP地址","opType": "1","value": "${oid2}"}]}]
- 4)根据业务主键匹配。
5.6之后版本支持(包含5.6)
,可根据CMDB中设置的业务主键
做CI匹配。如:CMDB的A分类中设置了两个业务主键,匹配规则应这样填写hashCode=${oid1},${oid2}
。其中${oid1}、${oid2}是源数据中的属性值(在这里使用${}
括起来表示变量,也可以是常量如:192.168.1.1
),这两个值分别对应CMDB的A分类中的两个业务主键的值。以下是项目中常见的几种匹配机制: - 相同个数业务主键匹配。规则代码的填写如
hashCode=${oid1},${oid2}
或者hashCode=${oid}
;只有一个业务主键时填写如后者,多个业务主键时填写如前者,多个属性值之间用英文的逗号,
分隔。 - 不同个数业务主键匹配。规则代码的填写如
hashCode=${oid1},${oid2}||${oid3}
,多个规则之前用||
分隔。
# Out配置
告警的发送方式选择:点击添加,选择对应的发送方式将数据进行发送
MYSQL
选择此项会将数据保存至mysql库,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
URL(必填项) | 数据库地址 | jdbc:mysql://0.0.0.0:3306/db_vmdb?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2b8 |
用户名(必填项) | 数据库用户名 | username |
密码(必填项) | 数据库密码 | password |
是否保存历史数据(必填项) | 默认为是,保存历史数据 | 是 |
ES
选择此项会将数据保存至ES库,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
ES请求地址(必填项) | 数据库地址 | 0.0.0.0:9200 |
用户名 | 数据库用户名 | username |
密码 | 数据库密码 | password |
ES性能数据保留天数(必填项) | 默认为7,保存7天内的性能数据 | 7 |
数据域 | ThingJS-X数据域ID (可选) |
ACTIVEMQ
选择此项会将数据发送至ActiveMQ,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
请求地址(必填项) | RocketMQ地址 | 0.0.0.0:9876;0.0.0.0:9876 |
生产者组别 | RocketMQ生产者组别 | producerGroup |
消息发送主题 | 消息发送主题 | topicA |
消息标签 | 消息标签 | tagA |
超时时间 | 消息发送超时时间,单位为毫秒 | 30000 |
字符集 | 字符编码集,默认UTF-8 | UTF-8 |
消息发送类型 | 分为:异步发送,单向发送,同步发送共三种;默认为异步发送 | 异步发送 |
KAFKA
选择此项会将数据发送至kafka,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
请求地址(必填项) | 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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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服务,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
http服务路径(必填项) | http服务地址 | http://0.0.0.0:0000 |
请求头 | 填写json格式的参数 | {"key":"value"} |
字符集 | 字符编码集,默认utf-8 | utf-8 |
HTTPSPOST
选择此项会将数据通过post请求发送至https服务,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
http服务路径(必填项) | https服务地址 | https://0.0.0.0:0000 |
请求头 | 填写json格式的参数 | {"key":"value"} |
字符集 | 字符编码集,默认utf-8 | utf-8 |
DIP实例的保存与启动
- 配置信息填写完成后,点击保存,成功保存后会在森数据DIX的数据集成页面看到新建的DIP实例。
- 点击开始/启动按钮,开始接入告警数据。
名词解释
已接入:当前数据接口接入到的总数据量
处理中:当前数据接口正在进行处理的数据量
发送中:当前数据接口正在向外部发送的数据量
已发送:当前数据接口发送到外部的总数据量
# 性能-getBulk的配置
- 在配置页面选择性能-getBulk
# DIP实例配置
- 名称:DIP实例名称
# IN配置
- SNMP服务器IP: 服务的ip
- SNMP端口: 服务的端口
- 团体字: 开放给uinnova的snmp团体,即密码
- SNMP版本: version1,version2c,version3根据需求选择
- 用户名: SNMP v3用户名
- 数据加密密码: SNMP v3数据加密密码
- 授权认证密码: SNMP V3授权认证密码
- 数据加密协议: SNMP V3数据加密时使用的协议
- 授权认证协议: SNMP V3授权认证时使用的协议
- SNMP批量获取数据量: 一次获取的数据量
- root oid(oid根节点): 设备oid的根节点
- 轮询间(秒): 获取性能数据的周期
- 配置文件: 通过Excel配置性能指标相关属性,oid根据snmp服务的mib库查找。其中sheet名称为分类名称,列标题定义如下:
- oid:指标对应的oid
- metric:指标对应的名称
- coefficient:指标对应值的比例系数
- valueMapping:指标值对应的映射关系,数据类型为json。若无则不用填写。示例:{"0":"通信失败","1":"通信正常"}
# 数据映射
映射CI:映射CI是为了将snmp性能数据匹配到设备(tarsier系统中的)上。此属性只有2种值。
为空(即不写任何字符):适用于cicode为设备的信息索引值,设备的信息索引值通过mib工具根据信息索引oid获取
CI分类名.属性名
的方式填写:即代表性能所属设备的属性在tarsier系统中对应的CI分类
和属性名
,属性名
具体值是设备的信息索引值,设备的信息索引值通过mib工具根据信息索引oid获取。
# Out配置
告警的发送方式选择:点击添加,选择对应的发送方式将数据进行发送
MYSQL
选择此项会将数据保存至mysql库,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
URL(必填项) | 数据库地址 | jdbc:mysql://0.0.0.0:3306/db_vmdb?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2b8 |
用户名(必填项) | 数据库用户名 | username |
密码(必填项) | 数据库密码 | password |
是否保存历史数据(必填项) | 默认为是,保存历史数据 | 是 |
ES
选择此项会将数据保存至ES库,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
ES请求地址(必填项) | 数据库地址 | 0.0.0.0:9200 |
用户名 | 数据库用户名 | username |
密码 | 数据库密码 | password |
ES性能数据保留天数(必填项) | 默认为7,保存7天内的性能数据 | 7 |
数据域 | ThingJS-X数据域ID (可选) |
ACTIVEMQ
选择此项会将数据发送至ActiveMQ,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
请求地址(必填项) | RocketMQ地址 | 0.0.0.0:9876;0.0.0.0:9876 |
生产者组别 | RocketMQ生产者组别 | producerGroup |
消息发送主题 | 消息发送主题 | topicA |
消息标签 | 消息标签 | tagA |
超时时间 | 消息发送超时时间,单位为毫秒 | 30000 |
字符集 | 字符编码集,默认UTF-8 | UTF-8 |
消息发送类型 | 分为:异步发送,单向发送,同步发送共三种;默认为异步发送 | 异步发送 |
KAFKA
选择此项会将数据发送至kafka,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
请求地址(必填项) | 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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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服务,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
http服务路径(必填项) | http服务地址 | http://0.0.0.0:0000 |
请求头 | 填写json格式的参数 | {"key":"value"} |
字符集 | 字符编码集,默认utf-8 | utf-8 |
HTTPSPOST
选择此项会将数据通过post请求发送至https服务,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
http服务路径(必填项) | https服务地址 | https://0.0.0.0:0000 |
请求头 | 填写json格式的参数 | {"key":"value"} |
字符集 | 字符编码集,默认utf-8 | utf-8 |
DIP实例的保存与启动
- 配置信息填写完成后,点击保存,成功保存后会在森数据DIX的数据集成页面看到新建的DIP实例。
- 点击开始/启动按钮,待启动成功之后,点击日志按钮,查看数据是否能正常接入。
名词解释
已接入:当前数据接口接入到的总数据量
处理中:当前数据接口正在进行处理的数据量
发送中:当前数据接口正在向外部发送的数据量
已发送:当前数据接口发送到外部的总数据量
# 性能-getSubtree的配置
- 在配置页面选择性能-getSubtree
# DIP实例配置
- 名称:DIP实例名称
# IN配置
- SNMP服务器IP: 服务的ip
- SNMP端口: 服务的端口
- 团体字: 开放给uinnova的snmp团体,即密码
- SNMP版本: version1,version2c,version3根据需求选择
- 用户名: SNMP v3用户名
- 数据加密密码: SNMP v3数据加密密码
- 授权认证密码: SNMP V3授权认证密码
- 数据加密协议: SNMP V3数据加密时使用的协议
- 授权认证协议: SNMP V3授权认证时使用的协议
- SNMP批量获取数据量: 一次获取的数据量
- 分类根节点oid: 设备分类oid的根节点
- 轮询间(秒): 获取性能数据的周期
- 配置文件: 通过Excel配置性能指标相关属性,oid根据snmp服务的mib库查找。其中sheet名称为分类名称,列标题定义如下:
- oid:指标对应的oid
- isCiCode:是否是指标对应的ci
- metric:指标对应的名称
- coefficient:指标对应值的比例系数
- valueMapping:指标值对应的映射关系,数据类型为json。若无则不用填写。示例:{"0":"通信失败","1":"通信正常"}
# 数据映射
映射CI:映射CI是为了将snmp性能数据匹配到设备(tarsier系统中的)上。此属性只有2种值。
为空(即不写任何字符):适用于cicode为设备的信息索引值,设备的信息索引值通过mib工具根据信息索引oid获取
CI分类名.属性名
的方式填写:即代表性能所属设备的属性在tarsier系统中对应的CI分类
和属性名
,属性名
具体值是设备的信息索引值,设备的信息索引值通过mib工具根据信息索引oid获取。
# Out配置
告警的发送方式选择:点击添加,选择对应的发送方式将数据进行发送
MYSQL
选择此项会将数据保存至mysql库,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
URL(必填项) | 数据库地址 | jdbc:mysql://0.0.0.0:3306/db_vmdb?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2b8 |
用户名(必填项) | 数据库用户名 | username |
密码(必填项) | 数据库密码 | password |
是否保存历史数据(必填项) | 默认为是,保存历史数据 | 是 |
ES
选择此项会将数据保存至ES库,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
ES请求地址(必填项) | 数据库地址 | 0.0.0.0:9200 |
用户名 | 数据库用户名 | username |
密码 | 数据库密码 | password |
ES性能数据保留天数(必填项) | 默认为7,保存7天内的性能数据 | 7 |
数据域 | ThingJS-X数据域ID (可选) |
ACTIVEMQ
选择此项会将数据发送至ActiveMQ,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
请求地址(必填项) | RocketMQ地址 | 0.0.0.0:9876;0.0.0.0:9876 |
生产者组别 | RocketMQ生产者组别 | producerGroup |
消息发送主题 | 消息发送主题 | topicA |
消息标签 | 消息标签 | tagA |
超时时间 | 消息发送超时时间,单位为毫秒 | 30000 |
字符集 | 字符编码集,默认UTF-8 | UTF-8 |
消息发送类型 | 分为:异步发送,单向发送,同步发送共三种;默认为异步发送 | 异步发送 |
KAFKA
选择此项会将数据发送至kafka,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
请求地址(必填项) | 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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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服务,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
http服务路径(必填项) | http服务地址 | http://0.0.0.0:0000 |
请求头 | 填写json格式的参数 | {"key":"value"} |
字符集 | 字符编码集,默认utf-8 | utf-8 |
HTTPSPOST
选择此项会将数据通过post请求发送至https服务,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
http服务路径(必填项) | https服务地址 | https://0.0.0.0:0000 |
请求头 | 填写json格式的参数 | {"key":"value"} |
字符集 | 字符编码集,默认utf-8 | utf-8 |
DIP实例的保存与启动
- 配置信息填写完成后,点击保存,成功保存后会在森数据DIX的数据集成页面看到新建的DIP实例。
- 点击开始/启动按钮,待启动成功之后,点击日志按钮,查看数据是否能正常接入。
名词解释
已接入:当前数据接口接入到的总数据量
处理中:当前数据接口正在进行处理的数据量
发送中:当前数据接口正在向外部发送的数据量
已发送:当前数据接口发送到外部的总数据量
# 性能-getWalk的配置
- 在配置页面选择性能-getWalk
# DIP实例配置
- 名称:DIP实例名称
# IN配置
- SNMP服务器IP: 服务的ip
- SNMP端口: 服务的端口
- 团体字: 开放给uinnova的snmp团体,即密码
- SNMP版本: version1,version2c,version3根据需求选择
- 用户名: SNMP v3用户名
- 数据加密密码: SNMP v3数据加密密码
- 授权认证密码: SNMP V3授权认证密码
- 数据加密协议: SNMP V3数据加密时使用的协议
- 授权认证协议: SNMP V3授权认证时使用的协议
- SNMP批量获取数据量: 一次获取的数据量
- 分类根节点oid: 设备分类oid的根节点
- 轮询间(秒): 获取性能数据的周期
- 配置文件: 通过Excel配置性能指标相关属性,oid根据snmp服务的mib库查找。其中sheet名称为分类名称,列标题定义如下:
- oid:指标对应的oid
- isCiCode:是否是指标对应的ci
- metric:指标对应的名称
- coefficient:指标对应值的比例系数
- valueMapping:指标值对应的映射关系,数据类型为json。若无则不用填写。示例:{"0":"通信失败","1":"通信正常"}
# 数据映射
映射CI:映射CI是为了将snmp性能数据匹配到设备(tarsier系统中的)上。此属性只有2种值。
为空(即不写任何字符):适用于cicode为设备的信息索引值,设备的信息索引值通过mib工具根据信息索引oid获取
CI分类名.属性名
的方式填写:即代表性能所属设备的属性在tarsier系统中对应的CI分类
和属性名
,属性名
具体值是设备的信息索引值,设备的信息索引值通过mib工具根据信息索引oid获取。
# Out配置
告警的发送方式选择:点击添加,选择对应的发送方式将数据进行发送
MYSQL
选择此项会将数据保存至mysql库,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
URL(必填项) | 数据库地址 | jdbc:mysql://0.0.0.0:3306/db_vmdb?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2b8 |
用户名(必填项) | 数据库用户名 | username |
密码(必填项) | 数据库密码 | password |
是否保存历史数据(必填项) | 默认为是,保存历史数据 | 是 |
ES
选择此项会将数据保存至ES库,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
ES请求地址(必填项) | 数据库地址 | 0.0.0.0:9200 |
用户名 | 数据库用户名 | username |
密码 | 数据库密码 | password |
ES性能数据保留天数(必填项) | 默认为7,保存7天内的性能数据 | 7 |
数据域 | ThingJS-X数据域ID (可选) |
ACTIVEMQ
选择此项会将数据发送至ActiveMQ,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
请求地址(必填项) | RocketMQ地址 | 0.0.0.0:9876;0.0.0.0:9876 |
生产者组别 | RocketMQ生产者组别 | producerGroup |
消息发送主题 | 消息发送主题 | topicA |
消息标签 | 消息标签 | tagA |
超时时间 | 消息发送超时时间,单位为毫秒 | 30000 |
字符集 | 字符编码集,默认UTF-8 | UTF-8 |
消息发送类型 | 分为:异步发送,单向发送,同步发送共三种;默认为异步发送 | 异步发送 |
KAFKA
选择此项会将数据发送至kafka,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
请求地址(必填项) | 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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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服务,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
http服务路径(必填项) | http服务地址 | http://0.0.0.0:0000 |
请求头 | 填写json格式的参数 | {"key":"value"} |
字符集 | 字符编码集,默认utf-8 | utf-8 |
HTTPSPOST
选择此项会将数据通过post请求发送至https服务,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
http服务路径(必填项) | https服务地址 | https://0.0.0.0:0000 |
请求头 | 填写json格式的参数 | {"key":"value"} |
字符集 | 字符编码集,默认utf-8 | utf-8 |
DIP实例的保存与启动
- 配置信息填写完成后,点击保存,成功保存后会在森数据DIX的数据集成页面看到新建的DIP实例。
- 点击开始/启动按钮,待启动成功之后,点击日志按钮,查看数据是否能正常接入。
名词解释
已接入:当前数据接口接入到的总数据量
处理中:当前数据接口正在进行处理的数据量
发送中:当前数据接口正在向外部发送的数据量
已发送:当前数据接口发送到外部的总数据量
# 性能-get的配置
- 在配置页面选择性能-get
# DIP实例配置
- 名称:DIP实例名称
# IN配置
- SNMP服务器IP: 服务的ip
- SNMP端口: 服务的端口
- 团体字: 开放给uinnova的snmp团体,即密码
- SNMP版本: version1,version2c,version3根据需求选择
- 用户名: SNMP v3用户名
- 数据加密密码: SNMP v3数据加密密码
- 授权认证密码: SNMP V3授权认证密码
- 数据加密协议: SNMP V3数据加密时使用的协议
- 授权认证协议: SNMP V3授权认证时使用的协议
- 轮询间(秒): 获取性能数据的周期
- 配置文件: 通过Excel配置性能指标相关属性,oid根据snmp服务的mib库查找。其中sheet名称为分类名称,列标题定义如下:
- oid:指标对应的oid
- ciCode:指标对应的ci,与森数据DIX中保持一致
- metric:指标对应的名称
- coefficient:指标对应值的比例系数
- valueMapping:指标值对应的映射关系,数据类型为json。若无则不用填写。示例:{"0":"通信失败","1":"通信正常"}
# 数据映射
映射CI:映射CI是为了将snmp性能数据匹配到设备(tarsier系统中的)上。此属性只有2种值。
为空(即不写任何字符):适用于cicode为设备的信息索引值,设备的信息索引值通过mib工具根据信息索引oid获取
CI分类名.属性名
的方式填写:即代表性能所属设备的属性在tarsier系统中对应的CI分类
和属性名
,属性名
具体值是设备的信息索引值,设备的信息索引值通过mib工具根据信息索引oid获取。
# Out配置
告警的发送方式选择:点击添加,选择对应的发送方式将数据进行发送
MYSQL
选择此项会将数据保存至mysql库,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
URL(必填项) | 数据库地址 | jdbc:mysql://0.0.0.0:3306/db_vmdb?useUnicode=true&characterEncoding=UTF-8&serverTimezone=GMT%2b8 |
用户名(必填项) | 数据库用户名 | username |
密码(必填项) | 数据库密码 | password |
是否保存历史数据(必填项) | 默认为是,保存历史数据 | 是 |
ES
选择此项会将数据保存至ES库,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
ES请求地址(必填项) | 数据库地址 | 0.0.0.0:9200 |
用户名 | 数据库用户名 | username |
密码 | 数据库密码 | password |
ES性能数据保留天数(必填项) | 默认为7,保存7天内的性能数据 | 7 |
数据域 | ThingJS-X数据域ID (可选) |
ACTIVEMQ
选择此项会将数据发送至ActiveMQ,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
请求地址(必填项) | RocketMQ地址 | 0.0.0.0:9876;0.0.0.0:9876 |
生产者组别 | RocketMQ生产者组别 | producerGroup |
消息发送主题 | 消息发送主题 | topicA |
消息标签 | 消息标签 | tagA |
超时时间 | 消息发送超时时间,单位为毫秒 | 30000 |
字符集 | 字符编码集,默认UTF-8 | UTF-8 |
消息发送类型 | 分为:异步发送,单向发送,同步发送共三种;默认为异步发送 | 异步发送 |
KAFKA
选择此项会将数据发送至kafka,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
请求地址(必填项) | 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,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
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服务,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
http服务路径(必填项) | http服务地址 | http://0.0.0.0:0000 |
请求头 | 填写json格式的参数 | {"key":"value"} |
字符集 | 字符编码集,默认utf-8 | utf-8 |
HTTPSPOST
选择此项会将数据通过post请求发送至https服务,配置项如下:
配置项名称 | 配置项描述 | 示例 |
---|---|---|
http服务路径(必填项) | https服务地址 | https://0.0.0.0:0000 |
请求头 | 填写json格式的参数 | {"key":"value"} |
字符集 | 字符编码集,默认utf-8 | utf-8 |
DIP实例的保存与启动
- 配置信息填写完成后,点击保存,成功保存后会在森数据DIX的数据集成页面看到新建的DIP实例。
- 点击开始/启动按钮,待启动成功之后,点击日志按钮,查看数据是否能正常接入。
名词解释
已接入:当前数据接口接入到的总数据量
处理中:当前数据接口正在进行处理的数据量
发送中:当前数据接口正在向外部发送的数据量
已发送:当前数据接口发送到外部的总数据量
# 编程式snmp-trap接收数据
引言
- 通过上边的学习,我们对snmp的使用和配置有了一定的了解。下面介绍一种较为灵活的snmp-trap(现有版本仅snmp-trap支持编程式)`方式获取数据。
# 操作步骤
- 新建一个javaScript类型的DIP实例,然后在脚本里输入示例代码。
示例代码
/**
* 示例代码, 仅提供了最基础的获取数据的部分, 获取到数据之后需要自行对数据进行解析
*/
function run() {
// 引入启动类依赖
var SnmpJdmkTrap = Java.type("com.uinnova.di.dip.snmp.jdmk.SnmpJdmkTrap");
// 本地服务的端口号, 默认162
var snmpJdmkTrap = new SnmpJdmkTrap("162");
while (true) {
var data = snmpJdmkTrap.getData();
// data 便是对方推送的数据
logger.info("---" + data);
}
}
2
3
4
5
6
7
8
9
10
11
12
13
14
参考日志
日志字段说明
可以看到,日志的返回格式是一个json格式的字符串,其中包含如下几个部分。
- ip:推送方的ip地址
- data:业务数据
- 其中data中一条数据格式为
{oid:value}
- 其中data中一条数据格式为
当接收到数据之后,便可以根据snmp的对照表将oid
映射成我们需要的字段即可。