AWS | Project | Final Part | Read S3 CSV file and insert into RDS mysql using Python Lambda Function
import json
import csv
import boto3
import mysql.connector
s3client=boto3.client('s3')
def lambda_handler(event, context):
bucket = event['Records'][0]['s3']['bucket']['name']
csv_file = event['Records'][0]['s3']['object']['key']
response = s3client.get_object(Bucket=bucket, Key=csv_file)
lines = response['Body'].read().decode('utf-8').split()
results = []
for row in csv.DictReader(lines):
results.append(row.values())
print(results)
connection = mysql.connector.connect(host='mysql.c79sd2kyheg7.us-east-1.rds.amazonaws.com',
database='employeedb',
port='3306',
user='admin',
passwd='admin123')
mysql_insert = "insert into employee(empid,ename,salary) values(%s,%s,%s)"
cursor = connection.cursor()
cursor.executemany(mysql_insert, results)
connection.commit()
return {
'statusCode': 200,
'body': json.dumps('Hello from Lambda!')
}
In questa pagina del sito puoi guardare il video online AWS | Project | Final Part | Read S3 CSV file and insert into RDS mysql using Python Lambda Function della durata di ore minuti seconda in buona qualità , che l'utente ha caricato Cloud Tech Masters 20 settembre 2020, condividi il link con amici e conoscenti, su youtube questo video è già stato visto 12,919 volte e gli è piaciuto 125 spettatori. Buona visione!
