PutMongoRecord 2025.5.31.15¶

捆绑包¶

org.apache.nifi | nifi-mongodb-nar

描述¶

该处理器是记录感知处理器，用于向 MongoDB 中插入/更新数据。它使用配置的记录读取器和架构从 FlowFile 正文中读取传入记录集，然后将这些记录批量插入/更新到配置的 MongoDB 集合。该处理器不支持删除操作。一次要插入/更新的文档数量由“Batch Size”配置属性控制。此值应设置为合理的大小，以确保 MongoDB 不会因同时进行过多的操作而过载。

标签¶

insert、mongodb、put、record、update、upsert

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
Mongo 集合名称	要使用的集合的名称
Mongo 数据库名称	要使用的数据库名称
bypass-validation	在插入或更新操作期间启用或禁用绕过文档架构验证。绕过文档验证是 MongoDB 中的一项权限操作。启用此属性可能会导致权限有限的用户遇到授权错误。
insert_count	对 MongoDB 进行一次插入/更新插入操作时要分组的记录数量。
mongo-client-service	如果已配置，则此属性将使用分配的客户端服务进行连接共享。
ordered	执行有序或无序操作
record-reader	指定用于解析传入数据和确定数据架构的控制器服务
update-key-fields	以逗号分隔的字段列表，用于识别需要更新的文档。如果设置了此属性，NiFi 将尝试对所有文档进行更新插入操作。如果未设置此属性，则将插入所有文档。
update-mode	选择对每个传入记录更新单个文档还是多个文档。

关系¶

名称	描述
failure	无法写入 MongoDB 的所有 FlowFiles 都将路由到此关系
success	写入 MongoDB 的所有 FlowFiles 都将路由到此关系