airflow DAG SQL 문법!!!!!!

Question

name &#61; 'jonggun'sql_insert_data &#61; &#34;insert into sql_test_ST(NAME) values (name);&#34; with DAG(dag_id&#61;'test_sql', schedule_interval&#61;'&#64;daily', default_args&#61;default_args, tags&#61;['sql'], catchup&#61;False) as dag: t2 &#61; MySqlOperator( task_id&#61;'insert_name', mysql_conn_id&#61;'mysql_outdoor', sql&#61;sql_insert_data ) airflow MysqlOperator 사용해서 mysql에 데이터를 저장하는 과정에서 문자열 변수를 쿼리에 넣고 싶은데 에러가 발생합니다.MySQLdb.OperationalError: (1054, &#34;Unknown column 'counSt' in 'field list'&#34;) #숫자 값의 변수를 넣을 때는 작동, 문자 입력 시 에러 발생num &#61; 123f&#34;insert into new_table(cnt) values ({num})&#34; 정수형 변수를 입력하면 잘 작동하는데 문자열 변수를 입력하면 위와 같은 에러가 발생합니다.

킹포링 (INTP) · Accepted Answer

문자열 변수를 SQL 쿼리에 넣으려면 문자열 변수를 따옴표로 둘러싸야 합니다. 현재 SQL 쿼리에서 name 변수가 따옴표로 둘러싸여 있지 않기 때문에 Unknown column 에러가 발생한 것입니다. 따라서, sql_insert_data 변수를 다음과 같이 수정하십시오.sql_insert_data &#61; f&#34;insert into sql_test_ST(NAME) values ('{name}');&#34; 이렇게 하면 name 변수가 따옴표로 둘러싸여 SQL 쿼리에 삽입됩니다.

airflow DAG SQL 문법!!!!!!

1개의 답변

#airflow 목록