我正在设置一个集成测试,以确定向 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 订阅者按预期接收消息属性。