Logo Questions Linux Laravel Mysql Ubuntu Git Menu
 

How to execute asynchronous post-processing in CherryPy?

Context: Imagine that you have a standard CherryPy hello word app:

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

and you would like to do some post-processing, i.e. record request processing or just log the fact that we were called from specific IP. What you would do is probably:

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

However, that will add to your request processing time. (btw. And probably you will use decorators, or even some more sophisticated method if you would like to call it on every function).

Question: Is there a way of creating a global threading aware queue (buffer) to which each request can write messages (events) that needs be logged, while some magic function will grab it and post-process? Would you know a pattern for such a thing?

I bet that CherryPy supports something like that :-)

Thank you in advance...

like image 983
stic Avatar asked Aug 21 '09 09:08

stic


2 Answers

The "global threading aware queue" is called Queue.Queue.

like image 87
fumanchu Avatar answered Sep 23 '22 22:09

fumanchu


As i was looking for this and it's now outdated, i found it useful to provide the correct (2012ish) answer. Simply add this at the beginning of the function that handles your url :

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

There's more infos on hooks in the documentation but it's not very clear to me.

like image 2
y_nk Avatar answered Sep 19 '22 22:09

y_nk