我对Flink非常陌生,通过遵循的文档来尝试异步IO操作。我有一个文本文件,里面有一堆整数。我在文件上创建一个流,然后对每一行进行异步http请求,最后将结果存储到一个输出文件中。我创建了一个fastAPI rest端点,用于管理简单的get请求。在Flink代码中,我使用java 库将http调用封装到异步请求中。但问题是,当我运行Flink代码时,总是会超时。
我的输入文件看起来类似于:
-9
42
2
12
15
18
13
9
45
-15
11
...
fastAPI代码如下所示:
import time
from random import random
from fastap