Как запустить сервер Celery: пошаговое руководство

Чтобы запустить сервер Celery, вы можете выполнить следующие действия:

  1. Убедитесь, что у вас установлен Celery. Вы можете установить его с помощью pip:

    pip install celery
  2. Создайте файл конфигурации Celery (например, celeryconfig.py) с необходимыми настройками. Вот простой пример:

    # celeryconfig.py
    broker_url = 'amqp://guest:guest@localhost:5672//'  # RabbitMQ broker URL
    result_backend = 'rpc://'
  3. Создайте файл 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
  4. Запустите рабочий Celery, выполнив в терминале следующую команду:

    celery -A tasks worker --loglevel=info
  5. Чтобы поставить задачи в очередь, вы можете импортировать экземпляр приложения 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в соответствии с вашими настройками.