import os
import json

class AwsException(Exception):
	pass

def aws_run(cmd,env=''):
	cmd = '%s aws %s'%(env,cmd)
	pipe = os.popen(cmd)
	output_str = pipe.read()

	if (not pipe.close()):
		output = json.loads(output_str)
		return output
	else:
		raise AwsException("Error: %s"%output_str)