1. Învăţa
    2. /
  2. Courses
    3. /
  3. Python으로 배우는 Apache Airflow 입문
Connected

exercise

PythonOperator 사용하기

이미 BashOperator로 여러 Airflow 작업을 구현했지만, 일부 작업은 Python으로 구현하는 편이 더 적합하다는 점을 알게 되었습니다. 이번에는 Airflow 내에서 파일을 다운로드해 시스템에 저장하는 작업을 구현해 보겠습니다.

requests 라이브러리는 이미 임포트되어 있으며, DAG process_sales_dag도 미리 정의되어 있습니다.

Instrucțiuni 1 / 3

undefined XP
    1
    2
    3
  • URL과 savepath 두 매개변수를 받는 pull_file 함수를 정의하세요.
  • print() 함수와 Python f-string을 사용해 로그에 메시지를 남기세요.