blob: dbe50c58a4402dcccf97c87712e79186a911be73 (
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
|
from config import *
import sys
from boto.s3.connection import S3Connection
from boto.s3.key import Key
class _S3(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)
|
