.NET ile blob yükleme

  • Makale

Bu makalede.NET için Azure Depolama istemci kitaplığını kullanarak blobu karşıya yükleme işlemi gösterilmektedir. Bir dosya yolundan, akıştan, ikili nesneden veya metin dizesinden blok bloba veri yükleyebilirsiniz. Ayrıca blob akışını açıp bu akışa yazabilir veya bloklar halinde büyük blobları karşıya yükleyebilirsiniz.

Önkoşullar

Blok bloba veri yükleme

Blok blobuna veri yüklemek için aşağıdaki yöntemlerden birini kullanabilirsiniz:

Bu karşıya yükleme yöntemlerini kullanırken, istemci kitaplığı Put Blob'u veya bir dizi Blok Koy çağrısını ve ardından Blok Listesini Koy'u çağırabilir. Bu davranış, nesnenin genel boyutuna ve veri aktarımı seçeneklerinin nasıl ayarlandığına bağlıdır.

Blob Depolama'da bir akış açmak ve bu akışa yazmak için aşağıdaki yöntemlerden birini kullanın:

Yerel dosya yolundan blok blobu yükleme

Aşağıdaki örnekte yerel dosya yolundan bir blok blobu karşıya yüklenir:

public static async Task UploadFromFileAsync(
    BlobContainerClient containerClient,
    string localFilePath)
{
    string fileName = Path.GetFileName(localFilePath);
    BlobClient blobClient = containerClient.GetBlobClient(fileName);

    await blobClient.UploadAsync(localFilePath, true);
}

Akıştan blok blobu yükleme

Aşağıdaki örnek bir Stream nesnesi oluşturup akışı karşıya yükleyerek blok blobunu karşıya yükler.

public static async Task UploadFromStreamAsync(
    BlobContainerClient containerClient,
    string localFilePath)
{
    string fileName = Path.GetFileName(localFilePath);
    BlobClient blobClient = containerClient.GetBlobClient(fileName);

    FileStream fileStream = File.OpenRead(localFilePath);
    await blobClient.UploadAsync(fileStream, true);
    fileStream.Close();
}

BinaryData nesnesinden blok blobu yükleme

Aşağıdaki örnek bir BinaryData nesnesinden blok blobunu karşıya yükler.

public static async Task UploadFromBinaryDataAsync(
    BlobContainerClient containerClient,
    string localFilePath)
{
    string fileName = Path.GetFileName(localFilePath);
    BlobClient blobClient = containerClient.GetBlobClient(fileName);

    FileStream fileStream = File.OpenRead(localFilePath);
    BinaryReader reader = new BinaryReader(fileStream);

    byte[] buffer = new byte[fileStream.Length];
    reader.Read(buffer, 0, buffer.Length);
    BinaryData binaryData = new BinaryData(buffer);

    await blobClient.UploadAsync(binaryData, true);

    fileStream.Close();
}

Dizeden blok blobu yükleme

Aşağıdaki örnek bir dizeden blok blobunu karşıya yükler:

public static async Task UploadFromStringAsync(
    BlobContainerClient containerClient,
    string blobName)
{
    BlobClient blobClient = containerClient.GetBlobClient(blobName);
    string blobContents = "Sample blob data";

    await blobClient.UploadAsync(BinaryData.FromString(blobContents), overwrite: true);
}

Blob Depolama'da bir akışa yükleme

Blob Depolama'da bir akışı açabilir ve buna yazabilirsiniz. Aşağıdaki örnek, Blob Depolama'da bir zip dosyası oluşturur ve bu dosyaya dosya yazar. Yerel bellekte zip dosyası oluşturmak yerine, aynı anda yalnızca bir dosya bellektedir.

public static async Task UploadToStreamAsync(
    BlobContainerClient containerClient,
    string localDirectoryPath)
{
    string zipFileName = Path.GetFileName(
        Path.GetDirectoryName(localDirectoryPath)) + ".zip";

    BlockBlobClient blockBlobClient = containerClient.GetBlockBlobClient(zipFileName);

    using (Stream stream = await blockBlobClient.OpenWriteAsync(true))
    {
        using (ZipArchive zip = new ZipArchive(stream, ZipArchiveMode.Create, leaveOpen: false))
        {
            foreach (var fileName in Directory.EnumerateFiles(localDirectoryPath))
            {
                using (var fileStream = File.OpenRead(fileName))
                {
                    var entry = zip.CreateEntry(
                        Path.GetFileName(fileName), CompressionLevel.Optimal);
                    using (var innerFile = entry.Open())
                    {
                        await fileStream.CopyToAsync(innerFile);
                    }
                }
            }
        }
    }
}

Yapılandırma seçenekleriyle blok blobu karşıya yükleme

