달나라 노트

Airflow에서 PrestoHook은 Presto database와 연결하여 PrestoHook query를 실행하는 등의 작업을 해줍니다. PrestoHook은 특히 PythonOperator와 같이 사용하면 용이하므로 아래 예시도 PythonOperator와 같이 사용하는 상황을 가정해보았습니다. from airflow import DAGfrom airflow.operators.python import PythonVirtualenvOperatordag = DAG( dag_id='test_dag', start_date=datetime.datetime(2022, 9, 27), schedule_interval='0 20 * * *')def test_function(): import ..