in codes/lambda/bucket-function/src/handler.py [0:0]
def handle(event, context):
# print('event====>', json.dumps(event))
s3 = get_client('s3')
dynamodb = get_resource('dynamodb')
table = dynamodb.Table(_table_name)
for record in event['Records']:
# print('record====>', record)
bucket_name = record['s3']['bucket']['name']
bucket_key = record['s3']['object']['key']
list = get_list(s3, bucket_name, bucket_key)
if list is not None:
for item in list:
print('put item===>', item)
put_ddb(table, item)