要安装PyFlink，你只需要执行：
第一个月
并确保你有一个兼容的Python版本（>= 3.5）。
导入是区分大小写的;抛出错误是因为包名是“pyflink”，而不是“pyFlink”。所以，你可以尝试：
from pyflink.datastream import StreamExecutionEnvironment个
如果你要使用Kafka，请记住还要添加所需的依赖项，使用：

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

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