搜狐

Airflow“3分钟上手”教程：用Python定义定时数据清洗任务

from airflow import DAG from airflow.operators.python import PythonOperator from datetime import datetime, timedelta import pandas as pd # 1. 定义数据清洗函数 ...