Чтобы запустить сервер Celery, вы можете выполнить следующие действия:
-
Убедитесь, что у вас установлен Celery. Вы можете установить его с помощью pip:
pip install celery -
Создайте файл конфигурации Celery (например,
celeryconfig.py) с необходимыми настройками. Вот простой пример:# celeryconfig.py broker_url = 'amqp://guest:guest@localhost:5672//' # RabbitMQ broker URL result_backend = 'rpc://' -
Создайте файл Python (например,
tasks.py), в котором вы определите свои задачи Celery:# tasks.py from celery import Celery app = Celery('tasks', include=['your_module_name']) app.config_from_object('celeryconfig') @app.task def your_task(): # Your task implementation goes here pass -
Запустите рабочий Celery, выполнив в терминале следующую команду:
celery -A tasks worker --loglevel=info -
Чтобы поставить задачи в очередь, вы можете импортировать экземпляр приложения Celery (
app), определенный вtasks.py, и вызвать функции задачи:# your_module_name.py from tasks import app # Enqueue a task app.send_task('tasks.your_task')
Эти шаги предполагают, что у вас есть RabbitMQ в качестве брокера сообщений, но вы также можете использовать других брокеров. Обязательно измените URL-адрес брокера в celeryconfig.pyв соответствии с вашими настройками.