вопрос новичка к RabbitMQ и сельдерею

Question

Я начал играть с Celery и RabbitMQ этим утром и определил несколько основных задач, чтобы посмотреть, как улучшится производительность на моем сервере.

Я добавил своего пользователя rabbitmq, vhosts и установил свои разрешения.Запустил мой сервер RabbitMQ

В очень подробном уроке я обнаружил, что эти парни используют celerybeat и celeryd, чтобы увидеть состояние некоторых задач, а также выполнить их.

подробный урок отRich Leland

Вам также как-то нужен сельдерей или достаточно шагов, которые я предпринял?

Нигде я не видел никакой информации или заметок по этому поводу ... просто спрашиваю

Answer 1

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

Если вам просто интересно посмотреть свои очереди, я бы порекомендовал установить плагин управления RabbitMQ .

Answer 2

http://ask.github.com/celery/getting-started/introduction.html

1. Запустите ваш сервер RabbitMQ
2. Определите свой celeryconfig.py
3. Запустите своего демона сельдерея: celeryd

RabbitMQ имеет гостевую учетную запись, так что это более быстрый способ начать работу. Поместите это в celeryconfig.py:

import sys
sys.path.append('.')

BROKER_HOST = "localhost"
BROKER_PORT = 5672
BROKER_USER = "guest"
BROKER_PASSWORD = "guest"
BROKER_VHOST = "/"

CELERY_RESULT_BACKEND = "amqp"

CELERY_IMPORTS = ("tasks",)

Для быстрого теста поместите это в tasks.py:

from celery.task import task

@task
def add(x, y):
    return x + y

if __name__ == "__main__":
    result = add.delay(4, 4)
    result.wait() 

Запустите celeryd в том же каталоге, где есть celeryconfig.py и tasks.py:

celeryd --loglevel=INFO

Наконец, запустите tasks.py