SQL 템플릿에서 Airflow의 XCom은 값을 큰따옴표로 묶은 문자열로 반환하는 반면 Snowflake는 SQL 쿼리에서 작은따옴표로 묶인 문자열을 사용합니다.
저는 ETL을 처음 접하고 공기 흐름과 눈송이 작업을 하고 있습니다. 저는 Python 연산자를 사용하여 mysql 테이블에서 생성된 최대 값을 얻고 해당 연산자의 xcom을 기반으로 눈송이 데이터의 csv 파일을 생성하여 mysql에서 가장 최근에 생성된 데이터만 눈송이로 덤프합니다. 문제는 SQL 템플릿에서 값을 추출할 때 airflow xcom이 큰따옴표를 반환한다는 것입니다. 그리고 Snowflake는 SQL 쿼리에서 작은따옴표를 허용합니다. 오류 사진
내 DAG 코드는 다음과 같습니다.
으아아아Mysql 쿼리 템플릿:
으아아아제 지식을 더해주셔서 미리 감사드립니다.
