1. 学ぶ
    2. /
  2. コース
    3. /
  3. Python으로 배우는 Apache Airflow 입문
Connected

演習

EmailOperator와 종속성

워크플로에 사용할 PythonOperator를 성공적으로 정의했으니, 이제 워크플로가 완료되면 파싱된 JSON 파일을 이메일로 받아보고 싶다는 매니저의 요청이 있습니다. 이전 태스크들은 그대로 정의되어 있고 DAG process_sales_dag도 구성되어 있어요. 참고로, 이 태스크는 예전 방식의 DAG 정의를 사용하며, 여러분을 위해 미리 추가되어 있습니다.

指示

100 XP
  • 이메일을 보내는 클래스를 임포트하세요.
  • Operator를 정의하고 필요한 인자(to, subject, files)를 지정하세요.
  • 태스크 실행 순서를 설정하여 순차적으로 실행되도록 하세요(파일을 가져오고, 파일을 파싱한 다음, 매니저에게 이메일을 보냅니다).