在PyFlink中导入本地包

Question

我正试图在PyFlink项目中编写一个本地包。但我只能通过相对路径导入。

喜欢

from .package import func

是否可以在导入为PyFlink的env.add_python_file('/path_to_project')项目中的包中使用绝对路径？

Answer 1

为了使用绝对路径--来自https://lists.apache.org/list.html?user@flink.apache.org：完全应答这里的答案--抽象结构目录：

flink_app/
    data_service/
        filesystem.py
    validator/
        validator.py
    common/
        constants.py
    main.py <- entry job

在提交PyFlink作业时，可以使用选项-pyFiles和--pyModule1指定python文件和条目主模块，如下所示：

$ ./bin/flink run --pyModule flink_app.main --pyFiles ${工作区}/flink_app

这样，目录下的所有文件都将添加到本地客户端和远程python工作人员的PYTHONPAHT中。