中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

如何在Airflow中編寫執行MySQL查詢的任務

小樊
91
2024-08-10 22:38:44
欄目: 云計算

在Airflow中編寫執行MySQL查詢的任務可以通過使用PythonOperator來執行查詢的Python函數。以下是一個簡單的示例:

from airflow import DAG
from airflow.operators.python_operator import PythonOperator
from airflow.operators.mysql_operator import MySqlOperator
from datetime import datetime

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': datetime(2021, 1, 1),
    'email_on_failure': False,
    'email_on_retry': False,
    'retries': 1
}

dag = DAG('mysql_query_dag', default_args=default_args, schedule_interval='@daily')

def execute_mysql_query():
    # 連接MySQL數據庫
    conn = MySQLdb.connect(host="localhost", user="root", passwd="password", db="database")
    cursor = conn.cursor()
    
    # 執行查詢
    cursor.execute("SELECT * FROM table")
    
    # 獲取結果
    rows = cursor.fetchall()
    for row in rows:
        print(row)
    
    # 關閉連接
    conn.close()

mysql_task = PythonOperator(
    task_id='execute_mysql_query',
    python_callable=execute_mysql_query,
    dag=dag
)

mysql_task

在這個例子中,首先創建了一個DAG,并定義了一個Python函數execute_mysql_query,該函數連接到MySQL數據庫,執行查詢并打印結果。然后使用PythonOperator來執行這個函數,并將其添加到DAG中。當DAG運行時,該任務將連接到MySQL數據庫執行查詢。

0
长子县| 阜康市| 汕头市| 衡水市| 柏乡县| 沾益县| 日照市| 东丽区| 贡觉县| 城市| 云南省| 本溪市| 同德县| 通化县| 平南县| 凤山市| 南开区| 呼玛县| 利津县| 龙岩市| 甘谷县| 明星| 临汾市| 娄烦县| 旬邑县| 云安县| 南丰县| 庄河市| 辽中县| 华亭县| 肥西县| 繁峙县| 曲阜市| 丰都县| 调兵山市| 旺苍县| 新绛县| 恩施市| 南投市| 磐安县| 沙洋县|