달나라 노트

Airflow에서 PostgresHook은 PostgreSQL database와 연결하여 PostgreSQL query를 실행하는 등의 작업을 해줍니다.PostgresOperator와 차이점이 무엇이며, PostgresHook은 어떨 때 쓰면 용이한지 알아봅시다. PostgresHook은 특히 PythonOperator와 같이 사용하면 용이하므로 아래 예시도 PythonOperator와 같이 사용하는 상황을 가정해보았습니다. from airflow import DAGfrom airflow.operators.python import PythonVirtualenvOperatordag = DAG( dag_id='test_dag', start_date=datetime.datetime(2022, 9..