python code to get/process events from AWS SQS

sqs-sample-code.py

from boto import sqs
from time import sleep
import time
import logging
import logging.handlers
import string

import os
import sys


def init_sqs(log):
    '''
        Setup Simple Queuing Service (SQS) on Amazon Web Services
    '''
    log.debug('Connecting to SQS')
    conn = sqs.connect_to_region('us-east-1')
    q = conn.get_queue('garage-door')
    return q


def process_msgs(q, rs, log):
    '''
        Process all messages accumulated in SQS.
    '''
    log.debug('Process Messages')
    # only process the last (most recent) message
    numMsgs = len(rs)
    m = rs[numMsgs - 1]
    process_msg(m, log)
    delete_all_msgs(q, rs, log)


def delete_all_msgs(q, rs, log):
    '''
        Delete all messages in the result set
    '''
    log.debug('delete all messages')
    for m in rs:
        res = q.delete_message(m)
        if res:
            log.info('Message deleted')


def process_msg(m, log):
    '''
        Process an individual SQS message (simplified).
    '''
    log.debug('Process Message')
      if payload.find('some-magic-string') >= 0:
        os.system('sudo /home/pi/actuategpiopin.py')
    log.debug('end of process msg')