Описание тега python-rq
RQ is a simple, lightweight, Python library for creating background jobs, and processing them.
0
ответов
ImportError на RQ Worker/Redis/Flask
У меня проблемы с этой настройкой. Таким образом, когда пользователь нажимает кнопку отправки в форме, данные передаются в RQWorker и Redis для обработки. Ошибка от rqworker является 23:56:44 RQ worker u'rq:worker:HAFun.12371' started, version 0.5.6…
26 окт '15 в 22:47
1
ответ
Есть ли функциональность Celery, аналогичная функциональности RQ?
RQ обеспечивает .work(burst=True) метод для его работников, которые хорошо подходят для интеграционных тестов, когда у вас есть код, который ставит в очередь задачу, а затем хочет, чтобы эта задача выполнялась синхронно. Я не могу найти какую-либо …
14 май '18 в 18:15
0
ответов
Обновить задачу python-rq из рабочей функции
Я запускаю задачи Python-RQ, которые могут занять от нескольких минут до нескольких часов в зависимости от входных данных. Я могу установить фиксированное время ожидания при планировании работы с помощью: low = Queue('low', default_timeout=600) # 10…
20 ноя '14 в 16:13
0
ответов
Планировщик RQ создает исключение NoRedisConnectionException
Я создаю приложение и пытаюсь настроить запланированные задачи с помощью Redis/python-rq/rq-scheduler. Я могу настроить очередь просто отлично, вот так: from redis import Redis from rq import Queue rq = Queue(connection=Redis(host=BaseConfig.REDIS_H…
28 май '18 в 16:10
0
ответов
Ошибка типа: не может сериализовать объект '_io.TextIOWrapper' - Flask
Я пишу фляжное приложение, которое просит пользователя загрузить таблицу Excel, а затем вычислить и заполнить базу данных. Я пытаюсь выполнить обработку части в фоновом режиме с помощью Redis RQ, но продолжаю получать TypeError: не могу сериализоват…
05 янв '16 в 07:33
3
ответа
Выполнение длинной задачи на удаленном сервере с помощью python-rq
Я написал код, выполнение которого занимает много времени (2-3 дня), и я хочу отправить его на сервер, который будет выполняться там. Код богат классами и функциями, взаимодействующими друг с другом, но в конце концов выполнение всего кода выполняет…
04 май '14 в 21:16
0
ответов
python-rq - как мне ждать обработки всей очереди?
Я ставлю несколько рабочих мест на rq.Queue и хотите подождать (не заняты ждать), пока очередь не опустеет и все задания не будут обработаны. Есть ли такое событие для прослушивания?
28 июл '18 в 09:59
1
ответ
Тайм-аут маршрута, так что запоминать не работает
У меня есть текущий маршрут @app.route('/as/<keyword>', methods=['GET']) @cache.memoize(timeout = 30 * 24 * 60 * 60) def auto_suggest(keyword): job = q.enqueue(find_keyword, keyword, timeout = 60 * 60) while not job.result: time.sleep(1) retur…
24 дек '15 в 18:16
1
ответ
Использование ZMQ внутри rq worker
Я пытаюсь настроить zmq гнездо внутри рабочей задачи в python-rq, Если я создам context внутри функции задачи: def push( user, task_id, data ): """Push message to `user` over websocket. """ ctx = zmq.Context() pub = ctx.socket( zmq.PUB ) pub.connect…
23 май '16 в 16:28
1
ответ
Проверьте, существует ли предыдущий результат с Python-RQ
Я использую Python-RQ для создания вакансии, когда вы создаете вакансию, вы получаете job.id: f311ae30-b623-4b38-9dcb-0edd0133a6e6 Затем я использую этот идентификатор, чтобы проверить, закончен ли результат, и это здорово. Затем этот результат кэши…
09 апр '13 в 18:29
1
ответ
Запуск rqworker одновременно
Я новичок в RQ и пытаюсь использовать его для работы, которая будет работать в фоновом режиме. Мне удалось настроить его, и я также могу запустить более одного работника. Теперь я пытаюсь запустить этих работников одновременно. Я установил супервизо…
06 мар '17 в 16:22
1
ответ
Почему RQ не вызывает исключения после logging.config.dictConfg?
Я хотел бы использовать logging.config.dictConfig в моем RQ работника. Но я обнаружил, что после запуска dictConfig()рабочий больше не будет вызывать исключения, которые не будут работать в производстве. Вот мой рабочий код: import logging import lo…
01 мар '19 в 17:32
1
ответ
Рабочий python-rq закрывается автоматически
Я реализую Python-RQ, чтобы передать домены в очередь и очистить его с помощью Beautiful Soup. Так что я работаю с несколькими рабочими, чтобы выполнить работу. На данный момент я создал 22 рабочих, и все 22 рабочих зарегистрированы на панели управл…
23 июн '16 в 05:02
0
ответов
Python-RQ не может запустить пример кода, упомянутый в примере
Я не могу запустить пример кода, упомянутого в документации по rq здесь from rq import Queue from redis import Redis from test import count_words_at_url import time # Tell RQ what Redis connection to use redis_conn = Redis() q = Queue(connection=red…
13 дек '17 в 09:59
0
ответов
Соединение с базой данных Flask-RQ
Я использую Flask-RQ2 для фоновых заданий, но я хочу получить данные из базы данных для этих фоновых заданий. Я создаю свое приложение фляги, используя фабричные образцы. Я получаю ошибку: AttributeError: 'NoneType' object has no attribute 'driverna…
31 мар '18 в 07:34
2
ответа
rq Параметр тайм-аута в вызове очереди не работает, что дает JobTimeoutException
Я пытаюсь изменить тайм-аут на работу RQ, но, похоже, ничего не работает. У меня есть кое-что с эффектом: my_queue = Queue('my_task', connection=Redis()) job_args = (1, 2, 4) my_queue.enqueue_call( my_func, args=job_args, timeout=2700 ) но я все еще…
27 апр '16 в 18:40
0
ответов
Python RQ - как запустить работу, когда несколько других работ завершены? Много работа зависимость зависимость вокруг?
У меня есть вложенная структура заданий в моей очереди на повторное редактирование Python. Сначала выполняется задание rncopy. После того, как это закончено, 3 зависимых регистрационных задания следуют. Когда вычисление всех этих трех заданий законч…
24 мар '18 в 20:24
0
ответов
Планировщик задач для заданий Python
У меня есть одна основная функция, которую я хочу выполнить с разными аргументами. Это функция, которая воспроизводит видео на Raspberry Pi с помощью omxplayer. Я хотел бы использовать планировщик, который позволяет мне планировать выполнение конкре…
04 окт '17 в 22:28
0
ответов
Тестирование сельдерея и RQ
Из-за проблем с надежностью и расписанием в сельдерее мы решили оценить альтернативы. Я изо всех сил пытался установить эталон между двумя решениями очереди сообщений в отношении базовой производительности. Мой текущий подход состоит в том, чтобы по…
29 июн '17 в 16:15
1
ответ
Python Redis Queue (rq) - как избежать предварительной загрузки модели ML для каждого задания?
Я хочу поставить в очередь свои прогнозы ml, используя rq. Пример кода (песо-иш): predict.py: import tensorflow as tf def predict_stuff(foo): model = tf.load_model() result = model.predict(foo) return result app.py: from rq import Queue from redis i…
30 авг '18 в 14:01