apache-flink - Apache flink 外部 api 调用

Question

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

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

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

Answer 1

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

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

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

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