Azure Blob Storage到Snowflake加载报错：无效标识符'Employee_ID'

以下是针对性的排查和解决步骤：

1. 核对列映射的大小写与拼写细节 #

• Snowflake默认对无引号创建的列名不区分大小写，但会统一转为小写存储。如果你的Snowflake表列是无引号创建的（实际存储为employee_id），但ADF映射里用了Employee_ID，就会触发无效标识符错误。
• 检查ADF数据流的手动映射（建议关闭自动映射，改为手动逐列对应），确保Employee_ID和Snowflake表列的名称、大小写、下划线完全一致。

2. 确认Snowflake表列的实际存储格式 #

• 执行Snowflake命令：

  DESCRIBE TABLE <你的目标表名>;
  

  查看结果里的列名，确认是否存在大小写差异（比如表列实际是employee_id，但ADF里用了大写）。手动COPY命令能成功，说明你在COPY里指定的列名是匹配的，对比这个列名和ADF的映射配置。

3. 检查ADF Sink的关键配置 #

• 关闭自动建表选项：如果ADF开启了Auto create table，可能会生成和现有表结构不匹配的列名（比如强制大写），导致写入冲突。
• 确认Sink的数据库/ Schema/表名完全正确，避免选错对象导致列名不匹配。

4. 对比ADF生成的SQL和手动COPY语句 #

• 在Snowflake的查询历史里找到ADF执行的语句，和你手动成功的COPY命令对比：
  • 看ADF生成的INSERT/COPY语句里的列名是否和手动语句一致；
  • 检查是否ADF自动添加了不必要的引号，或者遗漏了必要的引号（比如表列是用双引号创建的"Employee_ID"，ADF必须用引号包裹列名）。

5. 排查CSV表头的隐藏字符 #

• 有些CSV表头看起来是Employee_ID，但实际包含空格、制表符或不可见字符，手动COPY时可能通过指定列列表避开了问题，但ADF读取表头时会把这些字符带入列名。
• 用文本编辑器（如Notepad++）打开CSV文件，查看表头的实际内容；或者在ADF数据源里预览数据，确认列名是否干净无多余字符。

6. 统一Snowflake会话参数 #

• 手动COPY时的会话参数可能和ADF连接的参数不一致，比如QUOTED_IDENTIFIERS_IGNORE_CASE：
  • 在ADF的Snowflake链接服务中，添加会话参数QUOTED_IDENTIFIERS_IGNORE_CASE = TRUE；
  • 或者在Sink的前置SQL里加入SET QUOTED_IDENTIFIERS_IGNORE_CASE = TRUE;，确保标识符大小写规则统一。

内容的提问来源于stack exchange，提问作者rakesh.data