如何在 Apache Flink 程序中调用 rest API

Question

我想知道是否有解决方案可以调用

REST API

1. (或多个 REST API(直接或否在 flink 程序中？如果存在这样的解决方案。
2. 你认为首先将我处理后的数据从 flink 推送到像 kafka 之类的消息代理，然后再从 kafka 调用 REST API 推送会更好吗？
3. 或者我也可以直接从我的 flink 程序调用 REST API？

Answer 1

用户函数中的代码(例如 RichFlatMapFunction 或 KeyedProcessFunction(可以执行任何您想要的操作，包括对外部服务进行 REST 调用。但是，应避免在用户函数中执行阻塞 I/O，因为检查点屏障在用户函数中被阻塞时无法通过运算符。

解决这个问题的一个好方法是将 Flink 的异步 I/O API 与提供异步客户端接口的 HTTP 库结合使用。