[Airflow] python operator 사용해보기

파이썬 오퍼레이터는 파이썬 함수를 불러와서 실행하게 해줍니다. 이 기능을 통해서 파이썬으로 크롤러를 만들어서 연동할 수도 있고 전처리 함수를 연동할 수도 있습니다.

소스코드 from airflow import DAG from airflow.operators.python_operator import PythonOperator from datetime import datetime, timedelta dag = DAG ( 'python_example', description = 'Example DAG with PythonOperator', schedule_interval = timedelta(days=1), start_date = datetime(2023, 1, 1), catchup = False, tags=['example'], ) def my_python_function(): print('Hello, Airflow!') print("current time: " , datetime.no...