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，请记得添加required (JAR) dependencies，使用：

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

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