더 많은 PythonOperator 사용하기

워크플로를 계속 구현하려면, 다운로드한 파일을 파싱하고 변경 사항을 저장하는 단계를 하나 더 추가해야 합니다. DAG process_sales_dag는 이미 정의되어 있고 pull_file 태스크가 추가되어 있습니다. 이 경우 사용할 Python 함수 parse_file(inputfile, outputfile)도 이미 제공되어 있습니다.

Airflow 태스크를 구현할 때, 개별 단계의 세부 내용을 모두 이해하지 못할 때가 자주 있습니다. Airflow의 구조 안에 이 단계들을 올바르게 감싸기만 하면, 원하는 워크플로를 구현할 수 있습니다.