Öğretici: ASP.NET Core uygulamasını .NET Aspire depolama tümleştirmelerine bağlama

Bu makale için blob kapsayıcısı ve depolama kuyruğu olan bir Azure Depolama hesabında veri katkıcısı erişimine ihtiyacınız olacaktır. Aşağıdaki kaynaklara ve yapılandırmalara sahip olduğunuzdan emin olun:

Bu makale için, bir öykünücü kullanarak yerel geliştirme ortamınızda blob kapsayıcısı ve depolama kuyruğu kaynakları oluşturmanız gerekir. Bunu yapmak için Azurite kullanın. Azurite, Docker kapsayıcısında çalışan, ücretsiz, açık kaynak kodlu, platformlar arası, Azure depolama API’si ile uyumlu bir sunucu (öykünücü)dur.

Öykünücüyü kullanmak için Azuriteyüklemeniz gerekir.

1. Azure Depolama hesabı - Depolama hesabı oluşturma.
2. adlı bir Blob Depolama kapsayıcısında - dosyaları yükleyin.adlı bir blob depolama kapsayıcısı oluşturun.
3. bilet adlı bir Depolama Kuyruğu oluşturma - .

Gerekli Azure Depolama kaynaklarını ayarlamak için Azure CLI veya CloudShell'de aşağıdaki komutları çalıştırın:

az group create --name aspirestorage --location eastus2
az storage account create -n aspirestorage -g aspirestorage -l eastus2
az storage container create -n fileuploads --account-name aspirestorage
az storage queue create -n tickets --account-name aspirestorage

Ayrıca, Visual Studio oturum açtığınız kullanıcı hesabına aşağıdaki rolleri atamanız gerekir:

• Depolama Bloğu Verisi Katkıda Bulunma – Bir Azure RBAC rolü atama
• Depolama Kuyruğu Veri Katkıda Bulunanı - Azure RBAC rolü atama

Azure Developer CLI, şablon sistemi kullanarak Azure kaynakları sağlamanızı ve dağıtmanızı sağlar. Bu öğretici, gerekli kaynaklarını sağlayan ve tamamlanmış örnek uygulama kodunu içeren Azure sağlar. Şablonu başlatmak ve çalıştırmak için aşağıdaki komutları çalıştırın:

1. azd auth login'e oturum açmak için Azure çalıştırın.

   azd auth login
   

2. Örnek şablonu kopyalamak ve başlatmak için azd init çalıştırın:

   azd init --template dotnet-aspire-connect-storage
   

3. azd up kaynaklarını sağlamak için Azure çalıştırın:

   azd up
   

4. İstendiğinde, sağlanan kaynaklar için aboneliği ve Azure bölgeyi seçin. Şablon sizin için aşağıdaki görevleri çalıştırır ve tamamlar:

   • Blob ve kuyruk hizmetlerinin etkinleştirildiği bir Azure Depolama Hesabı oluşturur
   • fileUploads adlı bir blob depolama kapsayıcısı oluşturur
   • tickets adlı bir kuyruk oluşturur
   • Şablonu çalıştıran kullanıcı hesabına aşağıdaki rolleri atar.
     • Depolama Blob Verileri Katkı Sağlayan
     • Depolama Kuyruğu Veri Katkı Sağlayıcısı

İşlem başarıyla tamamlandıktan sonra, ileriye doğru iki seçeneğiniz vardır:

• 1. Seçenek: Tamamlanan uygulamayla deneme yapmak için şablon .NET dizininde src örnek uygulamasını çalıştırın.
• 2. Seçenek: İlerideki bölümleri kullanarak örnek uygulamayı adım adım oluşturun ve Azuretarafından sağlanan azd kaynaklarına bağlayın.

using AspireStorage.Web;
using AspireStorage.Web.Components;

using Azure.Storage.Blobs;
using Azure.Storage.Queues;

var builder = WebApplication.CreateBuilder(args);

builder.AddAzureBlobClient("BlobConnection");
builder.AddAzureQueueClient("QueueConnection");

// Add service defaults & Aspire components.
builder.AddServiceDefaults();

// Add services to the container.
builder.Services.AddRazorComponents()
    .AddInteractiveServerComponents();

builder.Services.AddOutputCache();

builder.Services.AddHttpClient<WeatherApiClient>(client =>
    {
        // This URL uses "https+http://" to indicate HTTPS is preferred over HTTP.
        // Learn more about service discovery scheme resolution at https://aka.ms/dotnet/sdschemes.
        client.BaseAddress = new("https+http://apiservice");
    });

