我有一个项目，我有这个项目的布局

|
|-- dags/
|---- dag.py
|-- logs/
|-- plugins/
|---- __init__.py
|---- core.py
|-- airflow.cfg

然后我把核心部分保存在core.py中。
当我想使用www.example.com文件中的代码时core.py，我将在www.example.com中dag.py执行以下操作：

from core import <some function>

• 注：*

这是我的airflow.cfg文件，它注册了plugins文件夹，以便PythonVirtualOperator可以找到插件中的代码。

[core]
dags_folder = {AIRFLOW_HOME}/dags

plugins_folder = {AIRFLOW_HOME}/plugins%

顶级域名注册商;

因此，对于您的情况，我可以想象您可以在airflow.cfg中这样做：

plugins_folder = {AIRFLOW_HOME}/shared_utils%

你可以把你的shared_utils文件夹移到python文件夹下的一个新文件夹my_package中，然后把my_package路径添加到你的python路径中：

# in your host
echo export PYTHONPATH="/path/to/python/my_package:$PYTHONPATH" >> ~/.profile
# in airflow docker image
ENV PYTHONPATH="/path/to/python/my_package"

现在你可以在所有的python控制台中从你的包导入：

from shared_utils.auth import module_x