К чему снится сельдерей: К чему снится сельдерей — значение сна сельдерей по соннику

1. Товары
2. Клиенты
3. Случаи использования

1. Переполнение стека Публичные вопросы и ответы
2. Команды Частные вопросы и ответы для вашей команды
3. предприятие Частные вопросы и ответы для вашего предприятия
4. работы Программирование и связанные с ним технические возможности карьерного роста
5. Талант Нанимать технический талант
6. реклама Связаться с разработчиками по всему миру

Как использовать сельдерей и RabbitMQ с Django

Celery — это асинхронная очередь задач, основанная на распределенной передаче сообщений. Очереди задач используются в качестве стратегии для распределить рабочую нагрузку между потоками / машинами. В этом уроке я объясню, как установить и настроить Celery + RabbitMQ для выполнения асинхронного в приложении Django.

Для работы с Celery нам также необходимо установить RabbitMQ, поскольку для Celery требуется внешнее решение для отправки и получения. Сообщения.Эти решения называются брокерами сообщений . В настоящее время Celery поддерживает RabbitMQ, Redis и Amazon SQS. в качестве решения для брокера сообщений.

Содержание

Почему я должен использовать сельдерей?

работают с циклами запросов и ответов. Когда пользователь получает доступ к определенному URL вашего приложения, Веб-браузер отправляет запрос на ваш сервер. Джанго получает этот запрос и что-то делает с ним. Обычно это предполагает выполнение запросов в базе данных, обработку данных.Пока Джанго делает свое дело и обрабатывает запрос, Пользователь должен ждать. Когда Django завершает свою работу по обработке запроса, он отправляет ответ пользователю, который наконец-то увидим.

В идеале этот цикл запроса и ответа должен быть быстрым, иначе мы бы оставили пользователя в ожидании слишком долго. И что еще хуже, наш веб-сервер может обслуживать только определенное количество пользователей одновременно. Итак, если этот процесс медленный, он может ограничить количество страниц, которые ваше приложение может обслуживать одновременно.

По большей части мы можем обойти эту проблему, используя кеш, оптимизируя запросы к базе данных и так далее. Но есть некоторые В случаях, когда нет другого выхода: тяжелая работа должна быть сделана. Страница отчета, экспорт большого количества данных, обработка видео / изображений — несколько примеров случаев, когда вы можете использовать Celery.

Мы не используем Celery в течение всего проекта, но только для конкретных задач, которые занимают много времени. Идея здесь заключается в отвечать пользователю как можно быстрее и передавать трудоемкие задачи в очередь для выполнения в фон, и всегда держите сервер готовым отвечать на новые запросы.

Установка

Самый простой способ установить Celery — использовать pip:

  пункт установки сельдерея  

Теперь нам нужно установить RabbitMQ.

Установка RabbitMQ в Ubuntu 16.04

Установить его на более новую версию Ubuntu очень просто:

  apt-get install -y erlang
apt-get установить rabbitmq-сервер  

Затем включите и запустите службу RabbitMQ:

  systemctl включить rabbitmq-сервер
systemctl start rabbitmq-сервер  

Проверьте статус, чтобы убедиться, что все работает гладко:

  systemctl status rabbitmq-server  

Установка RabbitMQ на Mac

Homebrew — самый простой вариант:

  заваривать установить rabbitmq  

Сценарии RabbitMQ устанавливаются в / usr / local / sbin .Вы можете добавить его к своему .bash_profile или .profile .

  vim ~ / .bash_profile  

Затем добавьте его в конец файла:

  экспорт PATH = $ PATH: / usr / local / sbin  

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

Теперь вы можете запустить сервер RabbitMQ, используя следующую команду:

  rabbitmq-сервер  

Установка RabbitMQ в Windows и других ОС

К сожалению, у меня нет доступа к компьютеру Windows, чтобы попробовать что-то, но вы можете найти руководство по установке Windows на веб-сайте RabbitMQ.

