AWS lambda to DynamoDB Part-2

CSV file records insert into DynamoDB through AWS Lambda using the Python

Create Table : (Python Code)
import json
import boto3

def lambda_handler(event, context):
# TODO implement
dynamodb = boto3.resource('dynamodb')
table = dynamodb.create_table(TableName = 'testing_table',
KeySchema = [
{
'AttributeName' : 'Id',
'KeyType' : 'HASH'
},
{
'AttributeName': 'First_name',
'KeyType' : 'RANGE'
}
],
AttributeDefinitions=[
{
"AttributeName" : 'Id',
"AttributeType": "N"
},
{
"AttributeName" : 'First_name',
"AttributeType": "S"
}
],
ProvisionedThroughput = {
'ReadCapacityUnits' : 1,
'WriteCapacityUnits' : 1
}
)
table.meta.client.get_waiter('table_exists').wait(TableName='testing_table')
print("table Created")




return {
'statusCode': 200,
'body': json.dumps('table created')
}

Insert records:- (Python code)

import pandas as pd
from db_module import DBOperation
from decimal import Decimal



def lambda_handler(event, context):
csv_file_path = 'utf-8 records.csv'
data_frame = pd.read_csv(csv_file_path)

# # Convert float values to Decimal
data_frame = data_frame.astype(object).where(pd.notnull(data_frame), None)
data_frame = data_frame.applymap(lambda x: Decimal(str(x)) if isinstance(x, float) else x)

# Extract the records from the DataFrame
records = data_frame.to_dict(orient='records')

# Initialize the DBOperation class with your DynamoDB table name
db_operation = DBOperation('testing_table')

# Store records in DynamoDB
for record in records:
db_operation.insert_record(record)

return {
'statusCode': 200,
'body': 'CSV file processed successfully'
}

DB_module :- (Python code)


import boto3


class DBOperation:
def __init__(self, table_name):
self.table_name = table_name
self.dynamodb = boto3.resource('dynamodb')
self.table = self.dynamodb.Table(table_name)

def insert_record(self, record):
self.table.put_item(Item=record)

CSV Records :
Id First_name last_name age markes
1 surya surya 27 87
2 anand anand 30 55
3 ramu ramu 25 45
4 shiva shiva 30 88