1. Uczyć się
  2. /
  3. Courses
  4. /
  5. Python으로 배우는 Apache Airflow 입문

Connected

Exercise

더 많은 PythonOperator 사용하기

워크플로를 계속 구현하려면, 다운로드한 파일을 파싱하고 변경 사항을 저장하는 단계를 하나 더 추가해야 합니다. DAG process_sales_dag는 이미 정의되어 있고 pull_file 태스크가 추가되어 있습니다. 이 경우 사용할 Python 함수 parse_file(inputfile, outputfile)도 이미 제공되어 있습니다.

Airflow 태스크를 구현할 때, 개별 단계의 세부 내용을 모두 이해하지 못할 때가 자주 있습니다. Airflow의 구조 안에 이 단계들을 올바르게 감싸기만 하면, 원하는 워크플로를 구현할 수 있습니다.

Instrukcje

100 XP
  • 변수 parse_file_task에 id가 parse_file인 Python 태스크를 정의하세요.
  • Operator에 parse_file(inputfile, outputfile)을 추가하세요.
  • callable에 전달할 인자를 정의하세요.