Mysql
 sql >> база данни >  >> RDS >> Mysql

Как да получите и обработите mysql записи с помощта на Airflow?

Наистина се борих с това през последните 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
)

Това връща в дневниците съдържанието на вашата DB заявка.

Надявам се това да е от полза за някой друг.



  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. SQL функция SUM без групиране на данни

  2. Вмъкнете Да или Не в MySQL въз основа на стойността на квадратчето за отметка

  3. Каква е по-добрата стратегия за съхраняване на регистрационни данни в база данни?

  4. Mysql - изберете идентификатори, които отговарят на всички тагове

  5. Как да поставя текст пред полето за автоматично увеличение в mysql (като:TTT00001)?