将csv文件加载到雪花时,在处理csv文件时遇到错误。每当遇到相同错误的记录很少,并且我不想从csv文件中删除任何记录时,我如何处理该问题。
还是我可以在这里实现尝试?我想纠正或跳过有错误的csv中的记录
import snowflake.connector
tableName='F58155'
ctx = snowflake.connector.connect(
user='-',
password='-',
account='-')
cs = ctx.cursor()
ctx.cursor().execute("USE DATABASE STORE_PROFILE_LANDING")
ctx.cursor().execute("USE SCHEMA PUBLIC")
ctx.cursor().execute("PUT file:///temp/data/{tableName}/* @%{tableName}".format(tableName=tableName))
ctx.cursor().execute("truncate table {tableName}".format(tableName=tableName))
ctx.cursor().execute("COPY INTO {tableName} ".format(tableName=tableName,
FIELD_OPTIONALLY_ENCLOSED_BY
= '"', sometimes=','))
ctx.close()
这是第178行出现错误的图像。最佳答案
在这里解释。此错误的最常见原因是字段值包含定界符
https://community.snowflake.com/s/article/Copy-Error-Message-Field-delimiter-found-while-expecting-record-delimiter-n
关于python-3.x - 在期望记录分隔符 ','时找到字段分隔符 '\n',我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/63003096/