17.2. 更新 MongoDB 数据库时触发集成


要在从 MongoDB 数据库获取更新时触发集成执行,请在启动连接时将 MongoDB 连接添加到简单集成。当集成运行时,MongoDB 连接会监控您在创建集成时指定的数据库集合。监控的集合必须是 MongoDB capped 集合。在连接配置为监控的集合中插入新文档,触发集成执行。MongoDB 连接将集合更新返回到集成,此数据可用于集成中的下一步。

先决条件

  • 您创建了 MongoDB 连接。
  • 您知道您希望连接读取的 MongoDB capped 集合的名称。
  • 您知道跟踪传入文档的 MongoDB 集合字段的名称。
  • 您知道是否为希望连接从中读取的数据库启用持久性跟踪。
  • 您知道如何指定与希望连接读取的数据相关的尾部跟踪信息。MongoDB 连接可以使用尾部跟踪信息在意外连接终止后恢复操作。tail 跟踪可确保当连接恢复其活动时,它不会将重复数据返回到集成,也不会丢弃需要返回到集成的任何数据。

流程

  1. 在左侧的 Fuse Online 面板中,单击 Integrations
  2. Create Integration
  3. Choose a connection 页面上,点 MongoDB 连接,该连接配置为访问您希望集成从中获取更新的数据库。
  4. Choose an action 页面上,选择 Mongo consumer 操作。
  5. 配置操作:

    1. Collection name 字段中,输入您希望连接读取的 MongoDB 集合的名称。
    2. 用于跟踪传入文档字段的 Collection 字段中,输入相关 MongoDB 集合字段的名称。此字段包含可以排序的数据,如日期或 ID。
    3. 如果为您希望连接要读取的数据库启用了持久性跟踪,请选择 Persistent tracking enabled
    4. 用来存储 tracking 进度字段的字段中,可选指定指定集合中的字段名称。MongoDB 管理员必须已经配置此字段。
    5. 用于存储 tail 跟踪字段的 DB 中,(可选)输入包含尾部跟踪信息的 MongoDB 数据库的名称。
    6. 用来存储 tail tracking 字段中的 Collection 中,(可选)输入包含尾部跟踪信息的集合名称。
    7. 用来存储 tail tracking 字段的字段中,(可选)输入存储此连接正在读取的集合的尾部跟踪信息的字段名称
    注意

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

  6. 点击 Next

结果

集成现在有一个启动连接,Fuse Online 会提示您选择完成连接。

在执行过程中,连接会返回 JSON 格式的插入文档。

Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2026 Red Hat
返回顶部