var app = builder.Build();

if (!app.Environment.IsDevelopment())
{
    app.UseExceptionHandler("/Error", createScopeForErrors: true);
    // The default HSTS value is 30 days. You may want to change this for production scenarios, see https://aka.ms/aspnetcore-hsts.
    app.UseHsts();
}
else
{
    // In development, create the blob container and queue if they don't exist.
    var blobService = app.Services.GetRequiredService<BlobServiceClient>();
    var docsContainer = blobService.GetBlobContainerClient("fileuploads");

    await docsContainer.CreateIfNotExistsAsync();

    var queueService = app.Services.GetRequiredService<QueueServiceClient>();
    var queueClient = queueService.GetQueueClient("tickets");

    await queueClient.CreateIfNotExistsAsync();
}

app.UseHttpsRedirection();

app.UseStaticFiles();
app.UseAntiforgery();

app.UseOutputCache();

app.MapRazorComponents<App>()
    .AddInteractiveServerRenderMode();

app.MapDefaultEndpoints();

app.Run();

using AspireStorage.Web;
using AspireStorage.Web.Components;

using Azure.Storage.Blobs;
using Azure.Storage.Queues;

var builder = WebApplication.CreateBuilder(args);

builder.AddAzureBlobClient("BlobConnection");
builder.AddAzureQueueClient("QueueConnection");

// Add service defaults & Aspire components.
builder.AddServiceDefaults();

// Add services to the container.
builder.Services.AddRazorComponents()
    .AddInteractiveServerComponents();

builder.Services.AddOutputCache();

builder.Services.AddHttpClient<WeatherApiClient>(client =>
    {
        // This URL uses "https+http://" to indicate HTTPS is preferred over HTTP.
        // Learn more about service discovery scheme resolution at https://aka.ms/dotnet/sdschemes.
        client.BaseAddress = new("https+http://apiservice");
    });

var app = builder.Build();

if (!app.Environment.IsDevelopment())
{
    app.UseExceptionHandler("/Error", createScopeForErrors: true);
    // The default HSTS value is 30 days. You may want to change this for production scenarios, see https://aka.ms/aspnetcore-hsts.
    app.UseHsts();
}

app.UseHttpsRedirection();

app.UseStaticFiles();
app.UseAntiforgery();

app.UseOutputCache();

app.MapRazorComponents<App>()
    .AddInteractiveServerRenderMode();

app.MapDefaultEndpoints();

app.Run();

AspireStorage.Web projesi başlatıldığında, Azurite Blob Depolama'da bir fileuploads kapsayıcı ve Azurite Kuyruk Depolama'da bir tickets kuyruk oluşturulacaktır. Uygulama bir geliştirme ortamında çalışırken bu koşulludur. Uygulama bir üretim ortamında çalışırken kapsayıcı ve kuyruğun önceden oluşturulmuş olduğu varsayılır.

using Microsoft.Extensions.Hosting;

var builder = DistributedApplication.CreateBuilder(args);

var storage = builder.AddAzureStorage("Storage");

if (builder.Environment.IsDevelopment())
{
    storage.RunAsEmulator();
}

var blobs = storage.AddBlobs("BlobConnection");
var queues = storage.AddQueues("QueueConnection");

var apiService = builder.AddProject<Projects.AspireStorage_ApiService>("apiservice");

builder.AddProject<Projects.AspireStorage_Web>("webfrontend")
    .WithExternalHttpEndpoints()
    .WithReference(apiService)
    .WithReference(blobs)
    .WithReference(queues); 

builder.AddProject<Projects.AspireStorage_WorkerService>("aspirestorage-workerservice")
    .WithReference(queues);

builder.Build().Run();

Önceki kod, Azure depolama, bloblar ve kuyruklar ekler ve geliştirme modundayken öykünücüyü kullanır. Her proje, bağımlı oldukları bu kaynaklar için başvurular tanımlar.

using Microsoft.Extensions.Hosting;

var builder = DistributedApplication.CreateBuilder(args);

var storage = builder.AddAzureStorage("Storage");

var blobs = storage.AddBlobs("BlobConnection");
var queues = storage.AddQueues("QueueConnection");

var apiService = builder.AddProject<Projects.AspireStorage_ApiService>("apiservice");

builder.AddProject<Projects.AspireStorage_Web>("webfrontend")
    .WithExternalHttpEndpoints()
    .WithReference(apiService)
    .WithReference(blobs)
    .WithReference(queues); 

builder.AddProject<Projects.AspireStorage_WorkerService>("aspirestorage-workerservice")
    .WithReference(queues);

