通过Amazon Lambda触发Amazon SNS消息

Question

我有一个Amazon Lambda实例和一个Amazon SNS实例。Lambda代码监视我们数据库中的变化，我希望它打电话给Amazon SNS，向我们的用户发送推送。例如：

当我们论坛上的用户收到新消息时，Lambda代码会在每次运行（每10分钟）时识别出这一变化，并应通过SNS向用户的智能手机发送推送。

说到文档，我遇到了麻烦；亚马逊的文档只讨论了如何通过SNS触发Lambda代码，而不是反过来。有没有人举个例子来说明我如何做到这一点？

Answer 1

您可以使用下面的lambda向用户推送SNS消息，但您必须知道该用户的endpointARN是什么。例如，如果在Android应用程序中，当用户登录时，您将让该应用程序向您的后端发送一个GCM（Google Cloud Messaging）令牌（例如，通过触发lambda的API调用）。然后，您连接到GCM的后端可以使用此令牌查找哪个endpointARN对应于此类用户，并将其放在下面的lambda中。或者，您可以让应用程序将endpointARN直接发送到您的后端，尽管我认为它可能不太安全。确保您授予IAM权限以通过SNS发布到您的应用程序。您可以使用下面的lambda推送消息：

var AWS = require('aws-sdk');
var sns = new AWS.SNS({apiVersion: '2010-03-31'});

exports.handler = (event, context, callback) => {

    console.log(JSON.stringify(event))

var payload = {
"default": "The message string.",
"GCM":"{"+
   "\"notification\":{"+
       "\"body\":\"PUT NOTIFICATION BODY HERE\","+
       "\"title\":\"PUT NOTIFICATION TITLE HERE\""+
   "}"+
"}"
};

  payload = JSON.stringify(payload);

    var params = {
      TargetArn: 'PUT THE ENDPOINT ARN HERE',
      Subject: 'foo2',
      MessageStructure: 'json',
      Message: payload
    }
    sns.publish(params, function(err, data) {
      if (err) console.log(err, err.stack); // an error occurred
      else     console.log(data);           // successful response
    });

};

Answer 2

是的，您可以使用AWS Lambda来实现您想要的。您还需要授予适当的IAM权限，允许您的Lambda IAM角色向您发布消息。

示例：SNS发布IAM策略：

{
    "Statement":[ {
        "Effect":"Allow",
        "Action":"sns:Publish",
        "Resource":"arn:aws:sns:*:<your account id>:<your topic id>"
    } ]
}

Answer 3

在Lambda上下文中推送SNS通知没有什么特别的。我认为它只是您与之交互的另一个外部服务。

您可以在lambda代码中引入AWS SDK，然后使用该代码进行SNS调用。您需要注入正确的凭据才能调用Amazon SNS API（但如果您正在与数据库对话，您可能会做类似的事情来获取数据库endpoint和凭据）