NIFI 在给定条件的帮助下从 API 获取数据答案

【问题标题】：NIFI fetching data from API with help of given conditionsNIFI 在给定条件的帮助下从 API 获取数据
【发布时间】：2020-06-10 20:01:02
【问题描述】：

我试图从 NIFI 中的一个 rest API 获取数据，我有以下场景。
1) 我有 Rest API，它使用给定的参数示例员工编号填充从 Cassandra 数据库获取数据。
2) NIFI 输入端口将从 Flink 应用程序接收到这个员工编号。
如何使用输入端口中收到的给定员工编号从其余 api 获取数据？我这里不需要调度机制，只需要在输入端口收到过滤器输入时从 Rest API 获取数据，这可以使用 NIFI 吗？

【问题讨论】：

标签： apache-flink apache-nifi flink-streaming apache-nifi-registry

【解决方案1】：

查看 NiFi 上已经内置的 http 处理器。

您可以使用InvokeHttp来查询外部的Rest Api，在输入端口使用已经在flowfile中注册的员工编号：

https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.5.0/org.apache.nifi.processors.standard.InvokeHTTP/

【讨论】：