달나라 노트

Airflow의 PythonOperator는 내가 정의해둔 Python 함수를 실행해주는 역할을 하는 operator입니다. 예시를 봅시다. from airflow import DAGdag = DAG( dag_id='test_dag', start_date=datetime.datetime(2022, 9, 27), schedule_interval='0 20 * * *')from airflow.operators.python_operator import PythonOperator # 1def test_function(**kwargs): # 2 import pandas as pd import openpyxl import os import sys import datet..