Bagaimana cara mendapatkan dan memproses catatan mysql menggunakan Airflow?

Saya benar-benar berjuang dengan ini selama 90 menit terakhir, berikut adalah cara yang lebih deklaratif untuk diikuti oleh pendatang baru:

from airflow.hooks.mysql_hook import MySqlHook

def fetch_records():
  request = "SELECT * FROM your_table"
  mysql_hook = MySqlHook(mysql_conn_id = 'the_connection_name_sourced_from_the_ui', schema = 'specific_db')
  connection = mysql_hook.get_conn()
  cursor = connection.cursor()
  cursor.execute(request)
  sources = cursor.fetchall()
  print(sources)

...your DAG() as dag: code

task = PythonOperator(
  task_id = 'fetch_records',
  python_callable = fetch_records
)

Ini mengembalikan ke log konten kueri DB Anda.

Saya harap ini berguna untuk orang lain.