AWS SNS - 如何获取由发布者 lambda 输出触发的订阅者 lambda

Question

我有一个发送邮件的 lambda 函数，如果电子邮件发送成功，return 输出 MessageID，如果发送失败则输出错误消息。现在我想创建一个架构，其中 returned 电子邮件状态将保存在 SNS 主题中。将有另一个 Lambda 函数作为订阅者，它将由 SNS 主题的电子邮件状态触发。

示例：如果发布者 Lambda returns MessageID，订阅者 Lambda 将 return "yes"、"no" 用于 错误消息 。有可能实现吗？如果没有，我可以去最近的地方？

到目前为止我做了什么

创建了 SNS 主题
为主题创建了订阅者 Lambda 函数。在 Lambda 中添加了以下 SNS 主题的触发器。
在我想用作发布者的现有 Lambda 中添加了 SNS 客户端。如果邮件发送成功，此 Lambda return 是 MessageID。
我向指定的 SNS 主题发布了一条简单消息。

这里是订阅者函数的代码，跟在文档之后：

import json

def lambda_handler(event, context):
    # TODO implement
    return {
        # 'statusCode': 200,
        # 'body': json.dumps('Hello from Lambda!')
         message = json.loads(event['Records'][0]['Sns']['Message']) 
         print("JSON: " + json.dumps(message)) 
         return message
    }

我的向 SNS 主题发布消息的代码：

sns_client = boto3.client('sns', aws_access_key_id=AWS_ACCESS_KEY, aws_secret_access_key=AWS_SECRET_KEY, region_name=AWS_REGION)

sns_response = sns_client.publish(
        TopicArn='my-ARN',    
        Message='Hello World',    
    )

Answer 1

我试图重现您的问题，但未能重现。我使用了 Javascript 和 Typescript 但这不应该是你的问题。

这是用于创建您的基础架构的 CDK 代码：

import cdk = require('@aws-cdk/core');

import sns = require('@aws-cdk/aws-sns');
import subs = require('@aws-cdk/aws-sns-subscriptions');

import lambda = require('@aws-cdk/aws-lambda');

export class CdkStack extends cdk.Stack {
  constructor(scope: cdk.Construct, id: string, props?: cdk.StackProps) {
    super(scope, id, props);

    let fn = new lambda.Function(this, 'SODemoFunction', {
      runtime: lambda.Runtime.NODEJS_10_X,
      code: lambda.Code.asset('./src'),
      handler: 'index.handler'
    });

    const topic = new sns.Topic(this, 'SODemoTopic', {
      displayName: 'Whosebug Demo'
    });
    topic.addSubscription(new subs.LambdaSubscription(fn));

  }
}

这是 Lambda 函数的 JS


exports.handler =  async function(event, context) {
    console.log("EVENT: \n" + JSON.stringify(event, null, 2));
    return event['Records'][0]['Sns']['Message']; 
}

这是我发送消息的方式：

$ aws sns publish --topic-arn arn:aws:sns:eu-west-1:012345678912:CdkStack-SODemoTopicD9C6180 --message "hello world"
{
    "MessageId": "b73b0141-e7d1-50f0-93ae-54f44cf8bb78"
}

这是我在 cloudwatch 日志中看到的

2019-07-27T01:29:13.981Z cc56486b-0a8f-4e7a-a880-1e09d7631b98 INFO EVENT:
{
    "Records": [
        {
            "EventSource": "aws:sns",
            "EventVersion": "1.0",
            "EventSubscriptionArn": "arn:aws:sns:eu-west-1:012345678912:CdkStack-SODemoTopicD9C61805:22d228db-9c3c-488d-84a3-cbdbf5e9d112",
            "Sns": {
                "Type": "Notification",
                "MessageId": "b73b0141-e7d1-50f0-93ae-54f44cf8bb78",
                "TopicArn": "arn:aws:sns:eu-west-1:012345678912:CdkStack-SODemoTopicD9C61805",
                "Subject": null,
                "Message": "hello world",
                "Timestamp": "2019-07-27T01:29:13.862Z",
                "SignatureVersion": "1",
                "Signature": "Xqy8DYPWu+ZFw0hU23C78CTuFB3DblDSrY+vY44sDFMLmuZjM/kaQNvTmHGlLEFcdG3MBQQYWtMc/VQjVXONeIuJr4S336IENPTWylwSNSKHi5kAD93EmDiLl2y3jW2CdsDN9/QwQ5aJQrIkIp91VnWmCx03kUqgzhMdvQ0bsz64EUN6vMpKDZ4oJ6Ug0zTPUwyvcEneMzYkaFISakZZr1SHZYfHp7bfqZVyc2fjOIHhFIyePbMOsGYpQC8CGgD8d2Yekv0f1wYQKn5At4aHWQ29ObyjdsnbYCwlAuej47n1qVwh9li7XKFsRqyqE562Ul7OdLwA1t8tZdYbYh6zjA==",
                "SigningCertUrl": "https://sns.eu-west-1.amazonaws.com/SimpleNotificationService-6aad65c2f9911b05cd53efda11f913f9.pem",
                "UnsubscribeUrl": "https://sns.eu-west-1.amazonaws.com/?Action=Unsubscribe&SubscriptionArn=arn:aws:sns:eu-west-1:012345678912:CdkStack-SODemoTopicD9C61805:22d228db-9c3c-488d-84a3-cbdbf5e9d112",
                "MessageAttributes": {}
            }
        }
    ]
}

你可以试试你这边吗？ CDK 文档在这里 https://docs.aws.amazon.com/cdk/latest/guide/getting_started.html

AWS SNS - 如何获取由发布者 lambda 输出触发的订阅者 lambda

AWS SNS - How to get subscriber lambda triggered by publisher lambda output

amazon-web-services

amazon-sns

aws-lambda