1. 学习
    2. /
  2. 课程
    3. /
  3. Python으로 배우는 Apache Airflow 입문
Connected

练习

BashOperator 실행 순서 정의하기

비트시프트 연산자에 대해 배웠으니, 이제 워크플로에 pull 단계와 태스크 실행 순서를 추가해 보겠습니다. 현재 cleanup, consolidate, push_data 이렇게 세 가지 컴포넌트가 정의되어 있습니다.

DAG analytics_dag은 이전과 동일하게 제공되며, BashOperator는 이미 임포트되어 있습니다.

说明

100 XP
  • pull_sales라는 BashOperator를 정의하고 bash 명령은 wget https://salestracking/latestinfo?json으로 설정하세요.
  • pull_sales 오퍼레이터가 cleanup 태스크보다 먼저 실행되도록 설정하세요.
  • downstream 연산자를 사용해 그다음에 consolidate가 실행되도록 구성하세요.
  • 마지막으로 push_data가 실행되도록 비트시프트 연산자 중 하나를 사용하세요.