سلام . جدیدا rabbitmq قابلیت transient_nonexcl_queues رو برداشته ولی سلری هنوز موقع اجرا گیر میده به این. چکار میشه کرد ؟ اصلن اجرا نمیشه ورکر amqp.exceptions.InternalError: Queue.declare: (541) INTERNAL_ERROR - Feature `transient_nonexcl_queues` is deprecated. By default, this feature is not permitted anymore. The feature will be removed from a future major RabbitMQ version, regardless of the configuration; actual version to be determined. توی خود rabbitmq با پاک کردن صف یا durable=True گذاشتن میشه حل کرد . مثل اینکه از سلری mingle منشا میگیره
سلام بقیه هم این مشکل رو دارن. فکر کنم توی نسخه های بعدی سلری این رو درست کنن. همچنین میتونید فعلا داخل فایل rabbitmq.conf کانفیگ زیر رو اضافه کنید: deprecated_features.permit.transient_nonexcl_queues = true
سلام امیر چطوری من یه مشگلی دارم ببین من تسک هارو 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 رو روی اون سوار میکنیم.
نشر و استفاده غیرقانونی از ویدیوها به دور از رضایت و مصداق بارز دزدی میباشد
ارسال نظر
برای ارسال نظر باید لاگین کنید