Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import boto3
- 53 = boto3.client('s3')
- dynamodb boto3.resource('dynamodb')
- def csv_reader(event, context):
- bucket event['Records 1[0]['s3 J['bucket'
- key event['Records ][0]['s3' object I'k
- obj - $3.get_object(Bucket-bucket, Key-key)
- rows objl Body 1.read).split( In)
- table dynamodb.Table('batch data)
- with table.batch_writer() as, batch:
- for row in rows:
- batch.put_item(Item
- negistration id',
- name
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement