간단한 DAG 만들기
Airflow 구성 요소를 살펴보고 나서, 직접 워크플로를 테스트해 보기로 했습니다. 먼저 기본 매개변수를 정의하고 워크플로에 사용할 DAG 객체를 생성해 봅시다.
datetime 객체는 이미 임포트되어 있습니다.
이 연습은 강의의 일부입니다
Python으로 배우는 Apache Airflow 입문
연습 안내
- Airflow DAG 객체를 임포트하세요. 대소문자를 구분하니 주의하세요.
- DAG 데코레이터를 정의하고 DAG 이름을
example_etl로 지정하세요. - 코드 파일 끝에서 DAG 함수를 호출하세요.
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
# Import the dag object
from ____ import dag
# Define the Dag attributes
____(
____='example_etl',
start_date=datetime(2026, 3, 1),
)
def example_etl():
pass
# Run the Dag
____()