def handle()

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)