in backend/shopping-cart-service/delete_from_cart.py [0:0]
def lambda_handler(event, context):
"""
Handle messages from SQS Queue containing cart items, and delete them from DynamoDB.
"""
records = event["Records"]
logger.info(f"Deleting {len(records)} records")
with table.batch_writer() as batch:
for item in records:
item_body = json.loads(item["body"])
batch.delete_item(Key={"pk": item_body["pk"], "sk": item_body["sk"]})
return {
"statusCode": 200,
}