0
ответов

сельдерей — вызов функции при выполнении задачи

Я использую сельдерей с django и rabbitmq для создания очереди сообщений. У меня также есть рабочий, который происходит от другой машины. В представлении django я запускаю такой процесс: def ...
вопрос задан: 11 March 2012 18:01
0
ответов

celery с несколькими экземплярами django

Я использую несколько экземпляров django, каждый в виртуальном окружении, на одном сервере. Как я могу запустить сервер сельдерея и убедиться, что он всегда работает и обновляется? т.е. после перезагрузки сервера или кода...
вопрос задан: 9 March 2012 13:34
0
ответов

Сбросить обратный отсчет в задаче Celery

Мне нужно, чтобы задача celery запускалась после обратного отсчета, но иметь возможность сбросить этот обратный отсчет при определенных условиях. Например, я хочу вызвать apply_async с обратным отсчетом=15, но если произойдет определенное событие...
вопрос задан: 6 March 2012 23:52
0
ответов

Что является эквивалентом проекта Python Celery для Java?

Я пытаюсь найти эквивалент проекта Celery для среды Java, я рассмотрел Spring Batch, но есть ли лучшие альтернативы для распределенных очередей задач. Благодарю.
вопрос задан: 6 March 2012 02:12
0
ответов

Как создать службу Windows Celery?

Я пытаюсь создать службу Windows для запуска Celery. Я наткнулся на статью, в которой это делается с помощью планировщика заданий. Однако он, кажется, запускает множество экземпляров сельдерея и продолжает съедать ...
вопрос задан: 21 February 2012 14:06
0
ответов

Предложения по распространению данных / кода Python по рабочим узлам?

Я начинаю заниматься распределенным кодом, и у меня возникают проблемы с определением, какое решение соответствует моим потребностям на основе всего имеющегося там материала. В основном у меня есть список данных на языке Python, которые мне нужны ...
вопрос задан: 16 February 2012 20:54
0
ответов

Работа вокруг сельдерея, являющегося единственной точкой отказа

Я ищу рекомендуемое решение для обхода celerybeat, являющегося единственной точкой отказа для развертывания celery / rabbitmq. Пока что я не нашел ничего, что имело бы смысл, занимаясь поиском в Интернете. В ...
вопрос задан: 15 February 2012 00:18
0
ответов

Является ли python zipfile потокобезопасным?

В проекте django мне нужно сгенерировать несколько pdf файлов для объектов в базе данных. Поскольку на генерацию каждого файла уходит несколько секунд, я использую celery для асинхронного запуска задач. Проблема в том, что мне нужно добавить каждый ...
вопрос задан: 8 February 2012 14:26
0
ответов

Celery: ограничения параллелизма для каждой задачи (количество рабочих на задачу)?

