x2tpXsbP

1# -*- coding: utf-8 -*-
2import boto3
3
4ACCESS_KEY = ''
5SECRET_KEY = ''
6BUCKET_NAME = ''
7
8
9client = boto3.client(
10    's3',
11    aws_access_key_id=ACCESS_KEY,
12    aws_secret_access_key=SECRET_KEY,
13)
14
15
16resource = boto3.resource('s3',
17                    aws_access_key_id=ACCESS_KEY,
18                    aws_secret_access_key=SECRET_KEY,
19                    )
20
21
22def upload_to_s3(local_file, remote_file):
23    client.upload_file(local_file, BUCKET_NAME, remote_file)
24
25
26def receive_file_names(dir_name='parent_dir/'):
27    bucket = resource.Bucket(BUCKET_NAME)
28    return_list = []
29    for my_bucket_object in bucket.objects.filter(Prefix=dir_name):
30        return_list.append(str(my_bucket_object.key))
31    return_list = list(filter(lambda x: x.count('.txt'), return_list))
32    return return_list
33
34
35def delete_file(file_name):
36    client.delete_object(Bucket=BUCKET_NAME, Key=file_name)