J'ai vraiment eu du mal avec cela au cours des 90 dernières minutes, voici une méthode plus déclarative à suivre pour les nouveaux arrivants :
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
)
Cela renvoie aux journaux le contenu de votre requête DB.
J'espère que cela sera utile à quelqu'un d'autre.
