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

NIFI fetching data from API with help of given conditions

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

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

您可以使用 InvokeHttp 来查询外部 Rest Api,使用预先在输入端口的流文件中注册的员工编号:

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