Для других операционных систем, проверьте Загрузка и установка RabbitMQ на их веб-сайте.

Основные настройки сельдерея

Сначала рассмотрим следующий проект Django с именем mysite с приложением с именем core :

  mysite /
 | - mysite /
 | | - ядро ​​/
 | | | - миграции /
 | | | - шаблоны /
 | | | - apps.py
 | | | - models.py
 | | + - views.py
 | | - шаблоны /
 | | - __init__.ру
 | | - settings.py
 | | - urls.py
 | + - wsgi.py
 | - manage.py
 + - needs.txt  

Добавьте конфигурацию CELERY_BROKER_URL в файл settings.py :

settings.py

  CELERY_BROKER_URL = 'amqp: // localhost'  

Наряду с файлами settings.py и urls.py , давайте создадим новый файл с именем celery.py .

celery.py

  импорт ос
из сельдерея импорт сельдерея

Операционные системы.environment.setdefault ('DJANGO_SETTINGS_MODULE', 'mysite.settings')

app = сельдерей ('mysite')
app.config_from_object ('django.conf: settings', namespace = 'CELERY')
app.autodiscover_tasks ()  

Теперь отредактируйте файл __init__.py в корне проекта:

__init__.py

  из .celery import app как celery_app

__all__ = ['celery_app']  

Это сделает наше приложение Celery важным при каждом запуске Django.

Создание нашего первого задания из сельдерея

Мы можем создать файл с именем задач.py внутри приложения Django и поместите все наши задачи Celery в этот файл. Приложение Сельдерей мы создали в корне проекта, соберу все задачи, определенные для всех приложений Django, перечисленных в INSTALLED_APPS конфигурации.

Только для целей тестирования, давайте создадим задачу Celery, которая генерирует несколько случайных учетных записей пользователей.

core / tasks.py

  строка импорта

из django.contrib.auth.models import User
из django.utils.crypto импортировать get_random_string

из импорта сельдерея shared_task

@shared_task
def create_random_user_accounts (total):
    для я в диапазоне (всего):
        username = 'user_ {}'.формат (get_random_string (10, string.ascii_letters))
        email = '{} @ example.com'.format (имя пользователя)
        пароль = get_random_string (50)
        User.objects.create_user (имя пользователя = имя пользователя, электронная почта = электронная почта, пароль = пароль)
    return '{} случайные пользователи созданы с успехом!'. формат (всего)  

Важные биты здесь:

  из импорта сельдерея shared_task

@shared_task
def name_of_your_function (необязательный_парам):
    пройти # сделать что-нибудь тяжелое  

Затем я определил форму и представление для обработки моей задачи Celery:

форм.пи

  из форм импорта Django
из django.core.validators import MinValueValidator, MaxValueValidator

Класс GenerateRandomUserForm (forms.Form):
    total = forms.IntegerField (
        валидаторы = [
            MinValueValidator (50),
            MaxValueValidator (500)
        ]
    )  

Эта форма ожидает положительное целое поле между 50 и 500. Это выглядит так:

Тогда мой взгляд:

views.py

  от Джанго.contrib.auth.models import Пользователь
из django.contrib импортировать сообщения
из django.views.generic.edit импортировать FormView
из django.shortcuts перенаправление импорта

из .forms import GenerateRandomUserForm
из .tasks import create_random_user_accounts

Класс GenerateRandomUserView (FormView):
    template_name = 'core / generate_random_users.html'
    form_class = GenerateRandomUserForm

    def form_valid (self, form):
        total = form.cleaned_data.get ('total')
        create_random_user_accounts.delay (всего)
        Сообщения.success (self.request, «Мы генерируем ваших случайных пользователей! Подождите немного и обновите эту страницу».)
        возврат перенаправления ('users_list')  

Важный бит здесь:

  create_random_user_accounts.delay (всего)  

