小编Ous*_*lah的帖子

如何在 Cloud Composer 中导入自定义模块

我使用 apache Airflow 创建了一个本地项目,我想在 Cloud Composer 中运行它。我的项目包含自定义模块和调用它们的主文件。
示例:从 src.kuzzle 导入 KuzzleQuery

结构:
  • 主要.py
  • 源代码
    • 库兹勒.py


我已将项目文件夹导入到数据存储中,当我刷新气流作曲家的 UI 时,出现此错误:

  File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
  File "/home/airflow/gcs/dags/quality-control/main.py", line 8, in <module>
    from src.kuzzle import KuzzleQuery, Tag
ModuleNotFoundError: No module named 'src' ```
Run Code Online (Sandbox Code Playgroud)

python-3.x google-cloud-composer airflow-2.x

6
推荐指数
1
解决办法
2408
查看次数