2

我正在设置一个集成测试，以确定向 SNS 发布消息的程序是否正常工作。发布的消息包括一些我需要检查以确定正确性的关键消息属性。

到目前为止，我已经设置了一个充当 SNS 订阅者的简单 HTTP 服务器。服务器正确确认其订阅，甚至接收来自主题的消息，但是我不知道如何访问这些消息的属性。

应该提到的是，我正在使用 ngrok 将我的主机暴露给 SNS。为此，我使用以下命令：

ngrok http 8080

创建订阅时，我已确保启用原始消息传递：

subOut, err := snsCli.Subscribe(&sns.SubscribeInput{
    Endpoint: &ngrokURL,
    Attributes: map[string]*string{
        "RawMessageDelivery": aws.String("True"),
    },
    Protocol: aws.String("https"),
    TopicArn: aws.String(topicArn),
})

注意：我也尝试将“RawMessageDelivery”设置为“true”而不是“True”。这似乎不会引起任何变化。

我也尝试过使用该http协议而不是https但取得了相同的结果。

以下是端点收到的通知发布请求（我已将 ARN 替换为星号）：

POST / HTTP/1.1
x-amz-sns-message-type: Notification
x-amz-sns-message-id: c8bce1ed-3766-5a04-a9ad-b4afc662cc31
x-amz-sns-topic-arn: ****
x-amz-sns-subscription-arn: ****
x-amz-sns-rawdelivery: true
Content-Length: 1
Content-Type: text/plain; charset=UTF-8
Host: ****.ngrok.io
User-Agent: Amazon Simple Notification Service Agent
Accept-Encoding: gzip,deflate
X-Forwarded-Proto: https
X-Forwarded-For: 54.240.230.176

发布到 SNS 的消息在其正文中只有一个字节（单个空格字符） - 我认为这就是内容长度为 1 的原因。

消息属性之一是二进制格式，并且包含 SNS 消息正文中不允许的字符，否则我将简单地将编码属性放在消息正文中。

请求中似乎没有任何可用的属性，我完全不知道为什么。我希望它们会成为原始请求正文的一部分，但情况似乎并非如此。有任何想法吗？

编辑：我可能应该补充一点，我已将 SQS 订阅者添加到同一主题，并且 SQS 订阅者按预期接收消息属性。

4

1 回答 1

1

解决方案就像禁用一样简单RawMessageDelivery。似乎此选项对于将消息属性传递到 SQS 端点是必需的，但在传递到 HTTP/S 端点时不得使用。

于 2019-05-02T18:28:54.247 回答