def lambda_handler()

in lambda_sns_notify/lambda_function.py [0:0]


def lambda_handler(event, context):
    topic_arn = os.getenv("TOPIC_ARN", "")

    object_name = event["Records"][0]["s3"]["object"]["key"]
    bucket_name = event["Records"][0]["s3"]["bucket"]["name"]

    message_subject = "Proximity detected!"
    message_body = f"Proximity detected in Bucket: {bucket_name} and Object: {object_name}"

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