翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
.NET 用の AWS Message Processing Framework での FIFO の使用
これはプレビューリリースの機能に関するプレリリースドキュメントです。このドキュメントは変更される可能性があります。 |
メッセージの順序付けとメッセージの重複排除が重要なユースケースでは、 AWS Message Processing Framework for .NET は first-in-first-out (FIFO) Amazon SQS キューと Amazon SNS トピックをサポートしています。
公開
FIFO キューまたはトピックにメッセージを発行するときは、メッセージが属するグループを指定するメッセージグループ ID を設定する必要があります。グループ内のメッセージは順番に処理されます。これは、SQS 固有および SNS 固有のメッセージ発行者に設定できます。
await _sqsPublisher.PublishAsync(message, new SQSOptions { MessageDeduplicationId = <message-deduplication-id>, MessageGroupId = <message-group-id> });
登録中
FIFO キューからのメッセージを処理する場合、フレームワークは特定のメッセージグループ内のメッセージをReceiveMessages
、呼び出しごとに受信した順序で処理します。フレームワークは、 で終わるキューで設定すると、このオペレーションモードに自動的に入ります.fifo
。
await Host.CreateDefaultBuilder(args) .ConfigureServices(services => { // Register the AWS Message Processing Framework for .NET. services.AddAWSMessageBus(builder => { // Because this is a FIFO queue, the framework automatically handles these messages in order. builder.AddSQSPoller("https://sqs.us-west-2.amazonaws.com/012345678910/MPF.fifo"); builder.AddMessageHandler<OrderMessageHandler, OrderMessage>(); }); }) .Build() .RunAsync();