mysqloperator专题

airflow系列教程(十)MySqlOperator和PostgresOperator

1. 依赖 MySqlOperator 的数据库交互通过 MySQLdb 模块来实现, 使用前需要安装相关依赖: pip install apache-airflow[mysql] 2. 使用 使用 MySqlOperator 执行sql任务的一个简单例子: from airflow import DAGfrom airflow.utils.dates import days_ago