# Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. # SPDX-License-Identifier: MIT-0 import json import boto3 import time import datetime s3=boto3.resource('s3') def lambda_handler(event,context): # Receive message from SQS queue payload =event['Records'][0]['body'] receiptHandle=event['Records'][0]['receiptHandle'] # Extract csv content of the payload l = payload.split(',') event_timestamp = l[0] event_sensorid = l[1] event_type = l[2] event_status = l[3] event_number_failure_15m = l[4] event_failure_rate_15m = l[5] cell = l[6] event_failure_rate_60m = l[7] IEFS_ID = l[8] # Upload the file file_name=event_sensorid+'_'+event_timestamp+'.csv' s3_object_path='engagement/'+file_name timestamp = datetime.datetime.fromtimestamp(int(event_timestamp)) date_time=timestamp.strftime('%Y-%m-%d %H:%M:%S') date_time=date_time+'.123' string=date_time+','+event_sensorid+',engagement_incident_driven,ENGAGEMENT,0,0,'+cell+',0,'+IEFS_ID+'\n'+'0'+','+event_sensorid+',engagement_incident_driven,ENGAGEMENT,0,0,0,0,'+IEFS_ID+'\n' encoded_string= string.encode("utf-8") object = s3.Object(bucket_name,s3_object_path) object.put(Body=encoded_string) return date_time