labm/bureau-importworkers-celery-daemon

labm/bureau-importworkers-celery-daemon镜像说明

镜像概述

labm/bureau-importworkers-celery-daemon是一个运行Celery workers的守护进程镜像，核心功能是接收消息队列（MQ）中的任务消息，并执行对应的Celery worker任务，支持分布式异步任务处理场景。

核心功能

• 接收消息队列（如RabbitMQ、Redis）的任务消息
• 执行Celery workers定义的后台任务
• 以守护进程模式持续运行，保障任务处理稳定性

使用场景

• 后台异步任务处理（数据导入、批量计算、文件转换等）
• 分布式任务调度与执行
• 消息驱动的业务流程自动化

配置说明

需通过环境变量配置关键参数：

1. MQ_BROKER_URL：消息队列连接地址（示例：amqp://user:pass@rabbitmq:5672/ 或 redis://redis:6379/0）
2. CELERY_TASK_MODULE：Celery任务模块路径（示例：my_project.tasks）
3. 可选配置：CELERY_CONCURRENCY（并发worker数量）、CELERY_RESULT_BACKEND（结果存储地址）

部署示例

Docker Run命令

bash
docker run -d \
  --name celery-worker \
  -e MQ_BROKER_URL=amqp://admin:admin@rabbitmq:5672/my_vhost \
  -e CELERY_TASK_MODULE=app.tasks \
  -e CELERY_CONCURRENCY=4 \
  labm/bureau-importworkers-celery-daemon

Docker Compose示例

yaml
version: '3'
services:
  celery-worker:
    image: labm/bureau-importworkers-celery-daemon
    environment:
      - MQ_BROKER_URL=amqp://admin:admin@rabbitmq:5672/my_vhost
      - CELERY_TASK_MODULE=app.tasks
      - CELERY_CONCURRENCY=4
    depends_on:
      - rabbitmq
  rabbitmq:
    image: rabbitmq:3-management
    ports:
      - "5672:5672"
      - "***:***"
    environment:
      - RABBITMQ_DEFAULT_USER=admin
      - RABBITMQ_DEFAULT_PASS=admin
      - RABBITMQ_DEFAULT_VHOST=my_vhost