我正在通过snowflake-connector
. 中的列df
有(
,)
在里面。我正在尝试用df.to_sql(table, con=engine, index=False, if_exists='replace', method=pd_writer)
.
- 这是动态创建表。
- 将
df
in parquet 文件转换PUT
为 S3 存储桶。 - 尝试对
COPY
parquet 数据进行处理,table
但出现异常。
复制 sql -
COPY INTO "DB1.SCHM1.T1" /* Python:snowflake.connector.pandas_tools.write_pandas() */
("Name", "Year(1)", "Year(2)")
FROM
(SELECT $1:Name, $1:Year(1), $1:Year(2) FROM @"djaks")
FILE_FORMAT=(TYPE=PARQUET COMPRESSION=auto)
PURGE=TRUE ON_ERROR=abort_statement
错误 -
SQL Compilation error: Syntax error line 1 at position X unexpected '1'. syntax error line 1 at position X ','.
这是因为语法$1:Year(1)
。我无法更改列名,其他解决方案是什么?