如何强制MassTransit更新已有的AWS SQS队列配置参数

问题原因 #

MassTransit SQS传输层默认仅在首次创建队列时应用配置的队列属性，对已存在的队列不会主动更新属性，这是框架内置的安全策略，避免意外修改线上已运行队列的配置。

解决方法 #

你需要额外开启队列属性更新的开关，完整配置示例如下：

services.AddMassTransit(x =>
{
    x.AddAmazonSqsMessageScheduler();
    x.AddConsumers(assembliesWithConsumers.ToArray());
    x.UsingAmazonSqs((context, cfg) =>
    {
        cfg.UseAmazonSqsMessageScheduler();

        cfg.Host("aws", h =>
        {
            // 原有Host配置保持不变
            if (!String.IsNullOrWhiteSpace(mtSettings.AccessKey))
            {
                h.AccessKey(mtSettings.AccessKey);
            }
            if (!String.IsNullOrWhiteSpace(mtSettings.SecretKey))
            {
                h.SecretKey(mtSettings.SecretKey);
            }
            h.Scope($"{mtSettings.Prefix}-{mtSettings.Environment}", true);
            var sqsConfig = !String.IsNullOrWhiteSpace(mtSettings.SqsServiceUrl)
                ? new AmazonSQSConfig() { ServiceURL = mtSettings.SqsServiceUrl }
                : new AmazonSQSConfig() { RegionEndpoint = RegionEndpoint.GetBySystemName(mtSettings.Region) };
            h.Config(sqsConfig);
            var snsConfig = !String.IsNullOrWhiteSpace(mtSettings.SnsServiceUrl)
                ? new AmazonSimpleNotificationServiceConfig() { ServiceURL = mtSettings.SnsServiceUrl }
                : new AmazonSimpleNotificationServiceConfig() { RegionEndpoint = RegionEndpoint.GetBySystemName(mtSettings.Region) };
            h.Config(snsConfig);
        });

        // 新增：开启普通队列的属性更新权限
        cfg.QueueAttributeUpdateEnabled = true;
        cfg.QueueAttributes.Add(QueueAttributeName.MessageRetentionPeriod, 1209600);
        
        cfg.SendTopology.ConfigureErrorSettings = settings => 
        {
            // 新增：开启错误队列的属性更新权限
            settings.QueueAttributeUpdateEnabled = true;
            settings.QueueAttributes.Add(QueueAttributeName.MessageRetentionPeriod, 1209600);
        };
        cfg.SendTopology.ConfigureDeadLetterSettings = settings => 
        {
            // 新增：开启死信队列的属性更新权限
            settings.QueueAttributeUpdateEnabled = true;
            settings.QueueAttributes.Add(QueueAttributeName.MessageRetentionPeriod, 1209600);
        };

        cfg.ConfigureEndpoints(context, new BusEnvironmentNameFormatter(mtSettings.Environment));
    });
});

注意事项 #

1. QueueAttributeUpdateEnabled配置仅在MassTransit v7.0及以上版本可用，如果你使用的版本更低，需要先升级MassTransit.AmazonSQS包到适配版本。
2. 请确认你的AWS访问密钥具备sqs:SetQueueAttributes权限，否则更新操作会被AWS拦截报错。
3. 所有队列TTL更新完成后，建议将三处QueueAttributeUpdateEnabled改回默认的false，避免后续迭代意外修改队列其他配置引发线上问题。
4. 如果你不想通过MassTransit修改，也可以直接通过AWS控制台、AWS CLI批量更新现有队列的MessageRetentionPeriod属性为1209600，效果完全一致。

内容的提问来源于stack exchange，提问作者Tanuki