오지's blog

airflow에서 select값을 가져오는 방법 본문

개발노트/데이터베이스

airflow에서 select값을 가져오는 방법

오지구영ojjy90 2023. 4. 18. 10:52
728x90
반응형
sf_hook = SnowflakeHook(snowflake_conn_id="SNOWFLAKE_CONN_ID")
sql = f"SELECT DISTINCT(REPLACE(SUBSTR({date_column_name}, 1, 10),'-', '')) FROM {table_name} WHERE SUBSTR({date_column_name}, 1, 10)='{yesterday.strftime(date_string)}';"

conn = sf_hook.get_conn()
cursor = conn.cursor()
cursor.execute(sql)

result = cursor.fetchone()

 

참고

https://stackoverflow.com/questions/53565834/fetch-results-from-bigqueryoperator-in-airflow

 

Fetch results from BigQueryOperator in airflow

I am trying to fetch results from BigQueryOperator using airflow but I could not find a way to do it. I tried calling the next() method in the bq_cursor member (available in 1.10) however it return...

stackoverflow.com

 

 

'개발노트 > 데이터베이스' 카테고리의 다른 글

distinct와 order by를 함께 쓰려고 할때  (0) 2023.06.28
AttributeError: 'OptionEngine' object has no attribute 'execute' 에러 해결 방안  (0) 2023.04.19
DELETE시 의문의 에러 메세지  (0) 2023.04.11
insert into select 시 특정 컬럼만 제외하고 SELECT하는 방법 - SNOWFLAKE  (0) 2023.04.05
snowflake에서 select시 where절의 서브 쿼리 between이용 하여 정제  (0) 2023.03.16
'개발노트/데이터베이스' Related Articles more
Comments