AWSSNSSDK创建订阅时无法附加Lambda触发器。
使用AWS SDK创建SNS主题时，无法直接设置Lambda触发器。需要以下步骤：
- 创建SNS主题：
import boto3
topic_arn = 'arn:aws:sns:us-east-1:123456789012:my-sns-topic'
sns = boto3.client('sns') response = sns.create_topic(Name='my-sns-topic') topic_arn = response['TopicArn']
- 将Lambda函数作为SNS主题的订阅者（这段代码可以作为Lambda函数）：
import boto3 import os
lambda_client = boto3.client('lambda') sns_client = boto3.client('sns')
def lambda_handler(event, context): # 获取Lambda函数所在的AWS区域 aws_region = os.environ['AWS_REGION'] # 创建Lambda函数与SNS主题之间的订阅关系 sns_subscription = sns_client.subscribe( TopicArn=topic_arn, Protocol='lambda', Endpoint='arn:aws:lambda:{}:{}:function:{}' .format(aws_region, os.environ['AWS_ACCOUNT_ID'], os.environ['AWS_LAMBDA_FUNCTION_NAME']) ) # 将Lambda函数作为SNS主题的订阅者 lambda_permission = lambda_client.add_permission( FunctionName=os.environ['AWS_LAMBDA_FUNCTION_NAME'], StatementId='sns-{}'.format(sns_subscription['SubscriptionArn']), Action='lambda:InvokeFunction', Principal='sns.amazonaws.com', SourceArn=sns_subscription['SubscriptionArn'] ) return { 'statusCode': 200, 'body': 'Lambda subscription for SNS topic created' }
- 在Lambda函数的执行角色中添加SNS权限。
在以上步骤完成后，每当SNS主题发布新消息时，Lambda函数都会自动接收到通知并执行相关操作。