Рубрики
Без рубрики

Сельдерей, должен учиться технологии для разработчиков Python

Здесь я пытаюсь прикрыть сельдерей в Python, нам нужно понять перед использованием сельдерея. Что такое … с меткой python, подпроцесса, сельдереем, резьбой.

Здесь я пытаюсь покрыть сельдерей в Python Нам нужно понять перед использованием сельдерея. Что такое сельдерей? Сельдерей – один пакет или модуль или программа, которая написана на Python, и она помогает разделить программу в мирной основе, и она будет запускать асинхронное программирование или многопоточную. Почему мы должны использовать сельдерей? Всякий раз, когда пользователь пытается забронировать отель или такси, тем временем он не получает ответа на некоторое время с веб-сайта, в тот момент сервер выполнял свою работу, чтобы получить запрос и процесс, а затем вернуть ответ на пользователя С

Когда время обработки может быть увеличено из-за отправки Hotel, или CAB доступно, а затем, наконец, подтвердите ее, отправляя, чтобы гарантировать вашу кабину или книгу отеля через электронные письма или SMS и bla .., BLA.

Мы знаем, что пользователь застрял, поэтому, почему мы должны определить процесс в нескольких задании или потоке или подпрограмме, а сельдерей помогают нам сделать это. Что рабочий на сельдереи? Работник похоже на труд, сотрудник, который сделал свою работу согласно инструкции, который дал его руководителем или руководителем здесь, на работнике сельдерея, кажется одним из подпрограмм, который будет выполнен задачей путем назначения очереди сообщений.

Что такое очередь или брокер сообщений в сельдерее? Брокер – это фасилитатор третьего лица между покупателем и продавцом. В сельдерее. Брокер Redis, rabbitmq ETC, который передает сообщение между клиентом и сельдереем.

Очередь сообщений является одним из менеджеров или лидеров. Кто получает некоторую инструкцию от клиента и передачи инструкций на работнику согласно его умению, так что в очереди сообщений работают в сельдереи, используя брокер, как ( robritmq, redis, Amazon SQS и т. Д.) – это инструкция с клиентами означает наш проект и передать это сообщение работнику делать эти задачи, назначив в нашем проекте.

Давайте начнем наш практично

Нам нужно сначала установить наши требования :

  • Брокер или сервер
  • Питон
  • Сельдерей

Примечание : – здесь я использовал Linux на данный момент, если вы использовали другую платформу, вы должны прочитать документы для установки

Установить брокер Вот я устанавливаю кролик . Вы можете установить другой брокер, как redis etc.

sudo apt-get update
sudo apt-get upgrade
sudo apt-get install rabbitmq-server

Перезагрузите сервер и проверьте состояние сервера

#restart
sudo service rabbitmq-server check status
#status
sudo rabbitmqctl status

Установите Python Linux предоставляет Python по умолчанию. Если вы используете другую платформу, то вы должны быть Установите Python

Установите сельдерей Установите на нашем уровне системы. Я не использовал виртуальный . Даже вы делаете отдельные Virtual-env Установите его.

pip3 install celery

Теперь мы создаем имя файла как Tasks.py

from celery import Celery

APP_NAME = 'tasks'
BROKER_NAME = '"amqp://guest:guest@localhost:5672//"'
BACKEND = 'db+postgresql://postgres:postgres@localhost/celerydemo'

app = Celery(APP_NAME,broker=BROKER_NAME, backend=BACKEND)

@app.task
def reverse(string):
    return string[::-1]

Вот сначала мы должны импортировать Celey класс от сельдерей И тогда мы определяем постоянную

  • App_name Назначается для уникального идентификации нашего приложения, возможно, имеет несколько приложений в одиночных проектах.
  • Broker_Name Как мы видели, что есть брокер, нам нужно указать, какой путь используется для брокера, который мы использовали, он предоставит по умолчанию, когда пользователь гостевой, если вы создали отдельный пользователь на Broker Server, он изменит базу на брокере, если мы выполняем нашу задачу используя это Broker_name. думал, что мы общаемся с нашим работником. Вы могли видеть Настроить сельдерей
  • Backend Необязательный параметр, когда принял, если нам нужно будет хранить статус задач сельдерей в базе данных, мы должны пройти другой путь согласно базе данных См. Путь Backend в сельдерею

Теперь мы открываем два терминала сначала для нашего Broker Server у меня есть rabbitmq взаимодействовать с сельдереем и дать статус задачи и второй – Интерактивный терминал Python

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

Сельререй – рабочие работники

Здесь мы проходим аргумент в сельдерей команда - означает приложение тогда задания это приложение (то же самое, что и наше имя файла), которое мы указываем и рабочий Для назначения рабочего для этой задачи последнее, но не в последнюю очередь loglevel Для ведения журнала Назначение IT Info Есть еще одна опция доступна, если вы --help или -h для этого

  • Откройте терминал, где ваш Tasks.py Первый магазин и запустить Python здесь мы начинаем Python Interactive Terminal и импорт Реверс из задач
>>> from tasks import reverse
>>> reverse
<@task: tasks.reverse of tasks at 0x7f49adca06d0>
>>> reverse('hi there we have used celery')
'yrelec desu evah ew ereht ih'
>>> reverse.delay('hi there we have used celery')

>>>

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

Мы сделаем периодическую задачу, такую как каждую 10-секундную задачу Run в следующем руководстве Надеюсь, этот учебник полезен для вас

Оригинал: “https://dev.to/l_b_vasoya/celery-a-must-learn-technology-for-python-developers-48im”