apache-flink - 使用异步 I/O 从 Flink 调用 http REST api

Question

在从流中获取的每个数据中，我都必须从 flink 进程元素中的 Rest API 中获取数据，我怎样才能做到这一点，我找不到足够的材料来异步调用 Rest 服务。请帮助我提供一些示例文章。

标签： apache-flinkflink-streaming

Answer 1

所有的工作都发生asyncInvoke在RichAsyncFunction. 因此，为了能够调用 REST 服务，您需要使用一些异步 HTTP 客户端（从技术上讲，它可能是一个同步客户端，但这没有意义）。可以在此处找到异步 http 客户端使用的示例。

因此，当您执行异步请求时，您需要做的就是调用resultFuture.complete您的请求处理程序，以便将结果在 Flink 中传递到下游。