transformRecord()

in src/RecordTransformer.js [52:69]


    transformRecord(record, attributes) {
        util.assertAttributes(record, 'eventName', 'eventSourceARN', 'dynamodb');
        assert(record.eventSource === 'aws:dynamodb', `event source should be aws:dynamodb, but is ${record.eventSource}`);

        const change = record.dynamodb;
        const result = getPrimaryKeys(change, this.arnToKeyStructureMap[record.eventSourceARN]);
        result.TableName = dynamodb.getTableNameFromArn(record.eventSourceARN);
        result.EventName = record.eventName;
        result.NewImage = change.NewImage;
        result.OldImage = change.OldImage;
        result.Timestamp = change.ApproximateCreationDateTime;
        result.SequenceNumber = change.SequenceNumber;
        if (change.NewImage !== undefined) {
            extractAttributeValues(change.NewImage, attributes, result);
        }

        return result;
    };