我遵循本教程:https://docs.snowflake.com/en/sql-reference/functions/validate.html
尝试和“按查询id返回错误并将结果保存到表中以供将来参考”
但是对于无缝传输,我不希望总是放置作业id,因为它需要我转到snowflake控制台-转到history-获取作业id-复制并粘贴到python代码。
相反,我只想使用tablename(一个变量)和'last\u query\u id()',并给出错误列表。我有什么办法可以做到这一点吗?
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")
try:
ctx.cursor().execute("PUT file:///temp/data/{tableName}/* @%
{tableName}".format(tableName=tableName))
except Exception:
pass
ctx.cursor().execute("truncate table {tableName}".format(tableName=tableName))
ctx.cursor().execute("COPY INTO {tableName} ON_ERROR = 'CONTINUE' ".format(tableName=tableName,
FIELD_OPTIONALLY_ENCLOSED_BY = '""', sometimes=',', ERROR_ON_COLUMN_COUNT_MISMATCH = 'TRUE'))
我试过下面的验证函数…它给我这行的错误
错误为“sql编译错误:语法错误行1,位置74意外的'tablename'。语法错误行1位于位置83“}”
ctx.cursor().execute("create or replace table save_copy_errors as select * from
table(validate({tableName},'select last_query_id()'))");
ctx.close()
1条答案
按热度按时间tsm1rwdh1#
线路
应该换成这两个