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 文档中阅读有关处理连接器和其他依赖项的更多信息。