ADF中Snowflake同步至Salesforce：避免源NULL值转为接收器空字符串

针对你遇到的Snowflake中Int/Double/Date类型的NULL值在Blob暂存中被转为空字符串，导致Salesforce类型转换失败的问题，结合你不能用Data Flows、只能用Azure暂存的限制，提供以下3种可行方案：

方案1：Snowflake源查询预处理，确保NULL值正确传递 #

直接在Snowflake的源查询中明确保留NULL值，避免ADF将其转为空字符串。同时配置ADF的Snowflake数据集属性，确保NULL值被正确识别：

1. 编写Snowflake查询时，不对NULL值做额外转换，直接保留原类型的NULL：

SELECT
  date_column,    -- Date类型NULL保留为NULL
  int_column,     -- Int类型NULL保留为NULL
  double_column,  -- Double类型NULL保留为NULL
  string_column
FROM your_target_table

2. 在ADF的Snowflake数据集的连接属性中，找到Null value设置，将其指定为NULL（而非空字符串），确保ADF读取Snowflake数据时，将NULL值原样传递到暂存。

方案2：ADF Copy活动映射中转换空字符串回NULL #

如果无法修改Snowflake源查询，可以在ADF的Copy活动列映射里，为每个有类型问题的列添加转换规则，把暂存中的空字符串转回对应类型的NULL：

1. 打开Copy活动的映射面板，找到目标Salesforce的Date/Int/Double类型列。
2. 点击列右侧的转换表达式按钮，输入对应规则：
   • Date类型列：@equals(item().source_date_col, '') ? null : item().source_date_col
   • Int类型列：@equals(item().source_int_col, '') ? null : item().source_int_col
   • Double类型列：@equals(item().source_double_col, '') ? null : item().source_double_col
3. 保存配置后，Copy活动会在向Salesforce写入前，将空字符串转换为对应类型的NULL，避免类型不匹配错误。

方案3：改用Parquet作为暂存格式，保留类型与NULL信息 #

CSV格式会将NULL值转为空字符串，而Parquet是列存格式，能完整保留数据类型和NULL值信息，从根源避免问题：

1. 调整第一个Copy活动（Snowflake到Blob暂存）的格式设置，选择Parquet而非默认的CSV。
2. 第二个Copy活动（Blob到Salesforce）读取Parquet文件时，会直接识别原类型的NULL值，无需额外转换即可正确写入Salesforce。

各方案适用场景 #

• 方案1：最直接高效，适合能修改Snowflake源查询的场景，减少中间环节。
• 方案2：适合无法修改源查询的情况，灵活处理中小数据量的转换需求。
• 方案3：适合大数据量场景，利用Parquet的性能优势，同时彻底解决NULL值类型转换问题。

内容的提问来源于stack exchange，提问作者Fernando Basaez