首先，dags文件夹被添加到sys路径中。因此，dags文件夹中的任何内容都可以导入到Airflow env中。
我将采取一个例子，你已经给了。所以让我们考虑下面的文件夹结构驻留在dags文件夹如/home/airflow/dags

exampleProject
--> models   
----> database
-------> __init__.py
-------> example1.py
--> services
----> __init__.py
----> service1.py

让我们假设exampleProject/models/database/example1.py看起来像这样

def example1_func():
    print("In example1_func")

现在，让我们在services/service1.py中导入上述函数，下面是我们将如何导入example1_func

from exampleProject.models.database.example1 import example1_func

def service1_func():
    example1_func()
    print('inside service1_func')

现在我们可以通过导入类似的方法在任务中调用service1_func

from exampleProject.services.service1 import service1_func

# creating dag
...

# calling the function in a task
service1_func()
...