您是否可以使用node.js支持的AWS Lambda函数向SNS主题发布消息?

Gar*_*rpe 59 amazon-web-services amazon-sns aws-lambda

您是否可以使用node.js支持的AWS Lambda函数向SNS主题发布消息?

Jam*_*mes 96

是的,您可以编写一个发布到SNS主题的Lambda函数.Lambda中运行的代码可以访问完整的AWS SDK for Java或Javascript,无论您的函数使用哪个.您只需确保赋予执行函数访问权限的IAM角色以发布到您的主题.在Javascript中:

console.log("Loading function");
var AWS = require("aws-sdk");

exports.handler = function(event, context) {
    var eventText = JSON.stringify(event, null, 2);
    console.log("Received event:", eventText);
    var sns = new AWS.SNS();
    var params = {
        Message: eventText, 
        Subject: "Test SNS From Lambda",
        TopicArn: "arn:aws:sns:us-west-2:123456789012:test-topic1"
    };
    sns.publish(params, context.done);
};
Run Code Online (Sandbox Code Playgroud)

也可以使用Lambda函数处理SNS消息.您可以查看sns-message通过Lambda控制台上的Create a Lambda function按钮提供的功能蓝图.


kix*_*orz 45

首先,您需要授予您的Lambda IAM role权限,以便SNS topic使用正确的发布IAM policy.

{
    "Action" : [
        "sns:Publish",
        "sns:Subscribe"
    ],
    "Effect" : "Allow",
    "Resource" : [
        { "Ref" : "<your SNS topic ARN>" }
    ]
}
Run Code Online (Sandbox Code Playgroud)

然后你可以用下面的代码SNS publish到您SNS topic从您的其他Lambda或Node.js代码.

var message = {};
var sns = new AWS.SNS();
sns.publish({
    TopicArn: "<your SNS topic ARN>",
    Message: JSON.stringify(message)
}, function(err, data) {
    if(err) {
        console.error('error publishing to SNS');
        context.fail(err);
    } else {
        console.info('message published to SNS');
        context.succeed(null, data);
    }
});
Run Code Online (Sandbox Code Playgroud)

  • 为什么你认为你的角色需要"sns:Subscribe"? (2认同)
  • 很高兴你提到需要制定政策,我想知道我做错了什么。 (2认同)