如何通过 MongoDB 查询结果有条件地处理 FlowFile？
How to conditionally process FlowFile's by a MongoDB query result?
我需要根据 MongoDB 查询的结果处理文件列表，但我找不到任何处理器可以让我这样做。我基本上必须根据涉及该文件属性的查询结果获取每个文件并对其进行处理或完全丢弃。
我在 NiFi 1.50 中看到的唯一 MongoDB 相关处理器是 GetMongo，它显然无法接收连接，但只会根据配置的参数发出 FlowFiles。
我是不是找错地方了？
NIFI-4827 是一个改进的 Jira，旨在让 GetMongo 接受传入的流文件，内容将包含查询，属性将接受表达式语言。该代码仍在审查中，但目的是使其在即将发布的 NiFi 1.6.0 版本中可用。
同时，作为一种可能的解决方法，如果有 REST API，您可以使用 InvokeHttp to make the call(s) manually and parse the result(s). Also if you have a JDBC driver for MongoDB (such as Unity), you might be able to use ExecuteSQL.
我需要根据 MongoDB 查询的结果处理文件列表，但我找不到任何处理器可以让我这样做。我基本上必须根据涉及该文件属性的查询结果获取每个文件并对其进行处理或完全丢弃。
我在 NiFi 1.50 中看到的唯一 MongoDB 相关处理器是 GetMongo，它显然无法接收连接，但只会根据配置的参数发出 FlowFiles。
我是不是找错地方了？
NIFI-4827 是一个改进的 Jira，旨在让 GetMongo 接受传入的流文件，内容将包含查询，属性将接受表达式语言。该代码仍在审查中，但目的是使其在即将发布的 NiFi 1.6.0 版本中可用。
同时，作为一种可能的解决方法，如果有 REST API，您可以使用 InvokeHttp to make the call(s) manually and parse the result(s). Also if you have a JDBC driver for MongoDB (such as Unity), you might be able to use ExecuteSQL.