在Apache Flink代码中调用外部API(RESTful)是否可能?如果可能,我们应该如何实现。
我在普通的Java代码中调用API是正常的,但是当我将相同的代码用于Apache Flink时,它会抛出异常:
java.io.IOException: Server returned HTTP response code: 500 for URL: http://example.com/someapi
在Apache Flink代码中调用外部API(RESTful)是否可能?如果可能,我们应该如何实现。
我在普通的Java代码中调用API是正常的,但是当我将相同的代码用于Apache Flink时,它会抛出异常:
java.io.IOException: Server returned HTTP response code: 500 for URL: http://example.com/someapi
是否可以在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。