def detect_anomalies()

in functions/DetectAnomaliesFunction/startDetectAnomalies.py [0:0]


def detect_anomalies(bucket, key):

    try:
        response = s3.get_object(Bucket=bucket, Key=key)

        project_name = LFV_PROJECT_NAME
        model_version = LFV_MODEL_VERSION
        content_type = response['ContentType']
        image = response['Body']
        image_body = image.read()

        camera_id = response['Metadata']['cameraid']
        assembly_line_id = response['Metadata']['assemblylineid']
        image_id = response['Metadata']['imageid']

        lookout_response = lookoutvision.detect_anomalies(
            ProjectName=project_name,
            ModelVersion=model_version,
            Body=image_body,
            ContentType=content_type
        )

        lookout_response['CameraId'] = camera_id
        lookout_response['AssemblyLineId'] = assembly_line_id
        lookout_response['ImageId'] = image_id
        lookout_response['ImageUrl'] = 's3://'+bucket+'/'+key

        print(json.dumps(lookout_response))

        return lookout_response

    except Exception as e:

        print(e)
        raise e