Мне нужно настроить очередь заданий/сообщений с возможностью установить задержку для задачи, чтобы она не сразу подхватывалась бесплатным работником, а через определенное время (может варьироваться от задачи к задаче). Я просмотрел пару решений для очередей Linux (rabbitmq, gearman, memcacheq), но ни одно из них не предлагает эту функцию из коробки.
Любые идеи о том, как я мог бы достичь этого?
Спасибо!
Я использовал BeanstalkD с большим эффектом, используя опцию задержки при вставке нового задания, чтобы подождать несколько секунд, пока элемент не станет доступным для резервирования.
Если вы выполняете более длительные задержки (скажем, более 30 секунд) или задания несколько важны для выполнения (пусть и позже), то у него также есть двоичная система ведения журнала, так что любой сбой демона все еще будет иметь запись о задании. . Тем не менее, я провел сотни тысяч живых заданий через экземпляры Beanstalkd, и рабочие, которые я написал, всегда были более проблематичными, чем сервер.
Вы можете использовать брокера AMQP (например, RabbitMQ), и у меня есть «агент» (например, процесс python, созданный с использованием pyton-amqplib), который сидит на обмене и перехватывает определенные сообщения (конкретные routing_key); по истечении таймера отправьте сообщение обратно на биржу с другим routing_key.
Я понимаю, что это означает "перевод/сопоставление" routing keys, но это работает. Работать с RabbitMQ и python-amqplib очень просто.
