Apache Flink 外部 API 调用

Question

3

在Apache Flink代码中调用外部API（RESTful）是否可能？如果可能，我们应该如何实现。

我在普通的Java代码中调用API是正常的，但是当我将相同的代码用于Apache Flink时，它会抛出异常：

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

- Kspace

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- koldbyte · Accepted Answer

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

您可以使用Flink Streaming API提供的Async I/O功能。Flink的Async I/O API允许用户在数据流中使用异步请求客户端。更多详情和示例在此处。

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

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