flask_twisted_stuff.py

#!/usr/bin/env python

import logging
from flask import Flask

from twisted.internet import ssl, reactor
from twisted.web.wsgi import WSGIResource
from twisted.web.server import Site
from twisted.python.threadpool import ThreadPool
from twisted.application import service
from multiprocessing import Event


app = Flask("my cool service")

@app.route('/', defaults={'path': ''})
@app.route('/<path:path>')
def catch_all(path):
    return 'You want path: %s' % path


def do_something(signal):
    logging.info("Doing something")


class ThreadPoolService(service.Service):
    def __init__(self, pool):
        self.pool = pool
        self.exit_signal = Event()

    def startService(self):
        service.Service.startService(self)
        self.pool.start()
        #use one thread to do something
        self.exit_signal.clear()
        self.pool.callInThread(do_something, self.exit_signal)

    def stopService(self):
        self.exit_signal.set()
        self.pool.stop()
        service.Service.stopService(self)

application = service.Application('my cool service')
tps = ThreadPoolService(ThreadPool())
tps.setServiceParent(application)

wsgiAppAsResource = WSGIResource(reactor, tps.pool, app)
reactor.listenSSL(
    8443,
    Site(wsgiAppAsResource),
    ssl.DefaultOpenSSLContextFactory('blah.key', 'blah.crt')
)