def lambda_handler()

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)}"