سلام امیر چطوری من یه مشگلی دارم
ببین من تسک هارو delay میکنم و بهم یک تسک ایدی برمیگردونه
حالا من تویه کد میخام ببینم این تسک ایدی که رفته تو صف الان تویه صف چندمه
چند تا تسک دیگه جلوشه
مثلا من ده تا تسک دارم
یک تسک هم اینجوری بهش اضافه میکنم :
test.delay('hi')
حالا تسک های من مسیهش 11 تا
حالا بعد 5 دقیقه میخام استعلام بگیرم که این تسک من با فلان تسک ایدی الان تو صف چندمه میشه راهنماییم کنی تو نت هرچی سرچ میزنم به جایی نمیرسم
ارسال نظر
سلام
تا جایی که من خبر دارم در سلری نمیتونید همچین کاری بکنید
سلام
من بعد از اجرای فایل این ارور رو دریافت میکنم:
[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 رو روی اون سوار میکنیم.
ارسال نظر