17.2. 更新 MongoDB 数据库时触发集成
要在从 MongoDB 数据库获取更新时触发集成执行,请在启动连接时将 MongoDB 连接添加到简单集成。当集成运行时,MongoDB 连接会监控您在创建集成时指定的数据库集合。监控的集合必须是 MongoDB capped 集合。在连接配置为监控的集合中插入新文档,触发集成执行。MongoDB 连接将集合更新返回到集成,此数据可用于集成中的下一步。
先决条件
- 您创建了 MongoDB 连接。
- 您知道您希望连接读取的 MongoDB capped 集合的名称。
- 您知道跟踪传入文档的 MongoDB 集合字段的名称。
- 您知道是否为希望连接从中读取的数据库启用持久性跟踪。
- 您知道如何指定与希望连接读取的数据相关的尾部跟踪信息。MongoDB 连接可以使用尾部跟踪信息在意外连接终止后恢复操作。tail 跟踪可确保当连接恢复其活动时,它不会将重复数据返回到集成,也不会丢弃需要返回到集成的任何数据。
流程
- 在左侧的 Fuse Online 面板中,单击 Integrations。
- 点 Create Integration。
- 在 Choose a connection 页面上,点 MongoDB 连接,该连接配置为访问您希望集成从中获取更新的数据库。
- 在 Choose an action 页面上,选择 Mongo consumer 操作。
配置操作:
- 在 Collection name 字段中,输入您希望连接读取的 MongoDB 集合的名称。
- 在 用于跟踪传入文档字段的 Collection 字段中,输入相关 MongoDB 集合字段的名称。此字段包含可以排序的数据,如日期或 ID。
- 如果为您希望连接要读取的数据库启用了持久性跟踪,请选择 Persistent tracking enabled。
- 在 用来存储 tracking 进度字段的字段中,可选指定指定集合中的字段名称。MongoDB 管理员必须已经配置此字段。
- 在 用于存储 tail 跟踪字段的 DB 中,(可选)输入包含尾部跟踪信息的 MongoDB 数据库的名称。
- 在 用来存储 tail tracking 字段中的 Collection 中,(可选)输入包含尾部跟踪信息的集合名称。
- 在 用来存储 tail tracking 字段的字段中,(可选)输入存储此连接正在读取的集合的尾部跟踪信息的字段名称。
注意要识别 tail 跟踪字段,您可以指定 tail 跟踪数据库或尾部跟踪集合。使用这些信息之一,连接可以找到 tail 跟踪字段。
- 点击 Next。
结果
集成现在有一个启动连接,Fuse Online 会提示您选择完成连接。
在执行过程中,连接会返回 JSON 格式的插入文档。