def processRecords()

in backend/lambda/question-stream/lambda.py [0:0]


def processRecords(records):
    processedRecords = []
    for r in records:
        imageToDeserialize = r['dynamodb']['OldImage'] if r['eventName'] == 'REMOVE' else r['dynamodb']['NewImage']
        processedRecords.append({
            'change': r['eventName'],
            'timeStamp': r['dynamodb']['ApproximateCreationDateTime'],
            'question': {k: deserializer.deserialize(v) for k,v in imageToDeserialize.items()},
        })
        
    return processedRecords