airflow系列教程（十）MySqlOperator和PostgresOperator

本文主要是介绍airflow系列教程（十）MySqlOperator和PostgresOperator，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1. 依赖

MySqlOperator 的数据库交互通过 MySQLdb 模块来实现, 使用前需要安装相关依赖:

pip install apache-airflow[mysql]

2. 使用

使用 MySqlOperator 执行sql任务的一个简单例子:

from airflow import DAG
from airflow.utils.dates import days_ago
from airflow.operators.mysql_operator import MySqlOperatordefault_args = {'owner': 'airflow','depends_on_past': False,'start_date': days_ago(1),'email': ['j_hao104@163.com'],'email_on_failure': True,'email_on_retry': False,
}dag = DAG('MySqlOperatorExample',default_args=default_args,description='MySqlOperatorExample',schedule_interval="30 18 * * *")insert_sql = "insert into log SELECT * FROM temp_log"task = MySqlOperator(task_id='select_sql',sql=insert_sql

这篇关于airflow系列教程（十）MySqlOperator和PostgresOperator的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---