SQL 템플릿에서 Airflow의 XCom은 값을 큰따옴표로 묶은 문자열로 반환하는 반면 Snowflake는 SQL 쿼리에서 작은따옴표로 묶인 문자열을 사용합니다.

Question

저는 ETL을 처음 접했고 공기 흐름과 눈송이 작업을 하고 있습니다. 나는 Python 연산자를 사용하여 mysql 테이블에서 생성된 최대 값을 얻고 해당 연산자의 xcom을 기반으로 눈송이 데이터의 csv 파일을 생성하여 mysql에서 가장 최근에 생성된 데이터만 눈송이로 덤프합니다. 문제는 SQL 템플릿에서 값을 추출할 때 airflowxcom이 큰따옴표를 반환한다는 것입니다. 그리고 Snowflake는 SQL 쿼리에서 작은따옴표를 허용합니다. 오류 그림 내 DAG 코드는 다음과 같습니다. defaultconverter(o):ifisinst

P粉896751037 · Answer

get_max_created_timestamp:

의 출력을 변경할지 여부 으아아아

도와주세요. 이제 눈송이 문자열 기대치를 나타내기 위해 문자열이 올바르게 인용됩니다.