Airflow是一個開源的工作流程管理系統，能夠幫助用戶創建、調度和監控工作流程。Airflow是由Python編寫的，底層使用了許多開源技術。

在Airflow中，MySQL是一個非常重要的數據庫。我們可以將Airflow的元數據存儲在MySQL數據庫中，包括任務執行狀態、任務調度信息、任務依賴等。下面是一個使用Airflow MySQL的例子，介紹如何在Airflow中連接和使用MySQL數據庫。

#import MySQLOperator
from airflow.operators.mysql_operator import MySqlOperator
#create a connection to MySQL
mysql_conn = MySqlHook(mysql_conn_id='mysql_conn_id', schema='mysql_schema')
#create a task to execute a MySQL query
mysql_task = MySqlOperator(
task_id='mysql_task_id',
mysql_conn_id='mysql_conn_id',
sql='select * from table',
database='mysql_database')
#add the task to a DAG
dag = DAG(
dag_id='mysql_dag_id',
default_args=default_args,
description='Example DAG using MySQL',
schedule_interval='@hourly')
mysql_task.set_upstream(mysql_sensor)
#run the DAG
airflow run mysql_dag_id mysql_task_id [date]

在上面的例子中，我們首先導入MySQLOperator。創建一個MySqlHook對象并指定連接ID和數據庫名稱。然后創建一個MySqlOperator任務來執行MySQL查詢。最后，將任務添加到一個DAG中。

現在你已經了解了如何使用Airflow連接和使用MySQL數據庫。希望這篇文章對你有所幫助。