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