如何将对象传递给amazon SNS

Question

我在示例中看到如何将消息字符串传递给亚马逊 sns sdk 的发布方法。但是，是否有如何将自定义对象作为消息传递的示例？我尝试将“消息结构”设置为“json”，但随后我得到无效参数：无效参数：消息结构 - JSON消息正文中没有默认条目错误。我应该将对象值传递到参数中的哪个位置？

有什么例子吗？

    var params = {
        Message: JSON.stringify(item),
        MessageStructure: 'json',
        TopicArn: topic
        //MessageAttributes: item
    };

    return sns.publishAsync(params);

Answer 1

Jackson 2非常支持将对象转换为JSON String，反之亦然。

串

Cat c = new Cat();
ObjectMapper mapper = new ObjectMapper();
String s = mapper.writeValueAsString(c);

对象

Cat obj = mapper.readValue(s,Cat.class);

Answer 2

示例如下所示：https://docs.aws.amazon.com/sns/latest/api/API_Publish.html#API_Publish_Example_2

消息的 JSON 格式如下：

{
    "default": "A message.",
    "email": "A message for email.",
    "email-json": "A message for email (JSON).",
    "http": "A message for HTTP.",
    "https": "A message for HTTPS.",
    "sqs": "A message for Amazon SQS." 
} 

所以，假设你想传递的是一个对象，对我来说是这样的:

const messageObjToSend = {
    ...
}

const params = {
    Message: JSON.stringify({
        default: JSON.stringify( messageObjToSend )
    }),
    MessageStructure: 'json',
    TopicArn: 'arn:aws:sns...'
}

Answer 3

SDK不支持将自定义对象作为消息传递——消息始终是字符串。当然，您可以将字符串设置为对象的序列化版本。

message structure:“JSON”有不同的用途——当您想要将不同的字符串传递给不同的订阅类型时。在这种情况下，您使消息成为具有AWS定义的结构的序列化json对象，其中每个元素都定义了要发送给特定订阅类型(email、sqs等)的消息。即使在这种情况下，消息本身也只是字符串。

消息属性是添加到消息中的参数，用于支持特定的订阅类型。例如，如果您使用 SNS 与 Apple 的 IOS 通知服务通信，则可能必须提供其他消息参数或身份验证密钥 - 消息属性提供了执行此操作的机制。本 AWS 文档中对此进行了介绍。