Вместо прямого вызова create_random_user_accounts , я звоню create_random_user_accounts.delay () . это Таким образом, мы инструктируем Celery для выполнения этой функции в фоновом режиме.

Затем Django продолжает обрабатывать мое представление GenerateRandomUserView и плавно возвращается к пользователю.

Но прежде чем попробовать, просмотрите следующий раздел, чтобы узнать, как запустить рабочий процесс Celery.

Запуск рабочего процесса

Откройте новую вкладку терминала и выполните следующую команду:

  сельдерей -Мизит рабочий -l инфо  

Измените mysite на название вашего проекта. Результат примерно такой:

Теперь мы можем проверить это. Я отправил 500 в моей форме, чтобы создать 500 случайных пользователей.

Ответ немедленный:

Тем временем проверка рабочего процесса сельдерея:

  [2017-08-20 19: 11: 17,485: INFO / MainProcess] Полученное задание:
mysite.core.tasks.create_random_user_accounts [8799cfbd-deae-41aa-afac-95ed4cc859b0]  

Затем, через несколько секунд, если мы обновим страницу, пользователи будут там:

Если мы снова проверим рабочий процесс сельдерея, мы увидим, что он завершил выполнение:

  [2017-08-20 19: 11: 45,721: INFO / ForkPoolWorker-2] Задача
мой сайт.core.tasks.create_random_user_accounts [8799cfbd-deae-41aa-afac-95ed4cc859b0] преуспел в
28.225658523035236s: «500 случайных пользователей созданы с успехом!»  

Управление рабочим процессом в производстве с помощью Supervisord

Если вы развертываете свое приложение на VPS, например, DigitalOcean вам захочется запустить рабочий процесс в фоновом режиме. В моих уроках мне нравится использовать Supervisord для управления Рабочие из Gunicorn, так что обычно это хорошо сочетается с сельдереем.

Сначала установите его (в Ubuntu):

  sudo apt-get install supervisor  

Затем создайте файл с именем mysite-celery.conf в папке: /etc/supervisor/conf.d/mysite-celery.conf :

  [программа: mysite-сельдерей]
команда = / home / mysite / bin / работник сельдерея -A mysite --loglevel = INFO
каталог = / дом / MySite / MySite
не пользователь = никто
numprocs = 1
stdout_logfile = / дом / MySite / журналы / celery.log
stderr_logfile = / дом / MySite / журналы / celery.log
автозапуск = TRUE
Автоперезапуск = TRUE
startsecs = 10

; Необходимо дождаться завершения выполняемых в данный момент задач при завершении работы.
; Увеличьте это, если у вас очень долго выполняющиеся задачи.stopwaitsecs = 600

stopasgroup = TRUE

; Установите приоритет сельдерея выше, чем по умолчанию (999)
; Итак, если rabbitmq находится под наблюдением, он запустится первым.
приоритет = 1000  

В приведенном ниже примере я рассматриваю, что мой проект Django находится в виртуальной среде. Путь к моему виртуалу среда / home / mysite / .

Теперь перечитайте конфигурацию и добавьте новый процесс:

  перечитать sudo supervisorctl
sudo supervisorctl обновление  

Если вы не знакомы с развертыванием Django на производственном сервере и работой с Supervisord, возможно, эта часть будет иметь больше смысла, если вы проверите этот пост из блога: Как развернуть приложение Django в Digital Ocean.

Дальнейшее чтение

Это основные шаги. Я надеюсь, что это помогло вам начать работу с сельдереем. Я оставлю здесь несколько полезных ссылок продолжать узнавать о сельдерее:

И, как обычно, примеры кода, используемые в этом руководстве, доступны на GitHub:

github.com/sibtc/django-celery-example

Реферальная ссылка

Если вы хотите попробовать эту настройку на облачном сервере Ubuntu, вы можете использовать эту реферальную ссылку, чтобы получить $ 10 бесплатный кредит от Digital Ocean.