एयरफ्लो का उपयोग करके mysql रिकॉर्ड कैसे प्राप्त करें और संसाधित करें?

मैं पिछले 90 मिनट से वास्तव में इससे जूझ रहा था, यहां नए लोगों के लिए अनुसरण करने का एक अधिक घोषणात्मक तरीका है:

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
)

यह आपके डीबी क्वेरी की सामग्री को लॉग में वापस कर देता है।

मुझे आशा है कि यह किसी और के लिए उपयोगी है।