AWS SDK for .NETのバージョン 4 (V4) がリリースされました。

SDK の新しいバージョンの使用を開始するには、「AWS SDK for .NET (V4) デベロッパーガイド」、特に「バージョン 4 への移行」に関するトピックを参照してください。

AWS Message Processing Framework for .NET で 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();