18.2. 从 MQTT 代理获取消息以触发集成执行
要根据 MQTT 代理收到消息来触发集成执行，请添加 MQTT 连接作为启动连接。当集成运行时，MQTT 连接会持续监控您指定的 MQTT 队列或主题上的消息。当连接找到消息时，它会将其传递给集成中的下一步。MQTT 连接一次处理一条消息。
前提条件
您创建了 MQTT 连接。
流程
- 在左侧的 Fuse Online 面板中，单击 Integrations。
- 点 Create Integration。
- 在 Choose a connection 页面上，单击您要用来启动集成的 MQTT 连接。
- 在 Choose an action 页面上，选择 Subscribe 操作来接收来自您指定的队列或主题的消息。
- 在 MQTT queue/topic name 字段中，输入要接收数据的队列或主题的名称。
- 点 Next 指定操作的输出类型。
在 Select Type 字段中，如果不需要知道数据类型，则接受 类型规格， 然后点 Next。您不需要遵循这些指令的其余部分。
但是，建议使用结构化的数据类型。例如，如果要在数据映射映射映射器步骤中的连接输出，您必须指定数据类型。数据映射器无法显示非结构化数据的字段。
要指定数据类型，点 Select Type 字段，并选择以下之一作为 schema 类型：
-
JSON 模式是 描述 JSON 数据结构的文档。文档的介质类型是
application/schema+json。 -
JSON 实例 是包含 JSON 数据的文档。文档的介质类型是
application/json。 -
XML 模式 是一个描述 XML 数据结构的文档。文档的文件扩展为
.xsd。 -
XML 实例 是包含 XML 数据的文档。文档的文件扩展为
.xml。
-
JSON 模式是 描述 JSON 数据结构的文档。文档的介质类型是
-
在 Definition 输入框中，粘贴符合您选择的 schema 类型的定义。例如，如果您选择 JSON 模式，您将粘贴 JSON 模式文件的内容，该文件的介质类型为
application/schema+json。 在 Data Type Name 字段中输入您为数据类型选择的名称。例如，如果您要为供应商指定 JSON 模式，您可以指定
Vendor作为数据类型名称。在创建或编辑使用指定此类型的连接时，您将看到此数据类型名称。Fuse Online 在集成视觉化和数据映射程序中显示类型名称。
- 在 Data Type Description 字段中，提供可帮助您区分此类型的信息。当您将鼠标悬停在处理此类型的步骤上时，此描述会出现在数据映射程序中。
- 点击 Next。
结果
集成现在有一个启动连接，Fuse Online 会提示您选择完成连接。
