Mysql 使用 SQLExecuteQueryOperator 的操作指南¶

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

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

使用 Operator¶

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

MySql Airflow 连接元数据¶
参数	输入
主机: 字符串	MySql 主机名
Schema: 字符串	设置默认执行 SQL 操作的 schema
登录名: 字符串	MySql 用户名
密码: 字符串	MySql 用户密码
端口: 整数	MySql 端口

SQLExecuteQueryOperator 的示例如下

tests/system/mysql/example_mysql.py

    drop_table_mysql_task = SQLExecuteQueryOperator(
        task_id="drop_table_mysql", sql=r"""DROP TABLE table_name;""", dag=dag
    )

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

tests/system/mysql/example_mysql.py

    mysql_task = SQLExecuteQueryOperator(
        task_id="drop_table_mysql_external_file",
        sql="/scripts/drop_table.sql",
        dag=dag,
    )

注意

可以传递给 Operator 的参数将优先于 Airflow 连接元数据中已有的参数（例如 schema、login、password 等等）。