Question

I'm trying to write a small wsgi application which will put some objects to an external queue after each request. I want to make this in batch, ie. make the webserver put the object to a buffer-like structure in memory, and another thread and/or process for sending these objects to the queue in batch, when buffer is big enough or after certain timeout, and clearing the buffer. I don't want to be in NIH syndrome and not want to bother with threading stuff, however I could not find a suitable code for this job. Any suggestions?

Was it helpful?

Solution

Examine https://docs.python.org/library/queue.html to see if it meets your needs.

OTHER TIPS

Since you write "thread and/or process", see also multiprocessing.Queue and multiprocessing.JoinableQueue from 2.6. Those are interprocess variants of Queue.

Use a buffered stream if you are using python 3.0.

Licensed under: CC-BY-SA with attribution
Not affiliated with StackOverflow
scroll top