使用 SQLExecuteQueryOperator 连接到 Sqlite¶

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

注意

之前，使用 SqliteOperator 执行此类操作。在弃用后，此操作符已被移除。请改用 SQLExecuteQueryOperator。

使用操作符¶

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

Sqlite Airflow 连接元数据¶
参数	输入
Host: 字符串	Sqlite 数据库文件

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

tests/system/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/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 等）。