Die Implementierung eines Puffers artige Struktur in Python

Question

Ich versuche, eine kleine wsgi Anwendung zu schreiben, die nach jeder Anfrage einige Objekte an eine externe Warteschlange gestellt wird. Ich möchte dies in Charge machen, das heißt. macht den Webserver das Objekt mit einer pufferartigen Struktur im Speicher gesetzt und ein anderen Thread und / oder Verfahren zur Herstellung dieser Objekte in die Warteschlange in batch senden, wenn der Puffer groß genug, oder nach bestimmten Zeitüberschreitung ist, und den Puffer gelöscht wird. Ich möchte nicht in NIH-Syndrom sein und nicht mit einem Gewinde Sachen stören will, aber ich konnte nicht einen geeigneten Code für diesen Job finden. Irgendwelche Vorschläge?

Answer 1

Überprüfen Sie https://docs.python.org/library/queue.html zu sehen, ob es Ihren Bedürfnissen entspricht.

Answer 2

Da Sie schreiben "Gewinde und / oder Prozess ", siehe auch multiprocessing.Queue und multiprocessing.JoinableQueue von 2,6. Das sind die Inter Varianten Queue.

Answer 3

Stream gepuffert , wenn Sie Python verwenden 3.0.