airflow xcom1 Airflow - XCom으로 다음 Task에 데이터 넘기기 Airflow XCom이란??Airflow에서 XCom은 Cross-Communication의 약자로 Task간의 데이터를 교환하는 매커니즘이다. XCom을 사용하면 하나의 Task에서 생성된 데이터를 다른 Task에서 사용할 수 있어 Task간의 데이터교환이 가능해진다.Task에서 XCom에 데이터 주입PythonOperator의 return으로 xcom에 값 주입PythonOperator를 사용하면 자동으로 xcom에 return값이 주입된다.def get_restaurant_ids(): restaurant_ids = ["1212121212","12121213242"] return restaurant_idspush를 이용한 데이터 주입def restaurant_ids_push(**conte.. 2024. 6. 2. 이전 1 다음