in source/core-api/lambda_functions/increment_serving_counter.py [0:0]
def lambda_handler(event, context):
"""
This function is the entry handler for Lambda.
"""
headers = {
'Content-Type': 'application/json',
'Access-Control-Allow-Origin': '*'
}
body = json.loads(event['body'])
increment_by = body['increment_by']
client_event_id = deep_clean(body['event_id'])
if client_event_id == EVENT_ID:
cur_serving = rc.incrby(SERVING_COUNTER, increment_by)
print(f"cur_serving: {cur_serving}")
response = {
"statusCode": 200,
"headers": headers,
"body": json.dumps({"serving_num": cur_serving})
}
else:
response = {
"statusCode": 400,
"headers": headers,
"body": json.dumps({"error": "Invalid event ID"})
}
return response