17.2. 更新 MongoDB 集合时触发集成

流程

1. 在左侧的 Fuse Online 面板中，单击 Integrations。
2. 点 Create Integration。
3. 在 Choose a connection 页面上，点 MongoDB 连接，该连接配置为访问您希望集成从中获取更新的数据库。

4. 在 Choose an action 页面中，选择这些操作之一：

   • 检索文档(stream) 通常是要选择的操作。它从非捕获的集合检索数据。
   • 检索文档(tail) 是从大写的集合中检索数据的操作。

5. 配置操作：

   1. 在 Collection name 字段中，输入您希望连接读取的 MongoDB 集合的名称。

      如果您要配置 Retrieve 文档(stream) 操作，这是唯一需要的参数。进入第 6 步。如果您要配置 Retrieve 文档(tail) 操作，请按照剩余的子步骤操作。

   2. 在 用于跟踪传入文档字段的 Collection 字段中，输入相关 MongoDB 集合字段的名称。此字段包含可以排序的数据，如日期或 ID。
   3. 如果为您希望连接要读取的数据库启用了持久性跟踪，请选择 Persistent tracking enabled。
   4. 可选的。在 唯一 id 中，用于识别此跟踪进程 字段，如果有多个消费者用于监控同一集合，则指定唯一的 ID。如需更多信息，请参阅 Camel 文档 Tailable Cursor Consumer。
   5. 可选的。在 用于存储 tail tracking 字段的 DB 中，输入包含尾部跟踪信息的 MongoDB 数据库的名称。
   6. 可选的。在 用来存储 tail tracking 字段的 Collection 中，输入包含尾部跟踪信息的集合名称。
   7. 可选的。在 用来存储 tail tracking 字段的字段中，输入存储此连接正在读取的集合的尾部跟踪信息的字段名称。

   要识别 tail 跟踪字段，您可以指定 tail 跟踪数据库或尾部跟踪集合。使用这些信息之一，连接可以找到 tail 跟踪字段。

6. 点 Next 指定操作的输出类型。

7. 在 Select Type 字段中，如果不需要知道数据类型，则接受 类型规格， 然后点 Next。您不需要遵循这些指令的其余部分。

   但是，建议使用结构化的数据类型。例如，如果要在数据映射映射映射器步骤中的连接输出，您必须指定数据类型。数据映射器无法显示非结构化数据的字段。

   要指定数据类型，点 Select Type 字段，并选择以下之一作为 schema 类型：

   • JSON 模式是 描述 JSON 数据结构的文档。文档的介质类型是 application/schema+json。
   • JSON 实例 是包含 JSON 数据的文档。文档的介质类型是 application/json。
   • XML 模式 是一个描述 XML 数据结构的文档。文档的文件扩展为 .xsd。
   • XML 实例 是包含 XML 数据的文档。文档的文件扩展为 .xml。
8. 在 Definition 输入框中，粘贴符合您选择的 schema 类型的定义。例如，如果您选择 JSON 模式，您将粘贴 JSON 模式文件的内容，该文件的介质类型为 application/schema+json。

9. 在 Data Type Name 字段中输入您为数据类型选择的名称。例如，如果您要为供应商指定 JSON 模式，您可以指定 Vendor 作为数据类型名称。

   在创建或编辑使用指定此类型的连接时，您将看到此数据类型名称。Fuse Online 在集成视觉化和数据映射程序中显示类型名称。

10. 在 Data Type Description 字段中，提供可帮助您区分此类型的信息。当您将鼠标悬停在处理此类型的步骤上时，此描述会出现在数据映射程序中。
11. 点击 Next。