달나라 노트

Airflow의 HiveOperator는 Hive database와 communication하는 것을 가능하게 해주는 operator입니다.간단하게 말하면 Hive database에 query를 날려서 query를 수행시킬 수 있다는 것이죠. 예시를 봅시다. from airflow import DAGdag = DAG( dag_id='test_dag', start_date=datetime.datetime(2022, 9, 27), schedule_interval='0 20 * * *')from airflow.providers.apache.hive.operators.hive import HiveOperator # 1op_test_hive = HiveOperator( # 2 dag=da..