[Airflow] DAG 실행

🟡 DAG 저장소 위치 확인

DAG 저장소는 검색하면 나오는데, 실제로 없을 수 있으니 없다면 생성하길 바람

$ airflow config get-value core dags_folder
/root/airflow/dags

 

🟡 DAG 저장소 위치 확인

DAG 기본 저장소 위치 변경 가능 !

/root/airflow/dags 경로 하위에 DOG 파일을 저장한다.

 

🟡 DAG 파일 생성

from airflow import DAG
from airflow.operators.bash import BashOperator
from datetime import datetime

# DAG 정의
with DAG(
    'hello_world_dag',
    default_args={
        'owner': 'airflow',
        'start_date': datetime(2023, 9, 1),
    },
    schedule_interval='@daily',  # 매일 실행
    catchup=False,
) as dag:
    
    # 태스크 정의
    hello_task = BashOperator(
        task_id='say_hello',
        bash_command='echo "Hello, World!"'
    )

 

🟡 DAG 파일 확인

아래와 같이 DAG 저장소에 생성한 DAG 를 확인 할 수 있다.

( 만약 없다면 재기동 해야한다. )

 

🟡 DAG 저장소 위치 확인

DAG 저장소는 검색하면 나오는데, 실제로 없을 수 있으니 없다면 생성하길 바람

$ airflow config get-value core dags_folder
/root/airflow/dags

 

🟡 DAG 저장소 위치 확인

DAG 기본 저장소 위치 변경 가능 !

/root/airflow/dags 경로 하위에 DOG 파일을 저장한다.

 

🟡 DAG 파일 생성

from airflow import DAG
from airflow.operators.bash import BashOperator
from datetime import datetime

# DAG 정의
with DAG(
    'hello_world_dag',
    default_args={
        'owner': 'airflow',
        'start_date': datetime(2023, 9, 1),
    },
    schedule_interval='@daily',  # 매일 실행
    catchup=False,
) as dag:
    
    # 태스크 정의
    hello_task = BashOperator(
        task_id='say_hello',
        bash_command='echo "Hello, World!"'
    )

 

🟡 DAG 파일 확인

아래와 같이 DAG 저장소에 생성한 DAG 를 확인 할 수 있다.

( 만약 없다면 재기동 해야한다. )