자습서: ASP.NET Core 앱을 .NET Aspire 스토리지 통합에 연결

이 문서에서는 Blob 컨테이너와 스토리지 큐가 포함된 Azure Storage 계정의 데이터 기여자 접근 권한이 필요합니다. 다음 리소스 및 구성을 사용할 수 있는지 확인합니다.

이 문서에서는 에뮬레이터를 사용하여 로컬 개발 환경에서 Blob 컨테이너 및 스토리지 큐 리소스를 만들어야 합니다. 이렇게 하려면 Azurite를 사용합니다. Azurite는 무료 오픈 소스 플랫폼 간 Azure Storage API 호환 server 에뮬레이터로, Docker 컨테이너에서 실행됩니다.

에뮬레이터를 사용하려면 Azurite를 설치해야 합니다.

1. Azure Storage 계정 - 스토리지 계정만듭니다.
2. Blob Storage 컨테이너 fileuploads - 가 있습니다. Blob Storage 컨테이너를 만드십시오.
3. 티켓이라는 스토리지 큐 - 를 포함하여 스토리지 큐만들기.

Azure CLI 또는 CloudShell에서 다음 명령을 실행하여 필요한 Azure Storage 리소스를 설정합니다.

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

또한 당신이 Visual Studio으로 로그인한 사용자 계정으로 다음 역할을 할당해야 합니다.

• Storage Blob 데이터 기여자 - RBAC 역할 할당
• 스토리지 큐 데이터 기여자 - Azure RBAC 역할 할당

Azure Developer CLI 템플릿 시스템을 사용하여 Azure 리소스를 프로비전하고 배포할 수 있습니다. 이 자습서에서는 필요한 리소스를 프로비전하고 완성된 샘플 애플리케이션 코드를 포함하는 Azure 제공합니다. 다음 명령을 실행하여 템플릿을 초기화하고 실행합니다.

1. azd auth login을 실행하여 Azure에 로그인합니다.

   azd auth login
   

2. azd init 실행하여 샘플 템플릿을 복제하고 초기화합니다.

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

3. azd up 실행하여 Azure 리소스를 프로비전합니다.

   azd up
   

4. 메시지가 표시되면 프로비전된 리소스에 대한 구독 및 Azure 지역을 선택합니다. 템플릿이 실행되고 다음 작업을 완료합니다.

   • Blob 및 큐 서비스를 사용하도록 설정된 Azure Storage 계정을 만듭니다.
   • fileUploads이라는 Blob Storage 컨테이너를 만듭니다.
   • tickets이라는 이름의 큐를 만듭니다.
   • 템플릿을 실행한 사용자 계정에 다음 역할을 할당합니다.
     • Storage Blob 데이터 기여자
     • 스토리지 큐 데이터 기여자

작업이 성공적으로 완료되면, 앞으로 진행할 두 가지 옵션이 있습니다.

• 옵션 1: 템플릿 .NET 디렉터리에서 src 샘플 앱을 실행하여 완료된 앱을 실험합니다.
• 옵션 2: 앞의 섹션을 사용하여 샘플 앱을 단계별로 빌드하고 Azure프로비전된 azd 리소스에 연결합니다.

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 프로젝트가 시작되면 Azurite Blob Storage에 fileuploads 컨테이너를 만들고, Azurite Queue Storage에 tickets 큐를 생성합니다. 앱이 개발 환경에서 실행되는 경우 조건부입니다. 앱이 프로덕션 환경에서 실행 중인 경우 컨테이너 및 큐는 이미 만들어진 것으로 간주됩니다.

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

앞의 코드는 Azure 스토리지, Blob 및 큐를 추가하고 개발 모드에서는 에뮬레이터를 사용합니다. 각 프로젝트는 이러한 리소스에 대한 참조를 정의합니다.

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

앞의 코드는 Azure 스토리지, Blob 및 큐를 추가하고 해당 리소스에 종속된 각 프로젝트 내에서 이러한 리소스에 대한 참조를 정의합니다.

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

작업자 서비스가 메시지를 처리하려면 Azure Storage 큐에 연결할 수 있어야 합니다. Azurite를 사용할 때, 작업자 서비스가 메시지 큐 처리를 시작하기 전에 큐가 사용 가능한지 확인해야 합니다.

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

작업자 서비스는 Azure Storage 큐에 연결하여 큐에서 메시지를 끌어와 처리합니다.

연결 문자열 구성

AspireStorage 및 AspireStorage.Worker 프로젝트는 이전에 만든 올바른 Azure Storage 계정에 연결하도록 구성해야 합니다. 각 프로젝트의 appsettings.json 파일을 사용하여 스토리지 계정의 Blob 및 큐 서비스에 대한 엔드포인트를 지정할 수 있습니다.

1. AspireStorage 프로젝트에서 appsettings.Development.json 파일에 다음 구성을 추가합니다.

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

2. AspireStorage.Worker 프로젝트에서 appsettings.Development.json 파일에 다음 구성을 추가합니다.

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

Azurite를 사용하도록 선택했으므로 에뮬레이터의 컨텍스트에서 로컬로 만들었으므로 테스트를 완료하면 이러한 리소스를 정리할 필요가 없습니다. 에뮬레이터를 사용하면 Azure 리소스가 프로비전되거나 생성되지 않으므로 비용이 발생하지 않고 로컬에서 앱을 테스트할 수 있었습니다.

리소스 정리

만든 Azure 리소스가 더 이상 필요하지 않은 경우 다음 Azure CLI 명령을 실행하여 리소스 그룹을 삭제합니다. 리소스 그룹을 삭제하면 리소스 그룹에 포함된 리소스도 삭제됩니다.

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

자세한 내용은 리소스 정리 참조하세요.