我试图从nifi内部的restapi获取数据，我有以下场景。
1） 我有restapi，它用给定的参数example employee number填充cassandra数据库中的fetch数据。
2） nifi输入端口将从flink应用程序接收此员工编号。
如何使用输入端口中接收到的给定雇员编号从restapi获取数据？我在这里不需要调度机制，只要在输入端口接收到过滤器输入时从restapi获取数据，这可以使用nifi吗？
我试图从nifi内部的restapi获取数据，我有以下场景。
1） 我有restapi，它用给定的参数example employee number填充cassandra数据库中的fetch数据。
2） nifi输入端口将从flink应用程序接收此员工编号。
如何使用输入端口中接收到的给定雇员编号从restapi获取数据？我在这里不需要调度机制，只要在输入端口接收到过滤器输入时从restapi获取数据，这可以使用nifi吗？
1条答案
按热度按时间jv2fixgn1#
查看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/