无法连接到兔芹菜

发布于 2025-01-28 10:17:32 字数 1256 浏览 0 评论 0原文

我正在使用芹菜,兔子,fastapi,docker开发应用程序。这是我的docker-compose-yml。

  services:  
    rabbitmq:
       container_name: rabbitmq
       image: rabbitmq:3-management
       ports:
          - 5672:5672
          - 15672:15672

    redis:
       container_name: redis                                                            
       image: redis
       ports:
          - "6379:6379"

    worker:
       container_name: worker
       build:
          dockerfile: api/Dockerfile
       context: .
          command: sh -c "cd api && uvicorn app:app --host 0.0.0.0 --port 8000 & cd ../ & celery -A celery_tasks.app_worker worker -l INFO --pool=solo"
      volumes:
           - .:/app
       ports:
           - "8000:8000

中我的worker配置

  import os
  from celery import Celery

  BROKER_URI = 'amqp://rabbitmq'
  BACKEND_URI = 'redis://redis'

  app = Celery(
   'celery_tasks',
    broker=BROKER_URI,
    backend=BACKEND_URI,
    include=['celery_tasks.upload_task','celery_tasks.save_record_task']
  )

以下是app-worker.py

 [2022-05-13 05:09:28,500: ERROR/MainProcess] consumer: Cannot connect to 
 amqp://guest:**@rabbitmq:5672//: [Errno 111] Connection refused.

I am using Celery,RabbitMq,FastAPI,docker to develop a application.This is my docker-compose-yml.

  services:  
    rabbitmq:
       container_name: rabbitmq
       image: rabbitmq:3-management
       ports:
          - 5672:5672
          - 15672:15672

    redis:
       container_name: redis                                                            
       image: redis
       ports:
          - "6379:6379"

    worker:
       container_name: worker
       build:
          dockerfile: api/Dockerfile
       context: .
          command: sh -c "cd api && uvicorn app:app --host 0.0.0.0 --port 8000 & cd ../ & celery -A celery_tasks.app_worker worker -l INFO --pool=solo"
      volumes:
           - .:/app
       ports:
           - "8000:8000

Following is my worker config in app-worker.py

  import os
  from celery import Celery

  BROKER_URI = 'amqp://rabbitmq'
  BACKEND_URI = 'redis://redis'

  app = Celery(
   'celery_tasks',
    broker=BROKER_URI,
    backend=BACKEND_URI,
    include=['celery_tasks.upload_task','celery_tasks.save_record_task']
  )

when I start the application using the command docker-compose up I am getting following error

 [2022-05-13 05:09:28,500: ERROR/MainProcess] consumer: Cannot connect to 
 amqp://guest:**@rabbitmq:5672//: [Errno 111] Connection refused.

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。
列表为空,暂无数据
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文