Можно ли установить параллелизм ( количество одновременно работающих) на уровне задачи в Celery? Я ищу что-то более детальное, например CELERYD_CONCURRENCY (которое устанавливает ...
вопрос задан: 6 February 2012 21:41
0
ответов

Зачем использовать Celery вместо RabbitMQ?

Насколько я понимаю, Celery - это распределенная очередь задач, что означает, что единственное, что он должен делать, - это отправлять задачи / задания на другие серверы и возвращать результат. RabbitMQ - это очередь сообщений, ...
вопрос задан: 31 January 2012 10:08
0
ответов

Python SEM_OPEN Error

Я пытаюсь использовать Celery, работающий с RabbitMQ и Django. Пока что на моем сервере установлен RabbitMQ 2.7 вместе с pyt. hon 2.7, Django 1.3, celery 2.4.6 и django-celery 2.4.2 Я следил за ...
вопрос задан: 26 January 2012 19:40
0
ответов

Состояние задачи и django-celery

Я использую django-celery и имею такую ​​задачу: class TestTask (Task): name = "enabler.test_task" def run (self, ** kw): debug_log ("begin тестовая задача ") time.sleep (5) ...
вопрос задан: 16 January 2012 07:25
0
ответов

У Celery и Redis не хватает памяти

У меня есть приложение Django, развернутое на Heroku, с рабочим процессом, работающим под управлением celery (+ celerycam для мониторинга). Я использую базу данных RedisToGo Redis в качестве брокера. Я заметил, что у Redis заканчивается ...
вопрос задан: 15 January 2012 06:28
0
ответов

Shared XMPP connection between Celery workers

Моему веб-приложению нужно иметь возможность отправлять XMPP-сообщения (Facebook Chat), и я подумал, что Celery может быть хорошим решением для этого. Задача будет состоять из запроса к базе данных и отправки XMPP-сообщения на ...
вопрос задан: 5 January 2012 21:24
0
ответов

Запуск задачи Celery при невозможности импорта этой задачи

У меня два сервера: на одном запущено приложение django, а на другом - очередь rabbitmq и рабочий сельдерея. Мой файл tasks.py на сервере, на котором запущена очередь / рабочий, содержит следующую задачу: @task (queue = "...
вопрос задан: 19 December 2011 18:42
0
ответов

Восстановление Celery после сбоя базы данных

У меня есть Celeryd / RabbitMQ, работающий на Fedora, общающийся с MySQL база данных на отдельном ящике. Я заметил, что в редких случаях, если есть даже малейшая проблема с подключением к ...
вопрос задан: 16 December 2011 19:06
0
ответов

Определить, доступен ли / запущен Celery

Я использую Celery для управления асинхронными задачами. Однако иногда процесс сельдерея останавливается, что не приводит к выполнению ни одной из задач. Я хотел бы иметь возможность проверять состояние сельдерея ...
вопрос задан: 14 December 2011 19:34
0
ответов

Исключение NotRegistered при использовании django-celery с redis

Я написал приложение django с именем «задача» и добавил его в * INSTALLED_APPS *. Однако, когда я попытался вызвать его в оболочке django, он вызвал исключение NotRegistered. Подробная информация ниже: из задачи ....
вопрос задан: 12 December 2011 08:00
0
ответов

Планирование задач с использованием django-celery на основе пользовательского ввода

Я создаю портал отчетов с помощью django . На этом портале мне нужно дать пользователям возможность планировать запуск отчетов на повторяющейся основе. Я исследовал django-celery и понимаю ...
вопрос задан: 8 December 2011 21:05
0
ответов

Stopping/Purging Periodic Tasks in Django-Celery

Мне удалось заставить периодические задачи работать в django-celery путем подклассификации PeriodicTask. Я попытался создать тестовую задачу и запустить ее на выполнение чего-то бесполезного. Она работает. Теперь я не могу остановить его. I'...
вопрос задан: 22 November 2011 17:14
0
ответов

Примеры Django и Celery: Периодические задачи

Я уже некоторое время бьюсь с документацией Django/Celery и нуждаюсь в помощи. Я хотел бы иметь возможность запускать Периодические Задачи, используя django-celery. Я видел в интернете (и в ...
вопрос задан: 22 November 2011 10:40
0
ответов

Книга для Django + Celery + RabbitMQ? [закрыто]

OK, я читал о celery и rabbitmq, хотя я ценю усилия проекта и документацию, я все еще смущен многими вещами. http://www.celeryproject.org/ ...
вопрос задан: 17 November 2011 06:08
0
ответов

Уведомить задачу сельдерея о завершении работы работника

Я использую сельдерей 2.4.1 с python 2.6, backend rabbitmq и django. Я бы хотел, чтобы моя задача могла правильно очищаться, если рабочий завершает работу. Насколько мне известно, вы не можете поставить задачу ...
вопрос задан: 15 November 2011 15:20
0
ответов

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

Я пытаюсь использовать Celery в качестве канала управления для приложения Twisted. application - это уровень абстракции, который предоставляет стандартный интерфейс для различных локально запущенных процессов (через ...
вопрос задан: 15 November 2011 13:45
0
ответов

Django - Выполнение задачи через сельдерей из модели

В моем models.py: из django.db import models из основного класса задач импорта Image (models.Model): image = models.ImageField (upload_to = 'images / orig') thumbnail = models.ImageField (upload_to = ...
вопрос задан: 12 November 2011 20:57
0
ответов

Использование Celery с SQLAlchemy и Pyramid

Я создаю веб-приложение, используя Pyramid-1.2.1 с SQLAlchemy в качестве серверной части базы данных. Теперь мне нужно выполнять некоторые периодические задачи вместе с этим приложением, и я хочу использовать Celery в качестве процессора задач и SQLAlc
вопрос задан: 11 November 2011 13:38
0
ответов

CELERY_ROUTES - как маршрутизировать на основе имени задачи

Я пытаюсь заставить celery маршрутизировать задачи на основе имени задачи... в основном, у меня есть задачи с именами 'worker.some_name' и 'web.some_name', и я использую две разные очереди, называемые worker и ...
вопрос задан: 20 October 2011 18:54
0
ответов

надежный способ развертывания нового кода в производственном сельдерее кластер без приостановки службы

У меня есть несколько узлов сельдерея, работающих в производстве с rabbitmq, и я занимался развертыванием с прерыванием службы. Мне нужно удалить весь сайт, чтобы внедрить новый код в сельдерей. ...
вопрос задан: 14 October 2011 19:05
0
ответов

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

Я использую python celery + rabbitmq. Я не могу найти способ получить количество задач в какой-либо очереди. Примерно так: celery.queue ('myqueue'). Count () Возможно ли получить количество задач из определенной очереди? ...
вопрос задан: 26 September 2011 09:02
0
ответов

Как обеспечивается соблюдение rate_limit в Celery?

У меня есть сайт на Django, где я использую Celery для реализации превентивного кэширования - то есть, я вычисляю и кэширую результаты еще до того, как они будут запрошены пользователем. Однако одна из моих задач Celery ...
вопрос задан: 24 September 2011 21:06