PyFlink - Kafka -缺少模块

zxlwwiss  于 12个月前  发布在  Apache
关注(0)|答案(1)|浏览(192)

我试图从PyFlink和Kafka开始,但得到下面的错误。
感谢您的支持!

安装

python -m pip install apache-flink
pip install pyFlink

字符串

验证码

from pyFlink.datastream import StreamExecutionEnvironment

错误

ModuleNotFoundError: No module named 'pyFlink'

w80xi6nr

w80xi6nr1#

要安装PyFlink,你只需要执行:
第一个月
并确保你有一个兼容的Python版本(>= 3.5)。
导入是区分大小写的;抛出错误是因为包名是“pyflink”,而不是“pyFlink”。所以,你可以尝试:
from pyflink.datastream import StreamExecutionEnvironment
如果你要使用Kafka,请记住还要添加所需的依赖项,使用:

config = t_env.get_config().get_configuration()
config.set_string("pipeline.jars",
                  "file:///path/to/jar/jarfile.jar")

字符串
您可以阅读更多关于在PyFlink documentation中处理连接器和其他依赖项的信息。

相关问题