blob: 6620bf11f1516ad2b6a99f6fcfcb868a7f3a48ef (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
"""All s3 related methods stored here"""
from config import AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY, BUCKET_NAME
import sys
from boto.s3.connection import S3Connection
from boto.s3.key import Key
class S3Cli(object):
def __init__(self):
try:
self.conn = S3Connection(AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY, is_secure=False)
self.bucket = self.conn.get_bucket(BUCKET_NAME)
except Exception as e:
sys.stderr.write("Could not connect to s3\n")
sys.stderr.write(str(e))
sys.exit(1)
def s3move(self, filename, objectname):
try:
k = Key(self.bucket)
k.key = objectname
k.set_contents_from_filename(filename)
k.set_acl('public-read')
k.storage_class = 'REDUCED_REDUNDANCY'
except Exception as e:
sys.stderr.write(str(e))
sys.exit(1)
|
