apache-flink - 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”。因此，您可以尝试:

从 pyflink.datastream 导入 StreamExecutionEnvironment

如果您要使用 Kafka，请记得同时添加 required (JAR) dependencies ，使用:

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

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