我使用的是Flink StateFun 3.1.0,并希望从嵌入式函数中调用远程Python函数。在StateFun 2.2中,我可以通过ProtoBuf (通过Protobuf生成) Java类的实例通过Any.pack(msg)创建Protobuf Any,这是可行的。现在我得到了
Caused by: java.lang.ClassCastException: class com.google.protobuf.Any cannot be cast to class org.apache.flink.statefun.sdk.reqreply.generated.TypedValue (
我正在尝试创建一个项目
每隔5分钟就会自动从网站上抓取数据,并将其保存到db烧瓶应用程序中与用户进行交互。用户从db请求数据。
抓取数据的python脚本如下所示:
import os
import time
while True:
os.system(scrape.py)
time.sleep(5*60)
我最初试图在每次用户请求数据时从网站上抓取数据。但我发现它工作得太慢了。
因此,现在我正在尝试制作另一个python脚本,它从网站中抓取数据并自动保存到db中。而烧瓶应用程序只需要从db获取数据。
我的问题是,如何同时运行python脚本和烧瓶应用程序?或者有什么更好的方法来解决