in lambda-sns-notify/lambda_function.py [0:0]
def lambda_handler(event, context):
topic_arn = os.getenv("TOPIC_ARN",
"arn:aws:sns:us-east-1:936068047509:satellite_notification_topic")
sqs_message = parser_sqs_message(event)
print(sqs_message)
message_subject = "Crowd Detected!"
message_body = f"Crowded detected in Bucket: {sqs_message.get('Bucket')} and Object: {sqs_message.get('Object')}"
try:
publish_to_sns(message_body, message_subject, topic_arn)
return {
'statusCode': 200,
'body': json.dumps('Hello from Lambda!')
}
except Exception as e:
return f"Error {str(e)}"