使用Snowflake COPY INTO加载CSV时遇GET函数参数错误，如何解决？

这个错误的核心原因是你在COPY INTO语句中对VARCHAR类型的数据调用了GET函数——Snowflake的GET函数仅支持VARIANT、OBJECT或ARRAY类型的输入，无法直接作用于字符串。以下是针对性的排查和解决步骤：

1. 定位错误来源 #

先检查你的COPY INTO代码中GET函数的使用场景：

• 常见误区：误将CSV的普通字符串列（或整行字符串）当作JSON/VARIANT嵌套结构处理，比如对$1（CSV的整行字符串）调用GET($1, 'xxx')，或者对某个STRING类型的字段调用GET。
• 错误示例：

  COPY INTO target_table (col_a, col_b)
  FROM (
      SELECT
          GET($1, 'user_id'), -- $1是CSV的字符串行，不是VARIANT，触发报错
          GET($2, 'user_name')
      FROM @my_stage/data.csv
  )
  FILE_FORMAT = (TYPE = CSV);
  

2. 根据实际场景修正代码 #

场景1：CSV是普通结构化数据（无嵌套JSON） #

直接通过$n引用CSV的列即可，不需要使用GET函数：

COPY INTO target_table (col_a, col_b)
FROM (
    SELECT
        $1, -- 引用CSV第1列
        $2  -- 引用CSV第2列
    FROM @my_stage/data.csv
)
FILE_FORMAT = (TYPE = CSV FIELD_DELIMITER = ',' SKIP_HEADER = 1);

场景2：CSV某列是JSON格式的字符串 #

如果CSV中存在存储为字符串的JSON数据，需要先通过TRY_PARSE_JSON将其转换为VARIANT类型，再调用GET函数：

COPY INTO target_table (user_id, user_name)
FROM (
    SELECT
        GET(TRY_PARSE_JSON($3), 'id'), -- 先将第3列的JSON字符串转为VARIANT
        GET(TRY_PARSE_JSON($3), 'name')
    FROM @my_stage/data.csv
)
FILE_FORMAT = (TYPE = CSV FIELD_DELIMITER = ',' SKIP_HEADER = 1);

场景3：误用GET处理字符串 #

如果只是想提取字符串的部分内容，用字符串处理函数替代GET：

• 拆分分隔符字符串：用SPLIT_PART，比如SPLIT_PART($1, ',', 2)（取逗号分隔的第2个元素）
• 截取子串：用SUBSTRING，比如SUBSTRING($1, 1, 10)（截取前10个字符）

3. 额外排查点 #

• 检查文件格式定义：确认FILE_FORMAT的TYPE设置为CSV，避免误设为JSON导致Snowflake错误解析行数据类型。
• 验证阶段文件：执行以下语句查看实际数据，确认字段类型和内容是否符合预期：

  -- 查看阶段文件列表
  LIST @my_stage;
  -- 预览前10行数据
  SELECT $1, $2, $3 FROM @my_stage/data.csv LIMIT 10;
  

内容的提问来源于stack exchange，提问作者Robert Crump