Как выполнить асинхронную пост-обработку в CherryPy?

Question

Контекст: Представьте себе, что у вас есть стандартный CherryPy привет слово приложение:

def index(self): 
     return "Hello world!" 
    index.exposed = True 

и вы хотели бы сделать некоторые пост-обработки, т.е. обработки запроса записи или просто войти тот факт, что мы были названы из конкретный IP. Что бы вы сделали, вероятно, было бы:

def index(self): 
    self.RunMyPostProcessing() 
    return "Hello world!" 
index.exposed = True 

Однако, это добавит ваше время обработки запроса. (Кстати, и, вероятно, вы будете использовать декораторы или даже какой-нибудь более сложный метод, если вы хотите называть его для каждой функции).

Вопрос: Есть ли способ создания глобальной поточной осведомленный очереди (буфер), к которому каждый запрос может писать сообщения (события), который нуждается быть авторизованы, в то время как какая-то магия функция будет захватить его и пост-процесс? Вы знаете образец такого?

Держу пари, что CherryPy поддерживает что-то вроде этого :-)

Спасибо заранее ...

Answer 1

«Глобальная очередь с поддержкой потоков» называется Queue.Queue. Я только что добавил рецепт для этого на http://tools.cherrypy.org/wiki/BackgroundTaskQueue

Answer 2

An on_end_request custom tool может быть то, что вы хотите.

Answer 3

Поскольку я искал это, и он теперь устарел, я нашел полезным дать правильный ответ (2012). Просто добавьте это в начале функции, которая обрабатывает свой адрес:

cherrypy.request.hooks.attach('on_end_request', mycallbackfunction) 

Там в более подробная информация на крюках в документации, но это не очень понятно мне.