每次从流中获取数据时，我都要从restapi的flink进程元素中获取数据，怎么才能做到呢，我找不到足够的数据来异步调用rest服务。请帮我拿些样品。
xuo3flqw1#
所有的工作都发生在 asyncInvoke 的 RichAsyncFunction . 所以，为了能够调用rest服务，您需要使用一些异步http客户机（从技术上讲，它可以是一个同步客户机，但这没有意义）。异步http客户机用法的示例可以在这里找到。因此，当您执行异步请求时，您需要做的就是调用 resultFuture.complete 在请求处理程序中，以便结果在flink中向下游传递。
asyncInvoke
RichAsyncFunction
resultFuture.complete
1条答案
按热度按时间xuo3flqw1#
所有的工作都发生在
asyncInvoke的RichAsyncFunction. 所以，为了能够调用rest服务，您需要使用一些异步http客户机（从技术上讲，它可以是一个同步客户机，但这没有意义）。异步http客户机用法的示例可以在这里找到。因此，当您执行异步请求时，您需要做的就是调用
resultFuture.complete在请求处理程序中，以便结果在flink中向下游传递。