builder.Build().Run();

Yukarıdaki kod Azure depolama, blob ve kuyruk ekler ve bunlara bağımlı olan her projede bu kaynaklar için başvurular tanımlar.

using Azure.Storage.Queues;
using Azure.Storage.Queues.Models;

namespace AspireStorage.WorkerService;

public sealed class WorkerService(
    QueueServiceClient client,
    ILogger<WorkerService> logger) : BackgroundService
{
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        var queueClient = client.GetQueueClient("tickets");
        await queueClient.CreateIfNotExistsAsync(cancellationToken: stoppingToken);

        while (!stoppingToken.IsCancellationRequested)
        {
            QueueMessage[] messages =
                await queueClient.ReceiveMessagesAsync(
                    maxMessages: 25, cancellationToken: stoppingToken);

            foreach (var message in messages)
            {
                logger.LogInformation(
                    "Message from queue: {Message}", message.MessageText);

                await queueClient.DeleteMessageAsync(
                    message.MessageId,
                    message.PopReceipt,
                    cancellationToken: stoppingToken);
            }

            // TODO: Determine an appropriate time to wait 
            // before checking for more messages.
            await Task.Delay(TimeSpan.FromSeconds(15), stoppingToken);
        }
    }
}

Çalışan hizmetinin iletileri işleyebilmesi için önce Azure Depolama kuyruğuna bağlanabilmesi gerekir. Azurite ile, çalışan hizmetin mesaj kuyruğu işlemeye başlamadan önce kuyruğun kullanılabilir olduğundan emin olmanız gerekir.

using Azure.Storage.Queues;
using Azure.Storage.Queues.Models;

namespace AspireStorage.WorkerService;

public sealed class WorkerService(
    QueueServiceClient client,
    ILogger<WorkerService> logger) : BackgroundService
{
    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        var queueClient = client.GetQueueClient("tickets");
        while (!stoppingToken.IsCancellationRequested)
        {
            QueueMessage[] messages =
                await queueClient.ReceiveMessagesAsync(
                    maxMessages: 25, cancellationToken: stoppingToken);

            foreach (var message in messages)
            {
                logger.LogInformation(
                    "Message from queue: {Message}", message.MessageText);

                await queueClient.DeleteMessageAsync(
                    message.MessageId,
                    message.PopReceipt,
                    cancellationToken: stoppingToken);
            }

            // TODO: Determine an appropriate time to wait 
            // before checking for more messages.
            await Task.Delay(TimeSpan.FromSeconds(15), stoppingToken);
        }
    }
}

Çalışan hizmeti, Azure Depolama kuyruğuna bağlanarak iletileri kuyruktan çekip işler.

Bağlantı dizelerini yapılandırma

AspireStorage ve AspireStorage.Worker projeleri daha önce oluşturduğunuz doğru Azure Depolama Hesabına bağlanacak şekilde yapılandırılmalıdır. Her projedeki appsettings.json dosyasını kullanarak depolama hesabındaki blob ve kuyruk hizmetlerinin uç noktalarını belirtebilirsiniz.

1. AspireStorage projesinde, appsettings.Development.json dosyasına aşağıdaki yapılandırmayı ekleyin:

     "ConnectionStrings": {
       "BlobConnection": "https://<your-storage-account-name>.blob.core.windows.net/",
       "QueueConnection": "https://<your-storage-account-name>.queue.core.windows.net/"
     }
   

2. AspireStorage.Worker projesinde, appsettings.Development.json dosyasına aşağıdaki yapılandırmayı ekleyin:

     "ConnectionStrings": {
       "QueueConnection": "https://<your-storage-account-name>.queue.core.windows.net/"
     }
   

Çünkü Azurite kullanmayı seçtiniz, öykünücü bağlamında kaynakları yerel olarak oluşturduğunuz için testleri bitirdiğinizde bu kaynakları temizlemeniz gerekmez. Öykünücü, herhangi bir Azure kaynağı sağlanmadığından veya oluşturulmadığından, herhangi bir ücret ödemeden uygulamanızı yerel olarak test etmenizi sağlamaktaydı.

Kaynakları temizleme

Oluşturduğunuz Azure kaynaklarına artık ihtiyacınız kalmadığında kaynak grubunu silmek için aşağıdaki Azure CLI komutunu çalıştırın. Kaynak grubunun silinmesi, içinde yer alan kaynakları da siler.

az group delete --name <your-resource-group-name>

Daha fazla bilgi için 'da kaynakları temizleme bölümüne bakın Azure.