Apache-Nifi :删除MongoDB集合

Question

我想删除一些集合:我的MongoDB数据库中的db['mycollection'].remove({})，我发现有一个deleteMongo处理器，但我不知道如何使用它，因为我找不到示例。

那么，deleteMongo处理器允许这样做吗？如果有的话，你能给我举个例子吗？

提前感谢！

Answer 1

DeleteMongo实际上并不删除集合，而是删除所提供集合中的文档。请查看处理器的文档here。它期望传入的FlowFile将查询作为其内容。您可以尝试的一个快速示例是：

GenerateFlowFile -> DeleteMongo

配置GenerateFlowFile并提供一个类似于{ "customer.name" : "Smith, John"}的MongoDB查询，然后将其连接到DeleteMongo。您必须使用数据库名称、连接字符串和集合名称来配置DeleteMongo。

话虽如此，它可能不适合您删除集合的要求，但是从技术上讲，如果您的查询是{}，并且DeleteMongo处理器的Delete Mode设置为Delete Many，那么您可以从配置的集合中擦除整个文档集合