如何简单地导入自定义模块（带有sql查询的文件）

Question

我有一些要存储在文件中的SQL查询，因此我可以轻松地调用它们。该文件名为sql_queries.py，并存储在helpers文件夹下的plugins文件夹中。

from airflow.plugins_manager import AirflowPlugin
import helpers

class SqlQueries:
    songplay_table_insert = ("""
        SELECT *
        FROM XXXX
    """)

class Project(AirflowPlugin):
    name = "Project"
    helpers = [SqlQueries]

我正在尝试像这样from airflow.helpers import SqlQueries 从我的达格导入我的查询>

我已经为操作员使用了相同的系统，并且可以正常工作。为什么在这种情况下不呢？

我有一些要存储在文件中的SQL查询，因此我可以轻松地调用它们。该文件名为sql_queries.py，并存储在plugins文件夹下的helpers文件夹中。从airflow.plugins_manager导入...

Answer 1

您不需要Airflow插件，可以像常规Python模块一样在DAG中导入任何自定义模块。

Answer 2

因为Airflow插件不支持创建助手。您可以编码自定义执行程序，宏，admin_views，flask_blueprints，menu_links，appbuilder_views，appbuilder_menu_items，global_operator_extra_links和operator_extra_links。