airflow_sftp_minio_hdfs_boto3

https://github.com/hjkim-sun/airflow/tree/master

 

▲▲ Python 오퍼레이터에 op_args로 변수 할당하기 ▲▲

dags_python_with_op_args.py

 

▲▲ Python 오퍼레이터에 op_kwargs로 변수 할당하기 ▲▲

dags_python_with_op_kwargs.py

 

▲▲ Python Operator에서 Xcom 사용 ▲▲

dags_python_with_xcom_eg1.py

dags_python_with_xcom_eg2.py

 

▲▲ Bash Operator에서 xcom 사용 ▲▲

dags_bash_with_xcom.py

 

▲▲ python과 bash operator간에 xcom 변수사용 ▲▲

dags_bash_python_with_xcom.py

 

▲▲ Bash Operator에서 xcom 사용 ▲▲

dags_bash_with_variable.py