如何将SQL Server Image数据类型迁移至Azure Blob容器？

方案一：修正Azure Data Factory Copy Data活动配置 #

你遇到的源接收器不匹配问题，大概率是未正确配置二进制数据处理规则和动态路径生成：

• 源配置：
  选择SQL Server作为源，查询语句包含所需字段：SELECT Id, Name, EntityId, RecordId, BlobData FROM [你的表名]，并在源设置的"Binary column"选项中指定BlobData为二进制列。
• 接收器配置：
  选择Azure Blob Storage作为接收器，指定目标容器；在"Folder path"中输入动态表达式@concat(toString(item().EntityId), '/', toString(item().RecordId), '/Files')生成层级路径；文件名直接调用Name字段，表达式写@item().Name；接收器的"Copy behavior"选择Binary copy，避免二进制数据转码。
• 迭代处理：用Foreach活动包裹Copy Data活动，将Foreach的输入设置为源查询的结果集，实现每条记录对应生成一个目标路径下的文件。

方案二：使用Azure Function批量处理 #

如果ADF配置仍有问题，用Azure Function写代码处理更灵活：

1. 创建C#或PowerShell类型的Azure Function，触发方式可选定时触发或HTTP触发。
2. 核心代码逻辑：
   • 连接本地SQL Server，查询未迁移记录（建议新增IsMigrated标记字段避免重复处理）。
   • 对每条记录拼接Blob路径：{容器名}/{EntityId}/{RecordId}/Files/{Name}。
   • 将BlobData二进制内容上传到对应Blob路径，上传成功后更新SQL Server的迁移标记。
3. 示例C#代码片段：

   // 连接SQL Server
   using (SqlConnection conn = new SqlConnection("你的SQL连接字符串"))
   {
       conn.Open();
       string query = "SELECT Id, Name, EntityId, RecordId, BlobData FROM [你的表名] WHERE IsMigrated = 0";
       SqlCommand cmd = new SqlCommand(query, conn);
       SqlDataReader reader = cmd.ExecuteReader();
       
       // 连接Azure Blob
       BlobServiceClient blobServiceClient = new BlobServiceClient("你的Blob连接字符串");
       BlobContainerClient containerClient = blobServiceClient.GetBlobContainerClient("你的容器名");
       
       while (reader.Read())
       {
           int entityId = reader.GetInt32(2);
           int recordId = reader.GetInt32(3);
           string fileName = reader.GetString(1);
           byte[] blobData = (byte[])reader.GetValue(4);
           
           // 构建Blob路径
           string blobPath = $"{entityId}/{recordId}/Files/{fileName}";
           BlobClient blobClient = containerClient.GetBlobClient(blobPath);
           
           // 上传二进制数据
           using (MemoryStream stream = new MemoryStream(blobData))
           {
               blobClient.Upload(stream, overwrite: true);
           }
           
           // 更新迁移标记
           using (SqlCommand updateCmd = new SqlCommand("UPDATE [你的表名] SET IsMigrated = 1 WHERE Id = @Id", conn))
           {
               updateCmd.Parameters.AddWithValue("@Id", reader.GetInt32(0));
               updateCmd.ExecuteNonQuery();
           }
       }
   }
   

方案三：使用SSIS（SQL Server Integration Services） #

若熟悉SSIS，这是稳定的传统方案：

1. 创建SSIS包，添加OLE DB源连接本地SQL Server，获取所有目标记录。
2. 添加Azure Blob Destination组件，配置Blob存储连接。
3. 在Blob Destination的"Blob path"中用表达式生成动态路径：[EntityId] + "/" + [RecordId] + "/Files/" + [Name]。
4. 将BlobData字段映射到Blob Destination的"Binary data"列，运行包完成迁移。

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