Blobu karşıya yüklerken istemci kitaplığı yapılandırma seçeneklerini tanımlayabilirsiniz. Bu seçenekler performansı geliştirmek, güvenilirliği artırmak ve maliyetleri iyileştirmek için ayarlanabilir. Aşağıdaki kod örneklerinde, karşıya yükleme yöntemini çağırırken yapılandırma seçeneklerini tanımlamak için BlobUploadOptions'ın nasıl kullanılacağı gösterilmektedir.

Karşıya yüklemede veri aktarımı seçeneklerini belirtme

Veri aktarımı işlemlerinin performansını geliştirmek için StorageTransferOptions içindeki değerleri yapılandırabilirsiniz. Aşağıdaki kod örneği için StorageTransferOptions değerleri ayarlamayı ve bir örneğin parçası BlobUploadOptions olarak seçenekleri eklemeyi gösterir. Bu örnekte sağlanan değerlerin bir öneri olması amaçlanmamıştır. Bu değerleri düzgün bir şekilde ayarlamak için uygulamanızın belirli gereksinimlerini dikkate almanız gerekir.

public static async Task UploadWithTransferOptionsAsync(
    BlobContainerClient containerClient,
    string localFilePath)
{
    string fileName = Path.GetFileName(localFilePath);
    BlobClient blobClient = containerClient.GetBlobClient(fileName);

    var transferOptions = new StorageTransferOptions
    {
        // Set the maximum number of parallel transfer workers
        MaximumConcurrency = 2,

        // Set the initial transfer length to 8 MiB
        InitialTransferSize = 8 * 1024 * 1024,

        // Set the maximum length of a transfer to 4 MiB
        MaximumTransferSize = 4 * 1024 * 1024
    };

    var uploadOptions = new BlobUploadOptions()
    {
        TransferOptions = transferOptions
    };

    FileStream fileStream = File.OpenRead(localFilePath);
    await blobClient.UploadAsync(fileStream, uploadOptions);
    fileStream.Close();
}

Veri aktarımı seçeneklerini ayarlama hakkında daha fazla bilgi edinmek için bkz. .NET ile karşıya yüklemeler ve indirmeler için performans ayarlama.

Karşıya yüklemede aktarım doğrulama seçeneklerini belirtme

Aktarım sırasında verilerin düzgün bir şekilde yüklendiğinden ve üzerinde oynanmadığından emin olmak için aktarım doğrulama seçeneklerini belirtebilirsiniz. Aktarım doğrulama seçenekleri, BlobClient örneğinden çağrılan tüm yöntemlere doğrulama seçeneklerini uygulayan BlobClientOptions kullanılarak istemci düzeyinde tanımlanabilir.

BlobUploadOptions kullanarak yöntem düzeyinde aktarım doğrulama seçeneklerini de geçersiz kılabilirsiniz. Aşağıdaki kod örneği, bir BlobUploadOptions nesnenin nasıl oluşturulacağını ve sağlama toplamı oluşturmak için bir algoritmanın nasıl belirtileceğini gösterir. Sağlama toplamı daha sonra hizmet tarafından karşıya yüklenen içeriğin veri bütünlüğünü doğrulamak için kullanılır.

public static async Task UploadWithChecksumAsync(
    BlobContainerClient containerClient,
    string localFilePath)
{
    string fileName = Path.GetFileName(localFilePath);
    BlobClient blobClient = containerClient.GetBlobClient(fileName);

    var validationOptions = new UploadTransferValidationOptions
    {
        ChecksumAlgorithm = StorageChecksumAlgorithm.Auto
    };

    var uploadOptions = new BlobUploadOptions()
    {
        TransferValidation = validationOptions
    };

    FileStream fileStream = File.OpenRead(localFilePath);
    await blobClient.UploadAsync(fileStream, uploadOptions);
    fileStream.Close();
}

Aşağıdaki tabloda , StorageChecksumAlgorithm tarafından tanımlandığı şekilde sağlama toplamı algoritması için kullanılabilir seçenekler gösterilmektedir:

Name Değer Açıklama
Otomatik 0 Önerilen. Kitaplığın bir algoritma seçmesine izin verir. Farklı kitaplık sürümleri farklı algoritmalar seçebilir.
Hiçbiri 1 Seçili algoritma yok. Sağlama toplamlarını hesaplamayın veya istemeyin.
MD5 2 Standart MD5 karma algoritması.
StorageCrc64 3 Azure Depolama özel 64 bit CRC.

Not

İstekte belirtilen sağlama toplamı hizmet tarafından hesaplanan sağlama toplamıyla eşleşmiyorsa karşıya yükleme işlemi başarısız olur. Varsayılan yeniden deneme ilkesi kullanılırken işlem yeniden denenmiyor. .NET'te, hangi algoritmanın kullanıldığına bağlı olarak durum kodu 400 ve hata kodu Md5Mismatch veya Crc64Mismatchile oluşturulurRequestFailedException.

Dizin etiketleriyle karşıya yükleme

