Apache flink 外部 api 调用

【问题标题】：Apache flink external api callApache flink 外部 api 调用
【发布时间】：2018-04-27 20:48:11
【问题描述】：

是否可以在 apache flink 代码中调用外部 api（RESTful）。如果有可能，那么我们如何做到这一点。

我正在从简单的 java 代码调用 api，它工作正常，但是当我在 apache flink 中使用相同的代码时，它会引发异常：

java.io.IOException: Server returned HTTP response code: 500 for URL: http://example.com/someapi

【问题讨论】：

【解决方案1】：

是否可以在 apache flink 代码中调用外部 api (RESTful)。如果有可能，那么我们如何做到这一点。

您可以使用 Flink Streaming API 中提供的异步 I/O 功能。 Flink 的 Async I/O API 允许用户使用带有数据流的异步请求客户端。更多细节和例子here。

java.io.IOException：服务器返回 HTTP 响应代码：500 for URL：http://example.com/someapi

这似乎是非 flink 错误，因为响应是 500。检查正在发送的请求标头/参数并验证是否正确创建了 http 请求。首先尝试使用 PostMan 等实用程序来测试 API。

【讨论】：