simple-webserver-with-graphdat-in-python

#! /usr/bin/env python
import time
from wsgiref.simple_server import make_server

import graphdat

def application(environ, start_response):

    # get the graphdat timer
    graphdat = environ['graphdat']

    # start a timer at the beginning of an operation
    graphdat.begin("sorting")

    # Sort and stringifying the environment vars
    response_body = ['%s: %s' % (key, value) for key,
                     value in sorted(environ.items())]
    response_body = '\n'.join(response_body)

    # end a timer when we are done the operation
    graphdat.end("sorting")

    # start a new timer for sending the response
    graphdat.begin("response")

    status = '200 OK'
    response_headers = \
        [('Content-Type', 'text/plain'),
            ('Content-Length', str(len(response_body)))]

    start_response(status, response_headers)

    BLOCKSIZE = 1000
    offset = 0

    # create a nested timer under the response timer
    graphdat.begin('offset' + str(offset))

    block = response_body[0:BLOCKSIZE]
    while block:
        time.sleep(0.5)
        yield block
        graphdat.end('offset' + str(offset))

        offset += BLOCKSIZE
        graphdat.begin('offset' + str(offset))
        block = response_body[offset:offset + BLOCKSIZE]

    # the open timers will automatically be closed
    # when the response is finished


# graphdat wraps the application
application = graphdat.WSGIWrapper(application)

if __name__ == '__main__':
    server = make_server(
        'localhost',  # The host name.
        1337,  # A port number.
        application  # Our graphdat wrapped application
    )
    print 'server starting on http://localhost:1337'
    server.serve_forever()