如何访问 SNS HTTPS 订阅端点中的消息属性
How to access message attributes in SNS HTTPS subscription endpoint
我正在设置集成测试以确定向 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
,但取得了相同的结果。
下面是端点收到的通知 post 请求(我用星号替换了 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 的消息正文中只有一个字节(单个 space 字符)- 我认为这就是内容长度为 1 的原因。
消息属性之一是二进制格式,包含SNS消息正文中不允许的字符,否则我会简单地将编码属性放在消息正文中。
请求中似乎没有任何可用属性,我完全不明白为什么。我希望它们将成为原始请求正文的一部分,但事实并非如此。有什么想法吗?
编辑:我可能应该补充一点,我已将 SQS 订阅者添加到同一主题,并且 SQS 订阅者会按预期接收消息属性。
解决方案就像禁用 RawMessageDelivery
一样简单。似乎需要此选项才能将消息属性传递到 SQS 端点,但在传递到 HTTP/S 端点时不得 使用 。
我正在设置集成测试以确定向 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
,但取得了相同的结果。
下面是端点收到的通知 post 请求(我用星号替换了 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 的消息正文中只有一个字节(单个 space 字符)- 我认为这就是内容长度为 1 的原因。
消息属性之一是二进制格式,包含SNS消息正文中不允许的字符,否则我会简单地将编码属性放在消息正文中。
请求中似乎没有任何可用属性,我完全不明白为什么。我希望它们将成为原始请求正文的一部分,但事实并非如此。有什么想法吗?
编辑:我可能应该补充一点,我已将 SQS 订阅者添加到同一主题,并且 SQS 订阅者会按预期接收消息属性。
解决方案就像禁用 RawMessageDelivery
一样简单。似乎需要此选项才能将消息属性传递到 SQS 端点,但在传递到 HTTP/S 端点时不得 使用 。