Ich verarbeite mehrere Protokolldateien und habe einen Code eingefügt, wenn etwas schief geht. Gleichzeitig schicke ich eine Nachricht in AWS SQS, die Details zum Fehler enthält. Jetzt möchte ich mir eine E-Mail senden, sobald eine Nachricht in SQS gesendet wird. Früher habe ich versucht, SES zu verwenden. Ich habe den SES-E-Mail-Sendecode eingegeben, aber SQS spielte dabei keine Rolle. Was kann ich tun, um meinen Anwendungsfall zu implementieren?
except:
#this part runs for any corrupted file
sqs_msg_response = queue_client.send_message(MessageBody='Data Processing num_failed')
print('messageID',sqs_msg_response.get('MessageId'))
subject = 'Data file is not processed'
body='''the {}file is not processed at the time{}'''.format(string,current_time)
message = {"Subject":{"Data":subject},"Body":{"Html":{"Data":body}}}
email_response = email_client.send_email(
Source="[email protected]",
Destination={
"ToAddresses":[
"[email protected]",
]
},
Message=message
)
Oben bin ich implementiert, aber SQS ist unabhängig und SES ist unabhängig. Jetzt möchte ich implementieren, sobald eine Nachricht an die SQS-E-Mail gesendet und an die angegebene E-Mail-ID gesendet wird.
Ein regelmäßiges Muster zur Lösung dieser Art von Problem ist die Verwendung einer Kombination aus Amazon SQS und Amazon SNS .
Auf diese Weise stellt das Thema jede Nachricht in die Warteschlange und sendet gleichzeitig eine E-Mail.
Dieser Artikel stammt aus dem Internet. Bitte geben Sie beim Nachdruck die Quelle an.
Bei Verstößen wenden Sie sich bitte [email protected] Löschen.
Lass mich ein paar Worte sagen