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

【问题标题】：AWS SNS - How to get subscriber lambda triggered by publisher lambda outputAWS SNS - 如何获取由发布者 lambda 输出触发的订阅者 lambda
【发布时间】：2019-12-02 16:13:51
【问题描述】：

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

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

到目前为止我做了什么

创建了一个 SNS 主题
为主题创建了订阅者 Lambda 函数。在 Lambda 中为以下 SNS 主题添加了触发器。
在我想要用作发布者的现有 Lambda 中添加了 SNS 客户端。如果邮件发送成功，此 Lambda 将返回 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',    
    )

【问题讨论】：

架构似乎是正确的。您面临的问题是什么？有什么错误信息要分享吗？
@SébastienStormacq 当我运行我的发布者代码时，它会显示 sns_response。但我在我的 sns 中没有看到任何消息，也没有在我的 cloudwatch 中看到任何日志。卡在这里
您能否用上述内容更新问题以明确您的要求？此外，您能否共享用于创建该基础设施的 cloudformation 模板或 CDK 代码。这将有助于复制

标签： amazon-web-services aws-lambda amazon-sns

【解决方案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: 'StackOverflow 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

【讨论】：