以下是一个使用AWS Lambda和AWS SNS来触发订阅者Lambda的示例代码:
import boto3
def lambda_handler(event, context):
# 创建SNS客户端
sns = boto3.client('sns')
# 发布消息到SNS主题
response = sns.publish(
TopicArn='YOUR_SNS_TOPIC_ARN',
Message='Hello from Publisher Lambda!'
)
return {
'statusCode': 200,
'body': 'Message published to SNS topic'
}
def lambda_handler(event, context):
# 处理SNS消息
for record in event['Records']:
# 获取SNS消息内容
message = record['Sns']['Message']
print('Received message: {}'.format(message))
# 在这里添加需要执行的代码逻辑
# ...
return {
'statusCode': 200,
'body': 'Subscriber Lambda executed successfully'
}
现在,当您调用发布者Lambda函数时,它将发布一条消息到SNS主题,并触发订阅者Lambda函数执行。您可以在订阅者Lambda函数中添加适当的代码逻辑来处理接收到的消息。