Picton 9.2.0

Picton

关于

Picton是一个库，旨在使处理Azure存储变得更简单。

该库中的主要功能包括：

1) 扩展方法

扩展方法允许在保持一个锁（也称为“租约”）的情况下对Blob进行操作。

• 锁定Blob一段时间，并在已经被其他进程锁定的情况下进行重试。
• 扩展现有的租约。
• 释放现有的租约。
• 使用给定的字符串覆盖Blob的内容（也有类似的方法用于上传字节数组或流）。
• 将给定的字符串追加到Blob中（也有类似的方法用于追加字节数组或流）。
• 更新与blob关联的元数据
• 将blob的内容下载到string中（还有一个将内容下载到byte[]的类似方法）
• 复制一个blob
• 获取一个URI，用于在一定时间内访问blob

2) 抽象层

早期版本的Picton库包含几个接口，用于克服Azure Storage库中大多数类都已经是密封的，或者他们的方法没有被标记为虚拟的方法，因此不可“模拟”的问题。在Azure Storage库的7.0版本中，微软解开了大多数类的密封，并将大多数方法标记为虚拟，这是一个相当重大的改进，因为它允许在对这些类进行注射时对这些类进行模拟。在8.0版本中，Azure Storage库得到了进一步改进，通过将“虚拟”修饰符添加到Get*Reference方法来更新这些方法。在9.0版本中，Azure Storage库再次得到改进，解开了StorageAccount类。这是阻止在单元测试中“模拟”Azure存储库的最后一个障碍。这意味着Picton库中所有的接口和包装类都已经变得过时，并且从3.0版本中删除。

3) 管理器

Blob和Queue管理器是帮助工具，它们简化了常见的blob和queue相关任务。例如，当消息大小超过Azure队列允许的最大大小时，QueueManager会自动将消息序列化和存储到临时位置。另一个例子：Blob队列在尝试修改blob内容之前会自动请求一个锁（又称租约），并在操作完成后自动释放该锁。

4) 其他

• AzureEmulatorManager允许启动Azure存储仿真器，您可能需要在执行集成测试之前使用它。

Nuget

Picton可以作为Nuget包使用。

安装

将Picton包含到C#项目中最简单的方法是获取nuget包。

PM> Install-Package Picton

在您的项目中正确引用Picton库后，添加以下命名空间：

using Picton;            // This is always required
using Picton.Managers;   // This is only required if you want to use BlobManager or QueueManager

用法

1) Blob扩展方法

首先，以下是下面代码示例所需的某些示例代码

var cancellationToken = CancellationToken.None;
var connectionString = "UseDevelopmentStorage=true";

var container = new BlobContainerClient(connectionString, "mycontainer");
await container.CreateIfNotExistsAsync(PublicAccessType.None, cancellationToken).ConfigureAwait(false);
var blob = container.GetBlockBlobClient("MyBlob.txt");

以下是使用扩展方法的几个示例

var leaseId = await blob.TryAcquireLeaseAsync(TimeSpan.FromSeconds(15), 5, cancellationToken).ConfigureAwait(false);
await blob.UploadTextAsync("Hello World", leaseId, cancellationToken).ConfigureAwait(false);
await blob.AppendTextAsync("More content", leaseId, cancellationToken).ConfigureAwait(false);
await blob.AppendTextAsync("Even more content", leaseId, cancellationToken).ConfigureAwait(false);
await blob.TryRenewLeaseAsync(leaseId, cancellationToken).ConfigureAwait(false);
await blob.AppendTextAsync("More more more", leaseId, cancellationToken).ConfigureAwait(false);
await blob.ReleaseLeaseAsync(leaseId, cancellationToken).ConfigureAwait(false);

var content = await blob.DownloadTextAsync(cancellationToken).ConfigureAwait(false);
await blob.CopyAsync("MyCopy.txt", cancellationToken).ConfigureAwait(false);

var permission = SharedAccessBlobPermissions.Read;
var duration = TimeSpan.FromMinutes(30);
var accessUri = await blob.GetSharedAccessSignatureUri(permission, duration).ConfigureAwait(false);

2) 管理器

var connectionString = "UseDevelopmentStorage=true";
var blobManager = new BlobManager(connectionString, "mycontainer");

await blobManager.CopyBlobAsync("test.txt", "test - Copy of.txt", cancellationToken).ConfigureAwait(false);

await blobManager.UploadTextAsync("test2.txt", "Hello World", cancellationToken: cancellationToken).ConfigureAwait(false);
await blobManager.AppendTextAsync("test2.txt", "qwerty", cancellationToken: cancellationToken).ConfigureAwait(false);

foreach (var blob in blobManager.ListBlobs("test", false, false))
{
    Console.WriteLine(blob.Uri.AbsoluteUri);
}

await blobManager.DeleteBlobAsync("test - Copy of.txt", cancellationToken).ConfigureAwait(false);
await blobManager.DeleteBlobsWithPrefixAsync("test", cancellationToken).ConfigureAwait(false);

3) 其他

class Program
{
    static void Main()
    {
        AzureEmulatorManager.EnsureStorageEmulatorIsStarted();

        var cancellationToken = CancellationToken.None;
        var connectionString = "UseDevelopmentStorage=true";
        var container = new BlobContainerClient(connectionString, "mycontainer");
		await container.CreateIfNotExistsAsync(PublicAccessType.None, cancellationToken).ConfigureAwait(false);
    }
}

许可证