DEV Community

Cover image for Integrando o Brighter V10 com AWS SDK v4
Rafael Andrade
Rafael Andrade

Posted on

Integrando o Brighter V10 com AWS SDK v4

#csharp #dotnet #brighter #aws

Em artigos anteriores, abordei Migrando para o Brighter V10 com AWS SNS/SQS. Este guia se concentra na integração do Brighter V10 com o AWS SDK v4.

AWS SDK v4

O AWS SDK v4 representa uma evolução significativa em relação às versões anteriores com várias mudanças importantes:

  • Suporte Assíncrono Aprimorado: O SDK agora adota totalmente os padrões async/await em toda a sua estrutura, eliminando chamadas bloqueantes e melhorando a utilização de recursos

  • Injeção de Dependência Modernizada: Integração aprimorada com o Microsoft.Extensions.DependencyInjection, tornando o registro e a configuração mais simples

  • Otimizações de Desempenho: Redução de alocação de memória e aumento do throughput para cenários de mensagens de alto volume

  • Tratamento de Erros Aprimorado: Tipos de exceção mais granulares e mecanismos de retry melhorados

Essas mudanças exigiram que o Brighter criasse pacotes de integração dedicados para manter a compatibilidade enquanto aproveita as novas capacidades do SDK.

Por que o Brighter tem 2 pacotes para AWS SNS/SQS

O Brighter fornece dois pacotes de integração distintos com a AWS para atender a diferentes necessidades de desenvolvimento:

  • Paramore.Brighter.MessagingGateway.AWSSQS - Para integração com AWS SDK v3
  • Paramore.Brighter.MessagingGateway.AWS.V4 - Para integração com AWS SDK v4

Não há diferença funcional significativa entre os dois pacotes em termos das capacidades principais de mensagens do Brighter. A separação existe apenas para suportar diferentes versões do AWS SDK, permitindo que as equipes:

  • Miguem para o Brighter V10 sem serem forçadas a atualizar o AWS SDK simultaneamente
  • Mantenham a compatibilidade com dependências existentes do AWS SDK v3
  • Adotem gradualmente o AWS SDK v4 no seu próprio ritmo

Escolha o pacote que corresponde à sua versão atual do AWS SDK - a interface da API do Brighter permanece consistente independentemente de qual pacote da AWS você selecionar.

Requisitos

Revisão do Brighter

Antes de continuar com a configuração do AWS SNS/SQS, vamos revisar o que já sabemos sobre o Brighter.

Request (Command/Event)

Defina mensagens usando IRequest:

public class Greeting() : Event(Id.Random()) { public string Name { get; set; } = string.Empty; }
Enter fullscreen mode Exit fullscreen mode
  • Commands: Operações para um único destinatário (ex: SendEmail).
  • Events: Notificações de broadcast (ex: OrderShipped).

Message Mapper (Opcional)

Traduz entre as mensagens do Brighter e os objetos do seu aplicativo:

