Zetian.Storage.AzureBlob

./nugetz

# Install SMTP Server and Storage Provider
dotnet add package Zetian
dotnet add package Zetian.Storage.AzureBlob

using Zetian.Server;
using Zetian.Storage.AzureBlob.Extensions;

// Configure with connection string
var server = new SmtpServerBuilder()
    .Port(25)
    .WithAzureBlobStorage("DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=mykey;EndpointSuffix=core.windows.net")
    .Build();

await server.StartAsync();

var server = new SmtpServerBuilder()
    .Port(25)
    .WithAzureBlobStorage(
        "DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=mykey;EndpointSuffix=core.windows.net",
        config =>
        {
            config.MaxMessageSizeMB = 100;
            config.EnableSoftDelete = true;
            config.CompressMessageBody = true;
            config.SoftDeleteRetentionDays = 7;
            config.AccessTier = BlobAccessTier.Hot;
            config.ContainerName = "smtp-messages";
            config.StoreMetadataAsBlobProperties = true;
            config.NamingFormat = BlobNamingFormat.DateHierarchy;
        })
    .Build();

// Using Azure AD Authentication
var server = new SmtpServerBuilder()
    .Port(25)
    .WithAzureBlobStorageAD(
        "mystorageaccount",
        config =>
        {
            config.ContainerName = "email-archive";
            config.AccessTier = BlobAccessTier.Cool;
            config.NamingFormat = BlobNamingFormat.YearMonth;
        })
    .Build();

Option	Type	Default	Description
`ConnectionString`	string	-	Azure Storage connection string
`ContainerName`	string	"smtp-messages"	Container name for messages
`UseAzureAdAuthentication`	bool	false	Use Azure AD authentication
`StorageAccountName`	string	-	Storage account name (for AD auth)
`AutoCreateContainer`	bool	true	Auto-create container if needed
`NamingFormat`	enum	DateHierarchy	Blob naming format
`AccessTier`	enum	Hot	Default blob access tier
`StoreMetadataAsBlobProperties`	bool	true	Store metadata as blob properties
`EnableSoftDelete`	bool	false	Enable soft delete feature
`SoftDeleteRetentionDays`	int	7	Days to retain deleted blobs
`MaxMessageSizeMB`	double	100	Maximum message size in MB
`CompressMessageBody`	bool	false	Compress message bodies
`EnableRetry`	bool	true	Enable retry logic
`MaxRetryAttempts`	int	3	Maximum retry attempts
`RetryDelayMs`	int	1000	Delay between retries
`ConnectionTimeoutSeconds`	int	30	Connection timeout
`LogErrors`	bool	true	Whether to log errors

// Connection string with SAS token
.WithAzureBlobStorage(
    "BlobEndpoint=https://myaccount.blob.core.windows.net/;" +
    "SharedAccessSignature=sv=2020-08-04&ss=b&srt=sco&sp=rwdlacx&se=2024-12-31")

// Emulator for local development
.WithAzureBlobStorage("UseDevelopmentStorage=true")

// Azure Government Cloud
.WithAzureBlobStorage(
    "DefaultEndpointsProtocol=https;AccountName=myaccount;" +
    "AccountKey=mykey;EndpointSuffix=core.usgovcloudapi.net")

// Flat structure: /msg-123.eml
config.NamingFormat = BlobNamingFormat.Flat;

// Year-Month: /2024-01/msg-123.eml
config.NamingFormat = BlobNamingFormat.YearMonth;

// Domain-based naming
config.NamingFormat = BlobNamingFormat.DomainBased;

// Date hierarchy: /2024/01/15/msg-123.eml
config.NamingFormat = BlobNamingFormat.DateHierarchy;

// Azure AD authentication (uses DefaultAzureCredential)
.WithAzureBlobStorageAD("mystorageaccount", config =>
{
    config.ContainerName = "smtp-messages";
    config.NamingFormat = BlobNamingFormat.DateHierarchy;
})

// With specific configuration
.WithAzureBlobStorageAD("mystorageaccount", config =>
{
    config.ContainerName = "email-archive";
    config.AccessTier = BlobAccessTier.Cool;
    config.EnableSoftDelete = true;
})

.WithAzureBlobStorage(
    "DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=mykey",
    config =>
    {
        config.ContainerName = "custom-container";
        config.NamingFormat = BlobNamingFormat.Flat;
    })

// Enable soft delete
config.EnableSoftDelete = true;
config.SoftDeleteRetentionDays = 30;

// Recover deleted blob
foreach (var blob in containerClient.GetBlobs(states: BlobStates.Deleted))
{
    var blobClient = containerClient.GetBlobClient(blob.Name);
    await blobClient.UndeleteAsync();
}

// Read from secondary region (RA-GRS/RA-GZRS)
config.ConnectionString = 
    "DefaultEndpointsProtocol=https;AccountName=myaccount;" +
    "AccountKey=mykey;EndpointSuffix=core.windows.net;" +
    "BlobEndpoint=https://myaccount-secondary.blob.core.windows.net/";

// Enable storage analytics
var serviceProperties = new BlobServiceProperties
{
    Logging = new BlobAnalyticsLogging
    {
        Read = true,
        Write = true,
        Delete = true,
        RetentionPolicy = new BlobRetentionPolicy
        {
            Enabled = true,
            Days = 7
        }
    }
};

await blobServiceClient.SetPropertiesAsync(serviceProperties);

// Connect via private endpoint
config.ConnectionString = 
    "DefaultEndpointsProtocol=https;" +
    "AccountName=myaccount;" +
    "AccountKey=mykey;" +
    "BlobEndpoint=https://myaccount.privatelink.blob.core.windows.net/";

// Configure parallel upload
var uploadOptions = new BlobUploadOptions
{
    TransferOptions = new StorageTransferOptions
    {
        MaximumConcurrency = 8,
        InitialTransferSize = 256 * 1024,
        MaximumTransferSize = 4 * 1024 * 1024
    }
};

await blobClient.UploadAsync(stream, uploadOptions);

// Batch delete
var batchClient = blobServiceClient.GetBlobBatchClient();
var batch = batchClient.CreateBatch();

foreach (var blobName in blobsToDelete)
{
    batch.DeleteBlob(containerName, blobName);
}

await batchClient.SubmitBatchAsync(batch);

// Check Azure AD permissions
// Verify tenant ID and client credentials
// Storage Blob Data Contributor role required

// Rehydrate before access
if (blobProperties.AccessTier == AccessTier.Archive)
{
    await blobClient.SetAccessTierAsync(AccessTier.Hot);
    // Wait for rehydration (can take hours)
}

Soferity/Zetian.Storage.AzureBlobv1.0.4

Get Started

Readme

Zetian.Storage.AzureBlob - Azure Cloud Storage

⚡ Features

📦 Installation

🚀 Quick Start

Basic Configuration

Advanced Configuration

Azure AD Authentication

🛠️ Configuration Options

🎯 Usage Examples

Connection Options

Blob Naming Strategies

🔐 Authentication Methods

Azure AD with Managed Identity

Connection String with Options

🗑️ Soft Delete & Recovery

🌍 Geo-Redundancy

📈 Monitoring & Analytics

🔒 Security Features

Private Endpoints

🚀 Performance Optimization

Parallel Upload

Batch Operations

🔧 Troubleshooting

Common Issues

📋 Requirements

📚 Documentation & Support

📄 License