in lambda_recognize_crowd/lambda_function.py [0:0]
def lambda_handler(event, context):
rekognition_client = aws_connection("us-east-1", "rekognition")
sqs_client = aws_connection("us-east-1", "sqs")
sqs_url = os.getenv("SQS_URL", "https://sqs.us-east-1.amazonaws.com/936068047509/rekognition_notify")
sqs_data_parsed = parser_sqs_message(event)
rekognition_json = rekognition_detect_crowd(rekognition_client, sqs_data_parsed)
is_crowded = check_if_crowded(rekognition_json)
if is_crowded:
sqs_data_parsed['Success'] = "True"
print(f"[INFO] Going to send to SQS Queue {sqs_data_parsed}")
send_message_sqs(sqs_client, sqs_data_parsed, sqs_url)
return {
'statusCode': 200,
'body': sqs_data_parsed
}
print("[INFO] Not going to send to SQS Queue")