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



我试图从NIFI内部的rest 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/

相关内容

  • 没有找到相关文章

最新更新