public class SqsFifoMapper : IAmAMessageMapperAsync<SqsFifoEvent> { public Task<Message> MapToMessageAsync(SqsFifoEvent request, Publication publication, CancellationToken cancellationToken = new CancellationToken()) { return Task.FromResult(new Message(new MessageHeader { MessageId = request.Id, Topic = publication.Topic!, PartitionKey = request.PartitionValue, // Requisito para FIFO MessageType = MessageType.MT_EVENT, TimeStamp = DateTimeOffset.UtcNow }, new MessageBody(JsonSerializer.SerializeToUtf8Bytes(request, JsonSerialisationOptions.Options)))); } public Task<SqsFifoEvent> MapToRequestAsync(Message message, CancellationToken cancellationToken = new CancellationToken()) { return Task.FromResult(JsonSerializer.Deserialize<SqsFifoEvent>(message.Body.Bytes, JsonSerialisationOptions.Options)!); } public IRequestContext? Context { get; set; } }
Enter fullscreen mode Exit fullscreen mode

Request Handler

Processa as mensagens recebidas:

public class GreetingHandler(ILogger<GreetingHandler> logger) : RequestHandler<Greeting> { public override Greeting Handle(Greeting command) { logger.LogInformation("Hello {Name}", command.Name); await processor.PostAsync(new Farewell { Name = command.Name }, cancellationToken: cancellationToken); return base.Handle(command); } }
Enter fullscreen mode Exit fullscreen mode

Configurando o Brighter com AWS SNS/SQS

1. Configuração da Conexão

Defina os detalhes da conexão com o AWS SNS:

 var connection = new AWSMessagingGatewayConnection(new BasicAWSCredentials("test", "test"), RegionEndpoint.USEast1, cfg => cfg.ServiceURL = "http://localhost:4566" // LocalStack );
Enter fullscreen mode Exit fullscreen mode

2. Inscrição no SQS

Inscreva-se em um SQS, neste exemplo mostrarei como conectar SNS para SQS, SQS para SQS e SNS para SQS FIFO:

.AddConsumers(opt => { opt.Subscriptions = [ // SNS → SQS new SqsSubscription<Greeting>( "greeting-subscription", // Opcional "greeting-queue", // Nome da fila SQS ChannelType.PubSub, // Necessário para SNS "greeting.topic".ToValidSNSTopicName(), // Nome do Tópico SNS bufferSize: 2, messagePumpType: MessagePumpType.Proactor), // SQS → SQS (Point-to-Point) new SqsSubscription<Farewell>( new SubscriptionName("farawell-subscription"), // Opcional new ChannelName("farewell.queue"), // Nome da fila SQS ChannelType.PointToPoint, // SQS Direto new RoutingKey("farewell.queue".ToValidSQSQueueName()), // Nome do Tópico SNS bufferSize: 2, messagePumpType: MessagePumpType.Proactor), // FIFO SNS → SQS new SqsSubscription<SnsFifoEvent>( new SubscriptionName("sns-sample-fifo-subscription"), // Opcional new ChannelName("sns-sample-fifo".ToValidSQSQueueName(true)), // Nome da fila SQS ChannelType.PubSub, new RoutingKey("sns-sample-fifo".ToValidSNSTopicName(true)), // Nome do Tópico SNS bufferSize: 2, messagePumpType: MessagePumpType.Proactor, topicAttributes: new SnsAttributes { Type = SqsType.Fifo }, // FIFO queueAttributes: new SqsAttributes(type: SqsType.Fifo)), // FIFO ]; opt.DefaultChannelFactory = new ChannelFactory(connection); })
Enter fullscreen mode Exit fullscreen mode

3. Configuração do Produtor SNS/SQS

Publique eventos em um tópico, como queremos produzir para múltiplos tipos de publicação (SNS e SQS), precisaremos usar o CombinedProducerRegistryFactory:

.AddProduces(opt => { opt.ProducerRegistry = new CombinedProducerRegistryFactory( // Produtores SNS new SnsMessageProducerFactory(connection, [ new SnsPublication<Greeting> { Topic = "greeting.topic".ToValidSNSTopicName(), MakeChannels = OnMissingChannel.Create }, new SnsPublication<SnsFifoEvent> { Topic = "sns-sample-fifo".ToValidSNSTopicName(true), MakeChannels = OnMissingChannel.Create, TopicAttributes = new SnsAttributes { Type = SqsType.Fifo } } ]), // Produtores SQS new SqsMessageProducerFactory(connection, [ new SqsPublication<Farewell> { ChannelName = "farewell.queue".ToValidSQSQueueName(), Topic = "farewell.queue".ToValidSQSQueueName(), MakeChannels = OnMissingChannel.Create } ]) ).Create(); });
Enter fullscreen mode Exit fullscreen mode

Conclusão

Integrar o Brighter V10 com o AWS SDK v4 fornece uma infraestrutura de mensagens moderna e eficiente que aproveita os últimos aprimoramentos do AWS SDK, mantendo os padrões familiares de command e event do Brighter. Compreendendo as sutis diferenças entre as versões do AWS SDK e seguindo os padrões de configuração descritos aqui, você pode construir soluções de mensagens robustas e escaláveis com separação adequada de responsabilidades.

A abordagem de dois pacotes garante caminhos de migração suaves, quer você esteja começando do zero com o SDK v4 ou planejando uma transição gradual do SDK v3. Com a configuração adequada de inscrições e produtores, o Brighter lida com os detalhes complexos da infraestrutura de mensagens, permitindo que você se concentre na sua lógica de negócios.

Top comments (0)