PyFlink

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)。

进口是case-sensitive；抛出错误是因为包名是“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 中阅读有关处理连接器和其他依赖项的更多信息。

PyFlink - Kafka - 缺少模块