Oktatóanyag: ASP.NET Core alkalmazás csatlakoztatása .NET Aspire tárolóintegrációkhoz

Ehhez a cikkhez adat-hozzáférési jogosultságra lesz szüksége egy Azure Storage-fiókhoz, amely rendelkezik blobtárolóval és tárolási üzenetsorral. Győződjön meg arról, hogy a következő erőforrások és konfigurációk érhetők el:

Ebben a cikkben egy blobtároló- és tárolósor-erőforrást kell létrehoznia a helyi fejlesztési környezetben egy emulátor használatával. Ehhez használja az Azurite-ot. Az Azurite egy ingyenes, nyílt forráskódú, platformfüggetlen Azure Storage API-kompatibilis kiszolgáló (emulátor), amely egy Docker tárolóban fut.

Az emulátor használatához telepítenie kell az Azurite.

1. Azure Tárolási fiók – Tárolófiók létrehozása.
2. A nevű Blob Storage-tároló - Hozzon létre egy blob tárolót.
3. Egy nevű tárolási üzenetsor, - . Hozzon létre egy tárolási üzenetsort.

Futtassa a következő parancsokat a Azure parancssori felületén vagy a CloudShellben a szükséges Azure Storage-erőforrások beállításához:

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

A következő szerepköröket is hozzá kell rendelnie ahhoz a felhasználói fiókhoz, amellyel bejelentkezett Visual Studio:

• Storage Blob-adatszolgáltató – Azure RBAC-szerepkör hozzárendelése
• Storage Queue Data Contributor – Azure RBAC-szerepkör hozzárendelése

A Azure Developer CLI lehetővé teszi Azure erőforrások sablonrendszerrel való kiépítését és üzembe helyezését. Ez az oktatóanyag egy teljes sablont biztosít, amely kiépíti a szükséges Azure erőforrásokat, és tartalmazza a kész mintaalkalmazás-kódot. Futtassa a következő parancsokat a sablon inicializálásához és futtatásához:

1. A azd auth login-re való bejelentkezéshez futtassa a Azure parancsot.

   azd auth login
   

2. Futtassa le a azd init-t a mintasablon klónozásához és inicializálásához.

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

3. Indítsa el a azd up a(z) Azure erőforrások kiépítéséhez:

   azd up
   

4. Amikor a rendszer kéri, válassza ki a kiépített erőforrások előfizetését és Azure régióját. A sablon a következő feladatokat futtatja és hajtja végre:

   • Azure Storage-fiók létrehozása engedélyezett blob- és üzenetsor-szolgáltatásokkal
   • Létrehoz egy fileUploads nevű blobtárolót
   • Létrehoz egy tickets nevű üzenetsort
   • A következő szerepköröket rendeli hozzá a sablont futtató felhasználói fiókhoz.
     • Tárolási blobadatok közreműködője
     • Tárolási várólista adatszolgáltatója

A művelet sikeres befejezése után két lehetőség közül választhat:

• 1. lehetőség: Futtassa a .NET mintaalkalmazást a sablon src könyvtárában a befejezett alkalmazással való kísérletezéshez.
• 2. lehetőség: A mintaalkalmazást lépésről lépésre készítheti el a következő szakaszok használatával, és csatlakoztathatja a Azureáltal kiépített azd erőforrásokhoz.

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();

Az AspireStorage.Web projekt elindulásakor létrehoz egy fileuploads tárolót az Azurite Blob Storage-ban, és egy tickets-üzenetsort az Azurite Queue Storage-ban. Ez feltételes, ha az alkalmazás fejlesztői környezetben fut. Amikor az alkalmazás éles környezetben fut, feltételezzük, hogy a tárolót és az üzenetsort már létrehozták.

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();

Az előző kód Azure tárterületet, blobokat és üzenetsorokat ad hozzá, és fejlesztési módban az emulátort használja. Minden projekt olyan hivatkozásokat határoz meg ezekhez az erőforrásokhoz, amelyektől függenek.

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();

Az előző kód Azure tárterületet, blobokat és üzenetsorokat ad hozzá, és az egyes projekteken belül definiál hivatkozásokat ezekhez az erőforrásokhoz, amelyek ezektől függenek.

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);
        }
    }
}

Ahhoz, hogy a feldolgozó szolgáltatás feldolgozhassa az üzeneteket, csatlakoznia kell a Azure Storage-üzenetsorhoz. Az Azurite használatával gondoskodnia kell arról, hogy az üzenetsor elérhető legyen, mielőtt a feldolgozó szolgáltatás elkezdené végrehajtani az üzenetsor feldolgozását.

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);
        }
    }
}

A feldolgozó szolgáltatás úgy dolgozza fel az üzeneteket, hogy csatlakozik a Azure Storage-üzenetsorhoz, és kiveszi az üzeneteket az üzenetsorról.

A kapcsolati sztringek konfigurálása

Az AspireStorage és AspireStorage.Worker projekteket úgy kell konfigurálni, hogy a korábban létrehozott megfelelő Azure tárfiókhoz csatlakozzanak. A blob- és üzenetsor-szolgáltatások végpontjait a tárfiókban az egyes projektek appsettings.json fájljának használatával adhatja meg.

1. Az AspireStorage projektben adja hozzá a következő konfigurációt a appsettings.Development.json fájlhoz:

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

2. Az AspireStorage.Worker projektben adja hozzá a következő konfigurációt a appsettings.Development.json fájlhoz:

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

Mivel az Azurite használata mellett dönt, nem kell törölnie ezeket az erőforrásokat, amikor végzett a teszteléssel, mivel helyileg hozta létre őket egy emulátor kontextusában. Az emulátor lehetővé tette az alkalmazás helyi tesztelését anélkül, hogy költségek merültek volna fel, mivel nem hoztak létre Azure erőforrásokat.

Erőforrások törlése

Futtassa a következő Azure parancssori felület parancsot az erőforráscsoport törléséhez, ha már nincs szüksége a létrehozott Azure erőforrásokra. Az erőforráscsoport törlése a benne található erőforrásokat is törli.

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

További információért lásd: Erőforrások tisztítása Azure.