mongodb - Nifi putMongo upsert 示例

Question

我正在努力寻找任何示例来展示如何在 putMongo NiFi 处理器中使用 upsert（或更新）功能。

如果有人可以为我提供一个示例，然后我可以根据自己的需要进行调整，我将不胜感激。

具体来说，给定一个包含单个 JSON 文档的流文件，从文档中提取单个值，对该值进行过滤，然后使用文档中其他可用属性和字段的子集进行更新插入。

我想做的类似于 SQL 合并，其中插入可以遵循一条路径，而更新可以遵循另一条路径，但我认为功能不允许这样做。

谢谢

标签： mongodbapache-nifi

Answer 1

从文档中提取单个值

该update query key参数应该为您完成这项工作。默认情况下，它使用_id，但您可以指定不同的键用于查找要更新的文档。update query此外，您可以使用配置参数指定查询。