FetchGridFS 2025.5.31.15¶

捆绑包¶

org.apache.nifi | nifi-mongodb-nar

描述¶

通过文件名或用户定义的查询从 GridFS 桶中检索一个或多个文件。

标签¶

fetch、gridfs、mongo

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
gridfs-bucket-name	存储文件的 GridFS 桶。如果留空，它将使用 MongoDB 客户端驱动程序使用的默认值“fs”。
gridfs-client-service	用于数据库连接的 MongoDB 客户端服务。
gridfs-database-name	要使用的数据库名称
gridfs-file-name	桶中作为该处理器目标的文件的名称。
gridfs-query	用于从 GridFS 中提取一个或多个文件的有效 MongoDB 查询。
mongo-operation-mode	此选项控制何时向下游处理器提供结果。如果启用了“Stream Query Results”，则如果收到输入 FlowFile 并开始查询，则不会跟踪相对于输入 FlowFile 的溯源。“Stream Query Results”模式下的错误处理机制：生成一个包含输入 FlowFile 原始内容和属性的新 FlowFile，并将其路由至 “failure” 关系。只有在 MongoDB 和 NiFi 之间存在可靠连接时，才应使用流式传输。
mongo-query-attribute	如有设置，则查询将写入输出 FlowFile 中的指定属性。

关系¶

名称	描述
failure	若处理 FlowFile 时出现故障，则会转为此关系。
original	如果查询未导致错误，则原始输入 FlowFile 将转为此关系
success	操作成功后，FlowFile 将发送到此关系。

写入属性¶

名称	描述
gridfs.file.metadata	如果文件存在，则随文件存储的自定义元数据将附加到此属性中。