XCom으로 데이터 전달하기
XCom을 활용해 데이터를 더 쉽게 추적할 수 있도록 ETL 워크플로를 업데이트하는 작업 중입니다. 이를 위해 Dag 내 태스크 간의 의존성을 수정해야 합니다.
다음과 같이 사용할 수 있는 네 가지 태스크가 이미 정의되어 있습니다:
extract()-order_data를 반환합니다transform(order_data)- 요약된 데이터를 반환합니다load(summary_data)- XCom 정보를 반환하지 않습니다send_report()- 알림을 처리하는 비(非) XCom 태스크입니다
이 연습은 강의의 일부입니다
Python으로 배우는 Apache Airflow 입문
연습 안내
- 체인을 완성하기 위해
extract()와load()사이에transform태스크를 삽입하세요. - 결과를
etl_result라는 변수에 할당하세요. etl_result변수 이후에send_report가 실행되도록 설정하세요.
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
@dag(start_date=datetime(2026,4,1))
def etl_example():
# Chain extract, transform, and load, assigning the result
____ = load(____(extract()))
# Run send_report after the ETL tasks
etl_result ____ ____()
etl_example()