Реализация буферной структуры в Python
Я пытаюсь написать небольшое приложение wsgi, которое будет помещать некоторые объекты во внешнюю очередь после каждого запроса. Я хочу сделать это партиями, т.е. заставить веб-сервер поместить объект в буферную структуру в памяти и другой поток и / или процесс для отправки этих объектов в очередь в пакетном режиме, когда буфер достаточно велик или после определенного тайм-аута, и очистить буфер. Я не хочу быть в синдроме NIH и не хочу возиться с потоками, однако я не смог найти подходящий код для этой работы. Какие-либо предложения?
Ответы 3
Изучите https://docs.python.org/library/queue.html, чтобы узнать, соответствует ли он вашим потребностям.
Вот что мне больше всего нравится в Python: 80% того, что вы собираетесь реализовать, уже есть. Часто даже в стандартной библиотеке.
И этот вопрос уже задавали на SO. stackoverflow.com/questions/394500/…
Я знаю, что это поток 5-летней давности, но, по-видимому, все еще актуален (поскольку я только что нашел его в поиске структуры, подобной буферу в Python) ... Я хотел сообщить, что указанная выше ссылка на python.org больше не действительна если кто-то хочет обновить его, если возможно. Я нашел pymotw.com/2/Queue как возможную замену.
Поскольку вы пишете «поток и / или процесс», см. Также multiprocessing.Queue и multiprocessing.JoinableQueue из 2.6. Это межпроцессные варианты очереди.
Используйте буферизованный поток, если вы используете python 3.0.
Похоже, это имеется в наличии и для Python 2.
опередил меня на 16 секунд до того же ответа. Думаю, он тоже этого хочет, но не мог понять.