1.1 功能介绍

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

1.2 应用场景

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

1.3 系统路径

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

2 主要操作

2.1 新增MQ订阅

前提条件

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

操作步骤

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

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

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

2.2 创建数据流方案

前提条件