root/aws/test_sqs.py

from twisted.internet import reactor

from aws import sqs

class Options(sqs.Options):
    optParameters = [
            ["method", "a", "postQueue"],
            ["queue", "q", ""],
            ["message", "m", ""],
            ["file", "f", ""],
        ]

config = Options()
config.parseOptions()

s = sqs.SQS(config)
if config['method'] == "postQueue":
    d = s.postQueue(config['queue'])
elif config['method'] == "listQueues":
    d = s.listQueues(config['queue'])
elif config['method'] == "putMessage":
    if config['file']:
        d = s.putMessageFromFile(config['queue'], open(config['file']))
    elif config['message']:
        d = s.putMessage(config['queue'], config['message'])
elif config['method'] == "getQueue":
    d = s.getQueue(config['queue'])
elif config['method'] == "getMessage":
    d = s.getMessage(config['queue'], config['message'])
elif config['method'] == "deleteMessage":
    d = s.deleteMessage(config['queue'], config['message'])


if d:
    def _print(s):
        print s
        return s
    d.addBoth(_print)
    d.addBoth(lambda x: reactor.stop())
    reactor.run()