در این ویدیو با application در celery آشنا میشوید. برای شروع کار با celery باید از کلاس Celery استفاده کنید و از این کلاس یک نمونه جدید ایجاد کنید. به هر نمونه ای که از کلاس Celery ایجاد میشود application یا بطور خلاصه app گفته میشود. تمامی appها باید یک اسم داشته باشند که پیشنهاد میشود همنام ماژول باشد. بعد از ایجاد کردن app با استفاده از دکوریتور task میتوانید فانکشن های خود را به صورت async صدا زنید.
سلام
من بعد از اجرای فایل این ارور رو دریافت میکنم:
[2024-04-18 05:27:24,050: ERROR/MainProcess] consumer: Cannot connect to amqp://guest:**@127.0.0.1:15672//: timed out.
Trying again in 2.00 seconds... (1/100)
علت چی میتونه باشه؟
ارسال نظر
سلام
احتمالا سلری نمیتونه به بروکر وصل بشه
سلام. میشه راهنمایی کنید که port برای اتصال از کجا باید به دست اورد وارد کرد؟؟ من به مشکل خوردم فکر کنم 5672 نباشه
ارسال نظر
سلام
توی کد خودتون پورت رو مشخص میکنید. اگر پورت پیشفرض جواب نمیده میتونید از پورت های دیگه مثل 5673 یا 5674 استفاده کنید.
اقای بیگدلو وقتی میخواهم از ترمینال برنامه رو اجرا کنم با خطا:
Error: Invalid value for '-A' / '--app':
Unable to load celery application.
The module tasks was not found.
مواجه میشم
کد:(tasks.py)
from celery import Celery
from time import sleep
app = Celery('tasks', broker='redis://localhost')
@app.task
def add(x, y):
sleep(15)
return x + y
- ظاهرا مشکل از مقداردهی اولیه خود جنگو هست اما نتونستم حلش کنم
ارسال نظر
سلام
با چه دستوری سلری رو اجرا میکنی؟ توی نسخه 5 دستور تغییر کرده و باید به شکل زیر اجرا کنید:
celery -A A worker -l info
سلام اقای بیگدلو
با وجود Celery دلیلی هست که از خود rabbitmq استفاده کنیم و اون همه پیچیدگی رو انجام بدیم؟
(البته بجز قضیه میکرو سرویس ها)
ارسال نظر
سلام
خیلی‌ها هستند که دوست دارن مستقیما با خود rabbitmq کار کنن و از اتفاقی که داره پشت پرده میفته خبر داشته باشن. اما خب معمولا ما rabbitmq رو فقط به عنوان broker استفاده میکنیم و celery رو روی اون سوار میکنیم.
ارسال نظر