1.1 功能介绍

MQ订阅事件模型是数据流的一种启动方式，当指定的消息主题接收到消息时将触发数据流任务的执行。

1.2 应用场景

当希望通过消息来触发启动数据流任务时可以使用该组件。

1.3 系统路径

【集成服务云】→【数据流】→【资源开发】 →【数据流资源】 →【事件模型（MQ订阅）】

2 主要操作

2.1 新增MQ订阅

前提条件

创建好订阅消息的数据结构模型。

操作步骤

步骤1： 选择左树连接器的最低层目录，点击‘新增’选择MQ订阅资源类型。

步骤2： 填写想要订阅的消息主题编码，并选择接收消息的数据结构模型。

步骤3： 根据业务需求可以在解析脚本中对订阅的消息进行处理，接收到的原始消息将根据字符集处理为字符串，经过解析脚本处理以后保存到数据结构模型中，以供下游使用。

2.2 创建数据流方案

前提条件

操作步骤

步骤1： 创建数据流图，在连接器页签创建一条MQ类型的连接器，并根据业务需要创建好系统连接。

注：此处创建的为逻辑连接器，还未真正关联具体系统连接。

步骤2： 配置数据流图，第一个节点选择已经创建好的MQ订阅事件模型，并绑定刚才创建的MQ连接。

步骤3： 配置完数据流图以后创建并启用启动方案。

当启用启动方案时，将在【集成管理】->【消息集成】->【订阅主题】下自动创建一条订阅主题。

注：如果订阅主题已经有一条相同编码和消息服务器的记录，将自动关联该记录，不再创建。后续以此处的订阅主题为准，在数据流修改MQ订阅事件模型将不再同步修改该订阅主题。