如何设置属性消息组 ID



我正在尝试将 SQS 消息发送到 FIFO 队列。我在使用消息组 ID 属性时遇到了问题。我认为使用 MessageAttributeValue 是设置"MessageGroupId"的正确方法,但 AWS 似乎无法识别此输入。设置 SQS SendMessageRequest.MessageAttributes 的正确方法是什么?

我创建了一个发送消息的控制台项目。我尝试了一些方法来设置消息组 ID 属性,但在发送消息时出现异常。

        SendMessageRequest sendMessageRequest = new SendMessageRequest();
        sendMessageRequest.QueueUrl = myURL;

        MessageAttributeValue mavGroupID = new MessageAttributeValue();
        mavGroupID.DataType = "MessageGroupId";
        mavGroupID.StringValue = "1";
        MessageAttributeValue mavDeDuplicateID = new    MessageAttributeValue();
        mavDeDuplicateID.DataType = "MessageDeduplicationId";
        mavDeDuplicateID.StringValue = "1";
        sendMessageRequest.MessageAttributes.Add("0", mavGroupID);
        sendMessageRequest.MessageAttributes.Add("1", mavDeDuplicateID);

        string sMyMessage = "";
        Console.WriteLine();
        Console.WriteLine("Message to send: ");
        sMyMessage = Console.ReadLine();

        sendMessageRequest.MessageBody = sMyMessage;
        SendMessageResponse sMR = amazonSQSClient.SendMessage(sendMessageRequest);

Amazon.SQS.AmazonSQSException:"请求必须包含参数 MessageGroupId。

MessageGroupIdSendMessageRequest本身上指定。这不是MessageAttribute.

SendMessageRequest.MessageGroupId = 'foo'

请参阅: 发送消息请求类 |适用于 .NET 的 AWS 开发工具包 V3

最新更新