PyFlink - Kafka -缺失模块

Question

我试着从PyFlink和Kafka开始，但不要出错。

谢谢你的支持！

安装

python -m pip install apache-flink
pip install pyFlink 

码

from pyFlink.datastream import StreamExecutionEnvironment

误差

ModuleNotFoundError: No module named 'pyFlink'

Answer 1

要安装PyFlink，只需执行：

python -m pip install apache-flink

并确保您有兼容的Python版本(>= 3.5)。

导入是区分大小写的；引发错误是因为包名是"pyflink"，而不是"pyFlink“。因此，相反，您可以尝试：

from pyflink.datastream import StreamExecutionEnvironment

如果要使用Kafka，请记住也要添加必需(JAR)依赖关系，使用：

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

您可以阅读更多有关在PyFlink文档中处理连接器和其他依赖项的信息。