def lambda_handler()

in code/metadata/registry.py [0:0]

• 25 lines of code
• 4 McCabe index (conditional complexity)

def lambda_handler(event, context):
    for record in event['Records']:
        print(event)
        assert record['eventSourceARN'] == SQS_QUEUE_ARN, "Unexpected Lambda event source ARN. Expected {}, got {}".format(SQS_QUEUE_ARN, record['eventSourceARN'])
        payload = json.loads(record["body"])
        message = json.loads(payload['Message'])
        print(message)
        receipt = record['receiptHandle']
        registryPayload = {}
        try:
            registryPayload = {
                "documentId":         message['documentId'],
                "bucketName":         message['bucketName'],
                "documentName":       message['documentName'],
                "documentMetadata":   message.get('documentMetadata', dict()),
                "documentLink":       message['documentLink'],
                "principalIAMWriter": message['principalIAMWriter'],
                "timestamp":          message['timestamp'],
            }
            if 'documentVersion' in message:
                registryPayload['documentVersion'] = message['documentVersion']
        except Exception as e:
            print(e)
            raise ValueError("Missing parameters in payload to document registry lambda")
            
        postRegistration(registryPayload, receipt)