Azure Data Factory(ADF)如何向存储过程传递二进制数据

1. ADF二进制Base64编码能力判断 #

「Azure Data Factory没有提供对二进制数据做base64编码的能力」的说法不正确，ADF内置表达式库提供了base64()原生函数，可直接对二进制内容进行Base64编码，配套还有binary()、base64ToBinary()、hex()等二进制处理函数可使用。

2. 直接传byte[]到varbinary存储过程参数的可行性 #

该方案不可行，报错原因是ADF存储过程活动的参数体系不支持原生字节数组（byte[]）类型的传递，仅支持JSON兼容的字符串、数值、布尔、数组等可序列化类型，原生二进制内容无法被正确序列化传递，因此会抛出「存储过程参数'Photo'的'Value'属性值无效」的错误。

3. ADF结合存储过程的实现方案 #

操作步骤： #

• Web活动调用API获取JPEG二进制数据后，通过表达式@base64(activity('<Web活动名称>').output)将二进制内容转换为Base64编码字符串
• 修改存储过程参数定义，将@Photo的类型从varbinary(max)调整为nvarchar(max)，用于接收Base64字符串
• 在存储过程内部通过SQL内置方法将Base64字符串转换为varbinary(max)，再写入目标表，示例逻辑如下：

CREATE OR ALTER PROCEDURE 存储过程名称
    @Photo nvarchar(max) NULL
AS
BEGIN
    DECLARE @PhotoBinary varbinary(max)
    -- Base64转varbinary逻辑
    SET @PhotoBinary = CAST(N'' AS XML).value('xs:base64Binary(sql:variable("@Photo"))', 'varbinary(max)')
    -- 写入目标表的逻辑
    INSERT INTO 你的目标表 (Photo字段, 其他字段)
    VALUES (@PhotoBinary, 其他参数值)
END

• ADF存储过程活动中，将生成的Base64字符串作为字符串类型参数传入@Photo即可正常执行。

轻量替代方案（无需调整存储过程参数） #

如果不想修改存储过程，也可以通过ADF脚本活动直接生成SQL语句执行：

@concat('INSERT INTO 你的目标表(Photo字段) VALUES (0x', hex(activity('<Web活动名称>').output),')')

该方式直接生成十六进制格式的插入语句，无需经过存储过程参数传递，也可实现二进制图片数据的写入。 #

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