SQL SSIS包中的Windows Azure蓝色Blob存储

这是一个多么有趣的问题！我不得不拼凑了很多我从未尝试过的作品。

我首先根据HOW TO：Blob Storage上的详细手册构建了一个简单的控制台应用程序。知道我拥有有效的代码后，我便可以将其适应SSIS。

我在程序包级别创建了3个SSIS变量。AccountName，AccountKey和ContainerName。它们都是数据类型String。这些提供凭据+我上传的数据将驻留的文件夹。

数据流

数据流的总体外观相当简单。脚本组件的数据源，它将充当目标。您将需要两列：一列为Blob提供唯一的名称，另一列为二进制位。

我的资料是一个琐碎的表。它具有国家名称和它们的标志（存储为varbinary（max）），如果您愿意的话，您可以从CIA世界手册中刮取。

目标将是C＃。添加类型为“目标”的脚本组件。

在“脚本”选项卡上，我列出了3个ReadOnly变量 User::AccountKey,User::AccountName,User::ContainerName

在“输入列”选项卡上，选择CountryName和FlagImage。

脚本本身如下。如操作方法中所述，您将需要添加对Microsoft.WindowsAzure.Storage程序集的引用，然后才能访问那里的最后3个程序集。

using System;
using System.Data;
using System.IO;
using Microsoft.SqlServer.Dts.Pipeline.Wrapper;
using Microsoft.SqlServer.Dts.Runtime.Wrapper;

// Must add reference to Microsoft.WindowsAzure.Storage for this to work
// http://www.windowsazure.com/en-us/develop/net/how-to-guides/blob-storage/
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Auth;
using Microsoft.WindowsAzure.Storage.Blob;

/// <summary>
/// Watch me load data to Azure from SSIS
/// </summary>
[Microsoft.SqlServer.Dts.Pipeline.SSISScriptComponentEntryPointAttribute]
public class ScriptMain : UserComponent
{

    /// <summary>
    /// The storage account used
    /// </summary>
    private CloudStorageAccount storageAccount;

    /// <summary>
    /// An entity to work with the Blobs
    /// </summary>
    private CloudBlobClient blobClient;

    /// <summary>
    /// Blobs live in containers
    /// </summary>
    private CloudBlobContainer container;

    /// <summary>
    /// blockBlob instead of a pageBlob
    /// </summary>
    private CloudBlockBlob blockBlob;

    /// <summary>
    /// This method is called once, before rows begin to be processed in the data flow.
    ///
    /// You can remove this method if you don't need to do anything here.
    /// </summary>
    public override void PreExecute()
    {
        base.PreExecute();
        string cs = string.Empty;
        string csTemplate = string.Empty;
        string accountName = string.Empty;
        string accountKey = string.Empty;
        string containerName = string.Empty;

        accountName = Variables.AccountName;
        accountKey = Variables.AccountKey;
        containerName = Variables.ContainerName;
        csTemplate = "DefaultEndpointsProtocol=https;AccountName={0};AccountKey={1}";
        cs = string.Format(csTemplate, accountName, accountKey);

        this.storageAccount = CloudStorageAccount.Parse(cs);
        this.blobClient = this.storageAccount.CreateCloudBlobClient();
        this.container = this.blobClient.GetContainerReference(containerName);
        this.container.CreateIfNotExists();
        this.container.SetPermissions(new BlobContainerPermissions { PublicAccess = BlobContainerPublicAccessType.Blob });

    }

    /// <summary>
    /// For each row passing through, upload to Azure
    /// </summary>
    /// <param name="Row">The row that is currently passing through the component</param>
    public override void Input0_ProcessInputRow(Input0Buffer Row)
    {
        string blobName = string.Empty;

        using (MemoryStream memStream = new MemoryStream(Row.FlagImage.GetBlobData(0, (int)Row.FlagImage.Length)))
        {
            this.blockBlob = this.container.GetBlockBlobReference(Row.CountryName);
            this.blockBlob.UploadFromStream(memStream);
        }
    }

}

全局程序集缓存（GAC）

您希望在SSIS中使用的程序集必须驻留在GAC中。除非已签名，否则大会不能进入GAC。幸运的是，对Azure程序集进行了签名，因此可以从Visual Studio命令提示符下键入gacutil -if "C:\Program Files\Microsoft SDKs\Windows Azure\.NET SDK\v2.1\ref\Microsoft.WindowsAzure.Storage.dll"该程序集版本所在的类型或等效版本

加载成功

作为证明，这是Azure存储资源管理器的快照