in lambda/comprehend-active-learning-user-feedback-via-api-gw-lambda.py [0:0]
def lambda_handler(event, context):
#print(event)
body = json.loads(event['body'])
classifier = body['classifier']
sentence = body['sentence']
try:
lowconfidencepair = {}
lowconfidencepair['utterance']=sentence
lowconfidencepair['prediction']='CLASSIFY'
lowconfidencepair['confidence']='NONE'
lowconfidencepair['classifier']=classifier
lowconfidencepair = json.dumps(lowconfidencepair)+"\n"
# write the lowconfidencepair to firehose
kinesis.put_record(DeliveryStreamName=kinesis_delivery_stream,Record={"Data":bytes(lowconfidencepair, 'utf-8')})
except Exception as e:
print(e)
print('Success')
return {'statusCode': 200,'headers' : {"X-Requested-With": '*',"Access-Control-Allow-Headers": 'Content-Type,X-Amz-Date,Authorization,X-Api-Key,x-requested-with',"Access-Control-Allow-Origin": '*',"Access-Control-Allow-Methods": 'DELETE, GET, HEAD, OPTIONS, PATCH, POST, PUT'},'body': 'success'}