Ярлыки

Показаны сообщения с ярлыком Celery. Показать все сообщения
Показаны сообщения с ярлыком Celery. Показать все сообщения

суббота, 3 ноября 2012 г.

insert new queue in CELERY


CELERY_IMPORTS = ("test1.tasks","new.tasks")
CELERY_ROUTES = \
{
        "test1":
        {
                "queue": "test1"
        },
        "NEW":
        {
                "queue": "
NEWtest"
        }

}
CELERY_QUEUES = \
{
        "default":
        {
                "exchange": "default",
                "binding_key": "default"
        },
        "test1":
        {
                "exchange": "test",
                "exchange_type": "direct",
                "binding_key": "test1"
        },
        "NEWtest":
        {
                "exchange": "test",
                "exchange_type": "direct",
                "binding_key": "test1"
        }


}
CELERY_DEFAULT_QUEUE = "default"

some CELERY parameters


# all in UTC :
CELERY_ENABLE_UTC = True
CELERY_TIMEZONE = 'Etc/UTC'

# tasks from and tasks to may be different addresses:
# tasks from
BROKER_URL = "redis://myserver.ru:6379//"

#  tasks to
CELERY_RESULT_BACKEND = "redis"
CELERY_REDIS_HOST = "myserver.ru"
CELERY_REDIS_PORT = 6379