task.skip_if1 airflow Taskflow api: @dag, @task 1. Taskflow API 소개Taskflow API는 Airflow에서 Python 함수를 간단하게 DAG 태스크로 변환할 수 있는 기능이다. 이 API를 사용하면 다음과 같은 이점이 있다.기존 Python 코드를 Airflow로 쉽게 이관할 수 있다.코드의 가독성과 유지보수성을 향상시킬 수 있다.DAG 구조를 더 직관적으로 표현할 수 있다.2. 기본 사용법Taskflow API의 핵심 데코레이터는 아래와 같다.@dag : DAG를 정의하는 데코레이터이다.@task : 개별 태스크를 정의하는 데코레이터이다.기본 예시import pendulumfrom airflow.decorators import dag, taskimport json@dag( schedule="@once", start_dat.. 2024. 8. 11. 이전 1 다음 반응형
