0
ответов

celery memory management

I have a 3 celery nodes running between 6 and 8 workers each and my tasks tend to use a lot of memory. It seems that when the tasks finish, they aren't releasing the memory. Is there a way to either ...
вопрос задан: 8 May 2011 15:27
0
ответов

How to tell if a task has already been queued in django-celery?

Here's my setup: django 1.3 celery 2.2.6 django-celery 2.2.4 djkombu 0.9.2 В моем файле settings.py у меня есть BROKER_BACKEND = "djkombu.transport.DatabaseTransport", т.е. я просто использую базу данных для ...
вопрос задан: 4 May 2011 20:03
0
ответов

A semaphore-like mechanism for Celery

We're developing a distributed application in Python + Celery for our task queue. Our application requires us to download emails from a remote ISP via IMAP (e.g.: gmail) and we're looking to have be ...
вопрос задан: 3 May 2011 22:49
0
ответов

Какой максимальный размер значения вы можете сохранить в redis?

Кто-нибудь знает, какой максимальный размер значения вы можете сохранить в redis? Я хочу использовать redis в качестве очереди сообщений с сельдереем для хранения небольших документов, которые должны быть обработаны одним работником на другом ...
вопрос задан: 9 April 2011 16:04
0
ответов

Does the java world have a task queue similar to celery?

Seeing as java is so mature, I'm hoping someone can tell me if java has something similar to http://celeryproject.org/ It is a distributed task queue. I'm writing to rabbitmq, and want to know what ...
вопрос задан: 9 April 2011 01:18
0
ответов

Как мне запланировать задачу с Celery, которая запускается 1-го числа каждого месяца?

Как мне запланировать задачу с сельдерей, который запускается 1-го числа каждого месяца?
вопрос задан: 8 April 2011 09:54
0
ответов

Использование сельдерея в качестве отказоустойчивого планировщика

я хотел бы использовать celery w / rabbitmq как отказоустойчивый планировщик в распределенной среде. Под отказоустойчивым я подразумеваю, что если задача передана работнику, и этот работник отключается из-за чего-то ...
вопрос задан: 6 April 2011 08:58
0
ответов

Получить список задач в очереди в сельдерее

Как я могу получить список задач в очереди, которые еще предстоит обработать?
вопрос задан: 4 April 2011 21:35
0
ответов

Получить объект результата задачи, заданный `task_id` в Celery

Я сохраняю task_id из celery.result.AsyncResult в базу данных и свяжите ее с элементом, на который влияет задача. Это позволяет мне выполнить запрос, чтобы получить все task_id задач, которые связаны ...
вопрос задан: 4 April 2011 21:33
0
ответов

rabbitmq + утечка памяти сельдерея?

Я успешно использовал сельдерей + rabbitmq + django в течение месяца или около того в Вчера я решил обновить celery 2.1.4 до 2.2.4, и теперь rabbitmq выходит из-под контроля. После ...
вопрос задан: 28 March 2011 18:22
0
ответов

Celery - запускайте разных рабочих на одном сервере

У меня есть 2 вида задач: Type1 - несколько небольших задач с высоким приоритетом. Type2 - много тяжелых задач с более низким приоритетом. Изначально у меня была простая конфигурация с маршрутизацией по умолчанию, никаких ключей маршрутизации не было ...
вопрос задан: 28 March 2011 18:16
0
ответов

Django Celery: интерфейс администратора, показывающий ноль задач / рабочих

I ' Настройте Celery с Django ORM в качестве серверной части. Пытаюсь следить за происходящим за кадром. Я начал celeryd с флагом -E python manage.py celeryd -E -l INFO -v 1 -f /path/to/celeryd.log ...
вопрос задан: 27 March 2011 12:20
0
ответов

Проблемы с остановкой celeryd

Я запускаю celeryd как демон, но иногда возникают проблемы с его корректной остановкой . Когда я отправляю сигнал TERM и в очереди есть элементы (в данном случае service celeryd stop), celeryd остановится ...
вопрос задан: 23 March 2011 16:49
0
ответов

Django Celery: manage.py celeryd возвращает «Неизвестная команда»

Я пытаюсь настроить Celery с помощью Django ORM как бэкэнд. Я установил все необходимые пакеты (django-celery, djkombu), сделал все, что указано в документации, запустил syncdb для создания необходимых таблиц БД. py celeryd возвращает «Неизвестная команд
вопрос задан: 20 March 2011 11:58
0
ответов

Расписание задач Celery (Celery, Django и RabbitMQ)

