app/aws/s3.py

from boto3 import resource


def get_s3_job_object(bucket_name, job_id):
    s3 = resource('s3')
    return s3.Object(bucket_name, '{}.csv'.format(job_id))


def get_job_from_s3(bucket_name, job_id):
    obj = get_s3_job_object(bucket_name, job_id)
    return obj.get()['Body'].read().decode('utf-8')


def remove_job_from_s3(bucket_name, job_id):
    obj = get_s3_job_object(bucket_name, job_id)
    return obj.delete()
Move job processing into celery - brings boto S3 into new AWS folder - CSV processing utils method Rejigs the jobs rest endpoint - removes some now unused endpoints, Calls to the task with the job, job processing in task, delegating SMS calls to the sms task 2016-02-24 17:12:30 +00:00			`from boto3 import resource`


Remove csv after process job is finished. Fixed new tests. 2016-04-05 14:28:19 +01:00			`def get_s3_job_object(bucket_name, job_id):`
Move job processing into celery - brings boto S3 into new AWS folder - CSV processing utils method Rejigs the jobs rest endpoint - removes some now unused endpoints, Calls to the task with the job, job processing in task, delegating SMS calls to the sms task 2016-02-24 17:12:30 +00:00			`s3 = resource('s3')`
Remove csv after process job is finished. Fixed new tests. 2016-04-05 14:28:19 +01:00			`return s3.Object(bucket_name, '{}.csv'.format(job_id))`


			`def get_job_from_s3(bucket_name, job_id):`
			`obj = get_s3_job_object(bucket_name, job_id)`
			`return obj.get()['Body'].read().decode('utf-8')`


			`def remove_job_from_s3(bucket_name, job_id):`
			`obj = get_s3_job_object(bucket_name, job_id)`
			`return obj.delete()`