我试图从PyFlink和Kafka开始,但得到下面的错误。
感谢您的支持!
安装
python -m pip install apache-flink
pip install pyFlink
字符串
验证码
from pyFlink.datastream import StreamExecutionEnvironment
型
错误
ModuleNotFoundError: No module named 'pyFlink'
型
我试图从PyFlink和Kafka开始,但得到下面的错误。
感谢您的支持!
安装
python -m pip install apache-flink
pip install pyFlink
字符串
验证码
from pyFlink.datastream import StreamExecutionEnvironment
型
错误
ModuleNotFoundError: No module named 'pyFlink'
型
1条答案
按热度按时间w80xi6nr1#
要安装PyFlink,你只需要执行:
第一个月
并确保你有一个兼容的Python版本(>= 3.5)。
导入是区分大小写的;抛出错误是因为包名是“pyflink”,而不是“pyFlink”。所以,你可以尝试:
from pyflink.datastream import StreamExecutionEnvironment
个如果你要使用Kafka,请记住还要添加所需的依赖项,使用:
字符串
您可以阅读更多关于在PyFlink documentation中处理连接器和其他依赖项的信息。