Я хочу иметь задачу, которая будет выполняться каждые 5 минут, но она будет ждать завершения последнего выполнения, а затем начнет считать эти 5 минут. (Таким образом я также могу быть уверен, что есть только одна задача ...
вопрос задан: 19 March 2011 10:25
0
ответов

Предоставляет ли опция django runserver ловушку для запуска других сценариев перезапуска?

Я недавно играл с django и celery. Во время разработки раздражает то, что мне приходится перезапускать демон celery каждый раз, когда я изменяю задачу. Когда я разрабатываю, я ...
вопрос задан: 1 March 2011 17:05
0
ответов

Можно ли прервать вызов Java RMI?

Мы делаем некоторую работу по созданию прототипа, и нам интересно, можно ли прервать поток, выполняющий вызов RMI. Если мы вызовем interrupt () в этом потоке, вызовет ли это исключение InterruptedException? ...
вопрос задан: 28 February 2011 10:20
0
ответов

Почему RabbitMQ не сохраняет сообщения в постоянной очереди?

Я использую RabbitMQ с Django через Celery. Я использую самую простую настройку: # Настройки подключения RabbitMQ BROKER_HOST = 'локальный хост' BROKER_PORT = '5672' BROKER_USER = 'гость' BROKER_PASSWORD = '...
вопрос задан: 18 February 2011 21:46
0
ответов

Celery (Django) Ограничение скорости

Я использую Celery для обработки нескольких задач интеллектуального анализа данных. Одна из этих задач связана с удаленной службой, которая позволяет максимум 10 одновременных подключений для каждого пользователя (или, другими словами, может превышать ..
вопрос задан: 31 January 2011 23:48
0
ответов

Отключить отладку Django для Celery

Можно ли установить DEBUG = False только для определенного приложения в Django? При включенной отладке у Celery есть известная утечка памяти. У меня есть сервер разработки, на котором я хочу, чтобы Celery работал как служба, ...
вопрос задан: 26 January 2011 15:26
0
ответов

Celery with Django - deployment

Я рассматриваю возможность использования сельдерея в своем проекте. Я нашел много информации о том, как его использовать и т.д. Меня интересует, как развернуть / упаковать мое решение. Мне нужно запустить два компонента - django ...
вопрос задан: 26 January 2011 00:55
0
ответов

Почему Celery работает в оболочке Python, но не в моих представлениях Django? (проблема с импортом)

Я установил Celery (последняя стабильная версия). У меня есть каталог / home / myuser / fable / jobs. Внутри этого каталога у меня есть файл с именем tasks.py: from celery.decorators import task из сельдерея ....
вопрос задан: 10 January 2011 01:39
0
ответов

Есть ли способ сделать Celery / RabbitMQ постоянным?

Чтобы в случае сбоя моего сервера У меня все еще есть задачи?
вопрос задан: 28 December 2010 08:48
0
ответов

Отладка celeryd djcelery через pdb

Кто-нибудь пробовал отлаживать работника celeryd с помощью pdb? Всякий раз, когда встречается точка останова (либо при запуске celeryd через pdb, либо при помощи pdb.set_trace ()), я получаю следующую ошибку: Ошибка при обработке ...
вопрос задан: 28 December 2010 05:50
0
ответов

Проблемы с подключением - Celery / Django

долгая ночь ... не могу заставить работать мой второй запуск установки Celery / RabbitMQ. шаг 1 запускается sudo rabbitmq-server: ок! шаг 2 python manage.py celeryd -l info error: [2010-12-28 03: 38: 24,690: ERROR / ...
вопрос задан: 28 December 2010 04:11
0
ответов

Асинхронная обработка Django

У меня есть куча Django запросы, которые выполняют некоторые математические вычисления (написанные на C и выполняемые через модуль Cython), которые могут занимать неопределенное количество (порядка 1 секунды) ...
вопрос задан: 27 December 2010 04:56
0
ответов

Celery - минимизировать потребление памяти

У нас есть ~ 300 процессов celeryd, работающих под Ubuntu 10.4 64-бит, в режиме ожидания каждый процесс занимает ~ 19 МБ RES, В активном состоянии - процесс ...
вопрос задан: 3 December 2010 17:08
0
ответов

Проверить, обрабатывается ли еще задача сельдерея

Как я могу проверить, обрабатывается ли еще задача (task_id) в сельдерее? У меня следующий сценарий: Запустить задачу в представлении Django Сохраните BaseAsyncResult в сеансе Выключить демон сельдерея (жестко) ...
вопрос задан: 2 December 2010 13:36
0
ответов

django celery - как отправить request.FILES ['photo'] задаче

Я пытаюсь отправить request.FILES [' photo '], файл, загруженный с моего сайта, в tCelery через: tasks.upload_photos.delay (img = request.FILES [' photo ']). Я получаю ошибку pickle, потому что он не может сериализовать его. ...
вопрос задан: 2 December 2010 01:22
0
ответов

Django Celery beat аварийно завершает работу при запуске

Недавно я настроил новый сервер с RabbitMQ и Celery. Когда я пытаюсь запустить Celerybeat на машине, он запускается на несколько секунд и останавливается. Я дал правильные разрешения для файлов журнала ...
вопрос задан: 1 December 2010 10:22