def processRecord()

in rekognition-pipeline/lambda/itemprocessor/lambda_function.py [0:0]

• 24 lines of code
• 13 McCabe index (conditional complexity)

def processRecord(record, syncQueueUrl, asyncQueueUrl):
    
    newImage = record["dynamodb"]["NewImage"]
    
    itemId = None
    bucketName = None
    objectName = None
    itemStatus = None
    
    if("itemId" in newImage and "S" in newImage["itemId"]):
        itemId = newImage["itemId"]["S"]
    if("bucketName" in newImage and "S" in newImage["bucketName"]):
        bucketName = newImage["bucketName"]["S"]
    if("objectName" in newImage and "S" in newImage["objectName"]):
        objectName = newImage["objectName"]["S"]
    if("itemStatus" in newImage and "S" in newImage["itemStatus"]):
        itemStatus = newImage["itemStatus"]["S"]

    print("ItemId: {}, BucketName: {}, ObjectName: {}, ItemStatus: {}".format(itemId, bucketName, objectName, itemStatus))

    if(itemId and bucketName and objectName and itemStatus):
        request = {}
        request["itemId"] = itemId
        request["bucketName"] = bucketName
        request["objectName"] = objectName
        request['syncQueueUrl'] = syncQueueUrl
        request['asyncQueueUrl'] = asyncQueueUrl

        response = processRequest(request)
        return response