| import os | |
| import json | |
| class AwsException(Exception): | |
| pass | |
| def aws_run(cmd): | |
| cmd = 'aws %s'%cmd | |
| pipe = os.popen(cmd) | |
| output_str = pipe.read() | |
| if (not pipe.close()): | |
| output = json.loads(output_str) | |
| return output | |
| else: | |
| raise AwsException("Error running command: %s"%cmd) | |