반응형 #백엔드개발1 [airflow] dag 생성 1. 기본 폼 from airflow import DAG with DAG() as dag: dag라는 객체는 데이터 파이프라인 그 자체이다. 'DAG()' 안의 파라미터 값들을 조정해서 dag를 생성한다. 2. 첫번째 파라미터 : 'dag id' with DAG('forex_data_pipeline') as dag: dag id는 각각의 dag가 가진 유일한 id값을 의미한다.모든 dag id 중 겹치는 id값이 전혀 없어야 한다. 3. 두번째 파라미터 : 'start_date' from datetime import datetime with DAG('forex_data_pipeline', start_date=datetime(2022, 12, 4)) as dag scheduling을 멈추는 날짜를 지정하는.. 2023. 6. 29. 이전 1 다음 반응형
