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的异步I/O API允许用户使用数据流的异步请求客户端。这里的更多详细信息和示例。

java.io.ioexception：服务器返回的http响应代码：500 for url：http：//example.com/someapi

这似乎是非链接错误，因为响应为500。检查要发送的请求标题/参数，并验证是否正确创建了HTTP请求。尝试一些公用事业，例如Postman首先测试API。