0

命令状态的Snowkflake 文档COPY INTO（用于 COPY 选项）

ON_ERROR = 继续 | 跳过文件 | SKIP_FILE_num | SKIP_FILE_num% | ABORT_STATEMENT

继续加载文件。COPY 语句针对每个数据文件遇到的最多一个错误返回错误消息。请注意，ROWS_PARSED 和 ROWS_LOADED 列值之间的差异表示包含检测到的错误的行数。但是，这些行中的每一行都可能包含多个错误。要查看数据文件中的所有错误，请使用 VALIDATION_MODE 参数或查询 VALIDATE 函数。

但对我来说，它似乎不服从，因为我看到了默认值，即 SKIP_FILE 被应用，因为文件中的任何错误都会被跳过。

create or replace file format jsonThing type = 'json' DATE_FORMAT='yyyy-mm-dd' 
   TIMESTAMP_FORMAT='YYYY-MM-DD"T"HH24:MI:SSZ' TRIM_SPACE=TRUE NULL_IF=('\\N', 'NULL',''); 

create or replace stage snowflake_json_stage
   storage_integration = snowflake_json_storage_integration
   url = 'azure://snowflakejson.blob.core.windows.net/cdrs'
   file_format = jsonThing
   COPY_OPTIONS = (ON_ERROR=CONTINUE PURGE=TRUE MATCH_BY_COLUMN_NAME=CASE_INSENSITIVE)
   COMMENT='The snowflake json stage';

CREATE or REPLACE PIPE SNOWFLAKE_JSON_PIPE
   AUTO_INGEST = TRUE
   integration = snowflake_json_notification_integration
   as
   COPY INTO purge.public.cdrs
   from @SNOWFLAKE_JSON_STAGE 
   ON_ERROR=CONTINUE 
   MATCH_BY_COLUMN_NAME=CASE_INSENSITIVE;

选项是否ON_ERROR=CONTINUE适用于 PIPE？

注意：该文件是一个 NDJSON 文件。

4

0 回答 0