시작하기무료로 시작하기

클래식 Dag를 TaskFlow로 변환하기

팀에서 모든 새 파이프라인에 TaskFlow API를 도입하기로 결정했습니다. 매니저가 기존 ETL 파이프라인을 재작성해 달라고 요청했는데, 이 파이프라인은 PythonOperator와 수동 >> 연결 방식을 사용하고 있었습니다.

기존 클래식 버전은 dags/classic_etl.py에서 참고할 수 있습니다. TaskFlow 방식으로 구조가 잡힌 파일이 준비되어 있으니, 이를 완성해 보세요.

이 연습은 강의의 일부입니다

Airflow로 데이터 파이프라인 구축하기

강의 보기

실습형 인터랙티브 연습문제

이론을 실습으로 바꾸는 인터랙티브 연습 중 하나를 만나보세요

연습 시작