def lambda_handler()

in old_reference/hl7_retrieve_msg.py [0:0]


def lambda_handler(event, context):
  logger.info("Start")
  logger.debug(event)
  
  s3 = boto3.client('s3')
  bucket = os.environ['data_lake_bucket']
  
  logger.debug("Retrieving parameters from event")
  format = event['pathParameters']['format']
  msg_uuid = event['pathParameters']['msg_uuid']
  
  if format == "original":
    key = "raw/hl7v2/{}.txt".format(msg_uuid) 
  elif format == "er7":
    # Change this to backward conversion from the cleansed json
    key = "raw/hl7v2/{}.txt".format(msg_uuid) 
  elif format == "json":
    key = "staging/hl7v2/{}.json".format(msg_uuid)
  
  response = s3.get_object(Bucket=bucket, Key=key)
  msg_er7 = response["Body"].read().decode("utf-8")
  
  encoding = 'utf-8'
  msg_base64 = encode_to_base64(msg_er7, encoding)
  
  return {
    'statusCode': 200,
    'body': msg_base64
  }