以下是Lambda函数的一个示例:
import boto3
import json
def lambda_handler(event, context):
state = event.get('detail').get('state')
if state == 'FAILED':
print("Sending notification.")
sns = boto3.client('sns', region_name='us-west-2')
message = 'Step function execution failed. Details: {}'.format(json.dumps(event))
response = sns.publish(TopicArn='arn:aws:sns:us-west-2:123456789012:mytopic', Message=message)
print("Notification sent.")
要使用此Lambda函数,请将其与CloudWatch事件集成,并配置Eventbridge规则以启用消息的传递。