使用Amazon SNS和SQS:
首先,您需要创建一个SNS主题并向其订阅您感兴趣的电子邮件地址。
然后,您需要创建一个SQS队列,并将其与SNS主题进行订阅。
然后,您可以开始使用SNS发布消息,并将其发送到SNS主题。只有在发件人电子邮件地址与您在第1步中订阅的地址匹配时,SNS才会将消息转发到SQS队列。
下面是示例代码:
import boto3
#创建一个SNS主题
sns_client = boto3.client('sns')
topic_arn = sns_client.create_topic(Name='MyTopic')['TopicArn']
#订阅一个电子邮件地址
sns_client.subscribe(TopicArn=topic_arn, Protocol='email', Endpoint='youremail@example.com')
#创建一个SQS队列
sqs_client = boto3.client('sqs')
queue_url = sqs_client.create_queue(QueueName='MyQueue')['QueueUrl']
#将SQS队列与SNS主题进行订阅
sns_client.subscribe(TopicArn=topic_arn, Protocol='sqs', Endpoint=queue_url)
#发布一个消息,只有当发件人电子邮件地址与订阅的地址匹配时,SNS才会将消息发送到SQS队列
sns_client.publish(TopicArn=topic_arn, Message='Hello World!', MessageAttributes={'From': {'DataType': 'String', 'StringValue': 'youremail@example.com'}})
这将创建一个SNS主题和SQS队列,并将其订阅。然后,它将发布一条带有“From”属性的消息,该属性匹配在第1步中订阅的电子邮件地址。当SNS收到消息并发现发件人地址与订阅匹配