Blob dizin etiketleri, anahtar-değer etiketi özniteliklerini kullanarak depolama hesabınızdaki verileri kategorilere ayırır. Bu etiketler otomatik olarak dizinlenir ve verileri kolayca bulmak için aranabilir çok boyutlu bir dizin olarak kullanıma sunulur. BlobUploadOptions örneğine etiket ekleyebilir ve bu örneği yöntemine UploadAsync geçirebilirsiniz.

Aşağıdaki örnek, dizin etiketlerine sahip bir blok blobunu karşıya yükler:

public static async Task UploadBlobWithTagsAsync(
    BlobContainerClient containerClient,
    string blobName)
{
    BlobClient blobClient = containerClient.GetBlobClient(blobName);
    string blobContents = "Sample blob data";

    BlobUploadOptions options = new BlobUploadOptions();
    options.Tags = new Dictionary<string, string>
    {
        { "Sealed", "false" },
        { "Content", "image" },
        { "Date", "2020-04-20" }
    };

    await blobClient.UploadAsync(BinaryData.FromString(blobContents), options);
}

Karşıya yüklemede blob'un erişim katmanını ayarlama

BlobUploadOptions sınıfını kullanarak karşıya yüklemede blob'un erişim katmanını ayarlayabilirsiniz. Aşağıdaki kod örneğinde blob karşıya yüklenirken erişim katmanının nasıl ayarlanacağı gösterilmektedir:

public static async Task UploadWithAccessTierAsync(
    BlobContainerClient containerClient,
    string localFilePath)
{
    string fileName = Path.GetFileName(localFilePath);
    BlockBlobClient blockBlobClient = containerClient.GetBlockBlobClient(fileName);

    var uploadOptions = new BlobUploadOptions()
    {
        AccessTier = AccessTier.Cool
    };

    FileStream fileStream = File.OpenRead(localFilePath);
    await blockBlobClient.UploadAsync(fileStream, uploadOptions);
    fileStream.Close();
}

Erişim katmanını ayarlamaya yalnızca blok blobları için izin verilir. Blok blobu için erişim katmanını Hot, Cool, Coldveya Archiveolarak ayarlayabilirsiniz. Erişim katmanını olarak ayarlamak için Colden düşük istemci kitaplığı sürümü olan 12.15.0 kullanmanız gerekir.

Erişim katmanları hakkında daha fazla bilgi edinmek için bkz. Erişim katmanlarına genel bakış.

Blokları hazırlayıp işleyerek blok blobu karşıya yükleme

Tek tek veri bloklarını el ile hazırlayarak karşıya yüklemeleri bloklara bölme konusunda daha fazla denetime sahip olabilirsiniz. Bir blobu oluşturan tüm bloklar hazırlandığında, bunları Blob Depolama'ya işleyebilirsiniz. Blokları paralel olarak karşıya yükleyerek performansı artırmak için bu yaklaşımı kullanabilirsiniz.

public static async Task UploadBlocksAsync(
    BlobContainerClient blobContainerClient,
    string localFilePath,
    int blockSize)
{
    string fileName = Path.GetFileName(localFilePath);
    BlockBlobClient blobClient = blobContainerClient.GetBlockBlobClient(fileName);

    FileStream fileStream = File.OpenRead(localFilePath);
    ArrayList blockIDArrayList = new ArrayList();
    byte[] buffer;

    var bytesLeft = (fileStream.Length - fileStream.Position);

    while (bytesLeft > 0)
    {
        if (bytesLeft >= blockSize)
        {
            buffer = new byte[blockSize];
            await fileStream.ReadAsync(buffer, 0, blockSize);
        }
        else
        {
            buffer = new byte[bytesLeft];
            await fileStream.ReadAsync(buffer, 0, Convert.ToInt32(bytesLeft));
            bytesLeft = (fileStream.Length - fileStream.Position);
        }

        using (var stream = new MemoryStream(buffer))
        {
            string blockID = Convert.ToBase64String(
                Encoding.UTF8.GetBytes(Guid.NewGuid().ToString()));

            blockIDArrayList.Add(blockID);
            await blobClient.StageBlockAsync(blockID, stream);
        }
        bytesLeft = (fileStream.Length - fileStream.Position);
    }

    string[] blockIDArray = (string[])blockIDArrayList.ToArray(typeof(string));

    await blobClient.CommitBlockListAsync(blockIDArray);
}

Kaynaklar

.NET için Azure Blob Depolama istemci kitaplığını kullanarak blobları karşıya yükleme hakkında daha fazla bilgi edinmek için aşağıdaki kaynaklara bakın.

REST API işlemleri

.NET için Azure SDK, Azure REST API'sinin üzerinde derleyerek tanıdık .NET paradigmalarıyla REST API işlemleriyle etkileşim kurmanızı sağlayan kitaplıklar içerir. Blobları karşıya yüklemek için istemci kitaplığı yöntemleri aşağıdaki REST API işlemlerini kullanır:

Kod örnekleri

Ayrıca bkz.