在气流DAG中导入本地模块(python脚本)
在气流DAG中导入本地模块(python脚本)
提问于 2018-05-03 08:29:16
我正在尝试将本地模块( python脚本)导入到我的DAG中。
目录结构：
airflow/
├── dag
│ ├── __init__.py
│ └── my_DAG.py
└── script
└── subfolder
├── __init__.py
└── local_module.pyMy_DAG.py中的示例代码：
#trying to import from local module
from script.subfolder import local_module
#calling a function in local_module.py
a = some_function() 我在气流中出现了一个错误，上面写着“坏掉的DAG: my_DAG。没有一个模块名为'local_ module‘。”
我已经更新了空气流量为1.9.0，但这并不能解决问题。
- 这里的解决方案是什么？
- 我还在某个地方读到，我可以通过创建一个插件来解决这个问题。有人能指出我是怎么做到的吗？
谢谢。
Stack Overflow用户
发布于 2018-05-03 11:00:49
这通常与气流的配置有关。
在airflow.cfg中，确保airflow_home中的路径被正确地设置为气流目录结构所在的路径。
然后气流扫描所有子文件夹并填充它们，以便可以找到模块。
否则，只需确保要导入的文件夹位于Python：How to use PYTHONPATH中。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/50150384
复制相关文章
相似问题
腾讯云开发者
