provides a HTTP and WSGI interface to memcached

wsgiqueue.py

#!/usr/bin/env python
import memcache

HOST = '127.0.0.1'
PORT = 11211

class QueueDoesNotExist(Exception):
    pass

def application(environ, start_response):

    path = environ['PATH_INFO']
    method = environ['REQUEST_METHOD']
    
    response_code = 200
    content_type = 'text/plain'
    
    try:
    
        key = path.strip('/').replace('/','_')
    
        if not key:
            raise QueueDoesNotExist, "no queue specified"
    
        c = memcache.Client(['%s:%d' % (HOST, PORT)])
    
        if method in ('POST','PUT'):
        
            post_data = environ['wsgi.input'].read()
            if c.set(key, post_data):
                response = ''
            else:
                response_code = 500
                response = 'unable to write to queue: %s' % key
    
        elif method in ('GET','HEAD'):
            
            val = c.get(key)
            
            if val:
                response = val
            else:
                raise QueueDoesNotExist, key
        
        else:
            
            response_code = 405
            response = "method not supported"
                    
    except QueueDoesNotExist, qdne:
        
        response_code = 404
        response = "queue does not exist: %s" % qdne.message
    
    start_response(str(response_code), [('content-type', content_type)])
    return (response,)