1. 학습
    2. /
  2. 강의
    3. /
  3. Python으로 배우는 Apache Airflow 입문
Connected

연습 문제

XCom으로 데이터 전달하기

XCom을 활용해 데이터를 더 쉽게 추적할 수 있도록 ETL 워크플로를 업데이트하는 작업 중입니다. 이를 위해 Dag 내 태스크 간의 의존성을 수정해야 합니다.

다음과 같이 사용할 수 있는 네 가지 태스크가 이미 정의되어 있습니다:

  • extract() - order_data를 반환합니다
  • transform(order_data) - 요약된 데이터를 반환합니다
  • load(summary_data) - XCom 정보를 반환하지 않습니다
  • send_report() - 알림을 처리하는 비(非) XCom 태스크입니다

지침

100 XP
  • 체인을 완성하기 위해 extract()와 load() 사이에 transform 태스크를 삽입하세요.
  • 결과를 etl_result라는 변수에 할당하세요.
  • etl_result 변수 이후에 send_report가 실행되도록 설정하세요.