Поиск…


замечания

Сельдерей - это очередь задач, которая может запускать фоновые или запланированные задания и очень хорошо интегрируется с Django. Сельдерей требует, чтобы что-то известное как брокер сообщений передавало сообщения от призыва к работникам. Этот брокер сообщений может быть redis, rabbitmq или даже Django ORM / db, хотя это не рекомендуется.

Прежде чем начать с примера, вам нужно будет настроить сельдерей. Чтобы настроить сельдерей, создайте файл celery_config.py в главном приложении, параллельно файлу settings.py .

from __future__ import absolute_import
import os
from celery import Celery
from django.conf import settings

# broker url 
BROKER_URL = 'redis://localhost:6379/0'

# Indicate Celery to use the default Django settings module
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'config.settings')

app = Celery('config')
app.config_from_object('django.conf:settings')
# if you do not need to keep track of results, this can be turned off
app.conf.update(
    CELERY_RESULT_BACKEND=BROKER_URL,
)

# This line will tell Celery to autodiscover all your tasks.py that are in your app folders
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

И в файле __init__.py основного приложения импортируйте приложение celery. как это

# -*- coding: utf-8 -*- 
# Not required for Python 3. 
from __future__ import absolute_import

from .celery_config import app as celery_app  # noqa

Чтобы запустить работника сельдерея, используйте эту команду на уровне, где находится manage.py.

# pros is your django project, 
celery -A proj worker -l info

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

Для начала:

  1. Установить сельдерей pip install celery
  2. настроить сельдерей (перейти в раздел замечаний)
from __future__ import absolute_import, unicode_literals

from celery.decorators import task


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

Вы можете запустить это асинхронно с помощью .delay() .

add_number.delay(5, 10) , где 5 и 10 являются аргументами для функции add_number

Чтобы проверить, завершила ли функция async операцию, вы можете использовать функцию .ready() для объекта async, возвращаемого методом delay .

Чтобы получить результат вычисления, вы можете использовать атрибут .result для объекта async.

пример

async_result_object = add_number.delay(5, 10)
if async_result_object.ready():
    print(async_result_object.result)


Modified text is an extract of the original Stack Overflow Documentation
Лицензировано согласно CC BY-SA 3.0
Не связан с Stack Overflow