Amazon S3 Object Lambda – Community Dev

import boto3
import requests
import pandas as pd
def lambda_handler(event, context):
print(event)
object_get_context = event["getObjectContext"]
request_route = object_get_context["outputRoute"]
request_token = object_get_context["outputToken"]
s3_url = object_get_context["inputS3Url"]
# Get object from S3
response = requests.get(s3_url)
original_object = response.content.decode('utf-8')
# Transform object
columns = original_object.split('\r\n')[0].replace('"','').replace('\ufeff','').split(',')
user_data = []
for data in original_object.split('\r\n')[1:-1] :
user_data.append(data.replace('"','').split(','))
user_df = pd.DataFrame(user_data,columns=columns)
user_df.drop(columns=['password'],inplace=True)
# Write object back to S3 Object Lambda
s3 = boto3.client('s3')
s3.write_get_object_response(
Body=bytes(user_df.to_csv(index=False),encoding = 'utf-8'),
RequestRoute=request_route,
RequestToken=request_token)
return {'status_code': 200}

id,email,username,password,name__firstname,name__lastname,phone,__v,address__geolocation__lat,address__geolocation__long,address__city,address__street,address__number,address__zipcode
1,sarahreyes@example.org,cameronrobert,&RnzRNczN6,Tracy,Doyle,9-087-607-2043,0,-81.123854,-158.066853,Thompsonland,166 Hammond Stravenue,8812,56265
2,amandawallace@example.net,lambertfranklin,$BQGXjt49y,Christopher,Hansen,6-507-543-5500,0,-56.4904755,-47.427614,Pageburgh,716 Leonard Haven Suite 277,8776,42149

import boto3
import pandas as pd

s3 = boto3.client('s3')

print('Original object from the S3 bucket:')
original = s3.get_object(
Bucket="your_bucket_name",
Key='user_daily_data.csv')
data_str = original['Body'].read().decode('utf-8')
print(data_str)

print('Object processed by S3 Object Lambda:')
transformed = s3.get_object(
Bucket="bucket_access_point",
Key='user_daily_data.csv')
data_str = transformed['Body'].read().decode('utf-8')
print(data_str)