模块介绍
RabbitMQ输入模块是订阅RabbitMQ作为数据服务的输入数据,该模块仅产生输入的数据,只能作为数据服务第一级输入的节点。
配置说明
参数名称 | 是否必填 | 描述 |
---|---|---|
数据源 | 是 | 在数据源中配置好的RabbitMQ连接 |
Topic | 是 | 需要订阅的Topic |
脚本配置-初始化 | 否 | 模块启动时执行的脚本 |
脚本配置-消息处理 | 是 | 从MQ收到的消息处理脚本 |
脚本配置-关闭 | 否 | 模块关闭时执行的脚本 |
输出属性配置-属性名 | 是 | 需要输出的属性名 |
输出属性配置-属性描述 | 是 | 属性标识符 |
输出属性配置-类型 | 是 | 需要输出属性类型 |
配置操作说明
- 点击左侧导航栏【数据引擎】->【数据引擎】,进入数据引擎列表页面;点击右侧【新增】按钮,新建数据引擎
- 点击数据引擎操作栏的【配置】按钮,进入数据引擎编辑页面
- 从右上角设备输入栏中,点击设备输入的下拉框,鼠标按住RabbitMQ输入不放,拖动组件进入画布中心,如下图
- 点击RabbitMQ输入组件框右上角的【配置】按钮,进入设备配置页面,选择对应的数据源,Topic;点击【配置脚本】按钮,脚本编辑页面左侧输入框加入参数,点击【执行】右侧输出框显示输出字段,保存提交后属性输出列表将显示脚本中属性参数。
- RabbitMQ输入配置完成后,点击右上角的【保存】按钮进行保存,也可点击右下角的【执行并保存】按钮启动该数据引擎。