Skip to content

Instantly share code, notes, and snippets.

@nithyadurai87

nithyadurai87/airflow_variables.py

Created November 23, 2020 17:52
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save nithyadurai87/6c3a7035a4ce48372a6d8864e5f65a0b to your computer and use it in GitHub Desktop.
Save nithyadurai87/6c3a7035a4ce48372a6d8864e5f65a0b to your computer and use it in GitHub Desktop.
Download ZIP
Raw
airflow_variables.py
from datetime import datetime
from airflow import DAG
import os
from airflow.operators.python_operator import PythonOperator
from airflow.models import Variable
usr = Variable.get("mysql_username")
pwd = Variable.get("mysql_password")
def backup():
backup_cmd = 'mysqldump -u '+usr+' -p'+pwd+' sample > "/home/shrini/backups/"sample_"$(date +"%Y%m%d_%H%M%S").sql"'
os.system(backup_cmd)
dag = DAG('mysql_backup', description='Mysql backup every hour', schedule_interval='00 * * * *', start_date=datetime(2020, 11, 2), catchup=False)
backup_operator = PythonOperator(task_id='backup_task', python_callable=backup, dag=dag)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment