Skip to content

Commit 2d7d24a

Browse files
Merge pull request #7 from alexjosesilva/developer
DEV | Create routines of read file and delete file
2 parents 7485401 + c5c2c1d commit 2d7d24a

File tree

4 files changed

+39
-4
lines changed

4 files changed

+39
-4
lines changed

src/delete_file.py

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
import boto3
2+
from configure import *
3+
4+
file_name = 'input/s2.csv'
5+
bucket_name = "bucketuse2023"
6+
7+
try:
8+
s3 = boto3.resource('s3',
9+
aws_access_key_id=AWS_ACCESS_KEY_ID,
10+
aws_secret_access_key=AWS_SECRET_ACCESS_KEY
11+
)
12+
s3.Object(bucket_name, file_name).delete()
13+
14+
except Exception as err:
15+
print("An exception occurred: upload: ", err)

src/get_file.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,13 @@
11
import boto3
22
from configure import *
3-
bucket_name = "bucketuse2023"
3+
44
class GetFile(object):
55

66
def __init__(self) -> None:
77
pass
88

99
def get_file(self):
10+
bucket_name = "bucketuse2023"
1011
try:
1112
s3 = boto3.resource('s3',
1213
aws_access_key_id=AWS_ACCESS_KEY_ID,

src/main.py

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,9 +10,11 @@ def main():
1010
upload = UploadFile()
1111
upload.upload_file()
1212

13-
#Read files in bucket
14-
#delete file or files in bucket
13+
print("Read file")
14+
readfile = ""
1515

16-
16+
#delete file or files in bucket
17+
print("Delet file")
18+
deletfile = ""
1719
if __name__ == "__main__":
1820
main()

src/read_file.py

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,17 @@
1+
import boto3
2+
from configure import *
3+
4+
file_name = 'input/s2.csv'
5+
bucket_name = "bucketuse2023"
6+
7+
try:
8+
s3 = boto3.resource('s3',
9+
aws_access_key_id=AWS_ACCESS_KEY_ID,
10+
aws_secret_access_key=AWS_SECRET_ACCESS_KEY
11+
)
12+
obj = s3.Object(bucket_name,file_name).delete()
13+
data=obj.get()['Body'].read()
14+
print(data)
15+
16+
except Exception as err:
17+
print("An exception occurred: upload: ", err)

0 commit comments

Comments
 (0)