PutMongo 2025.5.31.15¶

捆绑包¶

org.apache.nifi | nifi-mongodb-nar

描述¶

将 FlowFile 的内容写入 MongoDB

标签¶

insert、mongodb、put、update、write

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
字符集	对数据进行编码的字符集
模式	指明处理器是否应插入或更新内容
Mongo 集合名称	要使用的集合的名称
Mongo 数据库名称	要使用的数据库名称
Update Method	运行集合更新操作的 MongoDB 方法，例如 updateOne 或 updateMany
Update Query Key	用于构建更新查询条件的一个或多个以逗号分隔的文档密钥名称，例如 _id
Upsert	当为 true 时，如果没有文档符合更新查询条件，则插入文档；此属性仅在使用更新模式时有效，否则将被忽略
mongo-client-service	如果已配置，则此属性将使用分配的客户端服务进行连接共享。
put-mongo-update-mode	选择更新模式。您可以提供一个 JSON 文档作为直接替换，也可以指定一个包含 $set、$unset 和 $inc 等更新运算符的文档。启用运算符模式后，Flowfile 内容应成为运算符部分，例如：{$set:{"key": "value"},$inc:{"count":1234}}，更新查询将来自配置的更新查询属性。
putmongo-update-query	指定一个完整的 MongoDB 查询，用于查找查询以进行更新/更新插入。NOTE：如果“Update Query Key”值不为空，则忽略此字段。

关系¶

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

写入属性¶

名称	描述
mongo.put.update.match.count	如果执行更新/更新插入，则根据结果进行匹配计数，否则不设置。
mongo.put.update.modify.count	如果执行更新/更新插入，则根据结果修改计数，否则不设置。
mongo.put.upsert.id	如果执行更新插入，则为“_id”十六进制值，否则不设置。