Задать вопрос
@insekt
python

Как организовать очередь на Python?

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

Наверняка уже есть что-то готовое. Или как минимум какие-то рекомендации как организуется очередь.
  • Вопрос задан
  • 8492 просмотра
Комментировать
Подписаться 8 Оценить Комментировать
Пригласить эксперта
Ответы на вопрос 4
IlyaEvseev
@IlyaEvseev
Opensource geek
Вряд ли здесь вообще нужна очередь, т.к. запросы к разным датчикам друг с другом не связаны, т.е. могут производиться одновременно.

У запроса должны быть атрибуты "датчик" и "подписчики".
Каждый новый запрос имеет одного подписчика - создателя.
Перед созданием нового запроса к датчику проверяется, есть ли уже запрос к нему.
Если есть - туда добавляется ещё один подписчик.
При завершении запроса результат сообщается всем подписчикам.

На Python + Twisted сходу написать такое не смогу, на Perl + AnyEvent или на shell без проблем.
Ответ написан
Комментировать
Комментировать
JRazor
@JRazor
Senior StarkOverFlow Programmer
Копайте в сторону модуля Queue. К примеру, можете почитать вот здесь: john16blog.blogspot.com/2012/05/python-queue.html
Ответ написан
Комментировать
Комментировать
Fesor
@Fesor
Full-stack developer (Symfony, Angular)
Вам нужно реализовать простой менеджер очередей. В стандартной библиотеке Python есть несколько реализаций очередей, вам нужно сделать по простой FIFO очереди на каждый датчик. Можно сделать так же объект-заявку с тремя состояниями - pending, processing, done. Соответственно все новые заявки впихиваются в pending, как только заявка ушла на обработку в датчик - ей ставится статус processing, и затем, по получению данных - done и она выкидывается из очереди.

Можно так же сделать обертку-менеджер таких очередей. Если вы хотите сделать ее еще и асинхронной... то тут надо либо вешать обработчики результатов либо добавлять результаты в свою очередь. Эдакий конвейер.
Ответ написан
Комментировать
Комментировать
xSkyFoXx
@xSkyFoXx
Если Вам всё же хочется для данной задачи применить очередь, при этом Вы хотите, чтобы она была чуть более мощной чем та, что является частью стандартной библиотеки, я советую Вам посмотреть на биндинг к питону со стороны ZMQ (pyzmq). А если суть в том, чтобы просто применить серьёзные и мощные очереди для собственно интереса, тогда можно поиграться и с RabbitMQ, который очень просто ставится имеет стандартный биндинг к python.
Ответ написан
Комментировать
Комментировать
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы
Вакансии с Хабр Карьеры
Python developer
Bell Integrator
До 350 000 ₽
Python developer
Greenway Global • Новосибирск
от 150 000 ₽
TeamLead Python
AGIMA • Москва
До 350 000 ₽
Ещё вакансии
Заказы с Хабр Фриланса
Нужны заказы на разработку, дизайн
04 мая 2024, в 13:51
10000 руб./за проект
Поддержка сайта на Opencart
04 мая 2024, в 13:23
4000 руб./в час
Оформление ВК, услуги-4 карточки, 1 обложка
04 мая 2024, в 12:21
800 руб./за проект
Ещё заказы