使用 SQLExecuteQueryOperator 连接到 Sqlite¶

使用 SQLExecuteQueryOperator 在 Sqlite 数据库中执行 Sqlite 命令。

警告

以前，SqliteOperator 用于执行此类操作。但目前 SqliteOperator 已弃用，并将在未来版本的提供程序中删除。请考虑尽快切换到 SQLExecuteQueryOperator。

使用操作符¶

使用 conn_id 参数连接到您的 Sqlite 实例，其中连接元数据结构如下

Sqlite Airflow 连接元数据¶
参数	输入
主机：字符串	Sqlite 数据库文件

以下是使用 SQLExecuteQueryOperator 连接到 Sqlite 的示例

tests/system/providers/sqlite/example_sqlite.py[源代码]

    # Example of creating a task that calls a common CREATE TABLE sql command.
    create_table_sqlite_task = SQLExecuteQueryOperator(
        task_id="create_table_sqlite",
        sql=r"""
        CREATE TABLE Customers (
            customer_id INT PRIMARY KEY,
            first_name TEXT,
            last_name TEXT
        );
        """,
    )

此外，您可以使用外部文件来执行 SQL 命令。脚本文件夹必须与 DAG.py 文件位于同一级别。

tests/system/providers/sqlite/example_sqlite.py[源代码]

    # Example of creating a task that calls an sql command from an external file.
    external_create_table_sqlite_task = SQLExecuteQueryOperator(
        task_id="create_table_sqlite_external_file",
        sql="create_table.sql",
    )

参考¶

有关更多信息，请查看

Sqlite 文档

注意

通过 SQLExecuteQueryOperator() 给出的参数相对于通过 Airflow 连接元数据设置的参数（例如 schema、login、password 等）具有优先级。