Azure ADF如何将ArrayType转换为PostgreSQL的JSONB[]？

错误原因：ADF默认将包含JSON元素的ArrayType解析为text[]类型，但目标PostgreSQL列是jsonb[]，导致类型不匹配。以下是几种可行的解决方法：

方法1：ADF派生列预处理数组 #

1. 添加派生列活动，针对源数组列生成符合PostgreSQL jsonb[]格式的字符串：
   • 假设源数组列名为source_data，使用以下表达式：

     concat('{', replace(arrayToString(map(source_data, x -> toJson(x)), ','), '"', '\\"'), '}')
     

     逻辑说明：将数组中每个JSON元素转为标准JSON字符串，转义内部双引号，再用{}包裹成PostgreSQL数组的文本格式。
2. 在复制活动的映射中，将派生后的列关联到目标jsonb[]列，PostgreSQL会自动识别该格式并转换为jsonb[]。

方法2：PostgreSQL端通过视图自动转换 #

1. 针对目标表创建视图，在视图中完成类型转换：

   CREATE OR REPLACE VIEW target_data_view AS
   SELECT other_columns, CAST(data AS jsonb[]) AS data FROM target_table;
   

2. 让ADF直接写入该视图，PostgreSQL会自动将传入的text[]转为jsonb[]。

方法3：复制活动自定义类型映射与SQL写入 #

1. 在复制活动的映射标签中，找到目标数组列，设置类型转换：
   • 源类型保持Array，目标类型选String，转换表达式用：

     concat('{', arrayToString(source_data, ','), '}')
     

2. 在复制活动的目标设置→附加设置中，自定义写入SQL：

   INSERT INTO target_table (other_columns, data) VALUES (?, CAST(? AS jsonb[]))
   

   注意替换占位符顺序与列映射一致。

内容的提问来源于stack exchange，提问作者K N