dittofeed/dittofeed-worker

Dittofeed Worker 镜像文档

镜像概述和主要用途

Dittofeed Worker镜像是Dittofeed开源客户参与平台的核心组件之一，作为后台工作器负责处理平台的异步任务和后台作业，确保主应用服务的高效运行和任务的可靠执行。该镜像与Dittofeed主应用协同工作，承担非实时性任务处理，是保障平台功能完整性和稳定性的关键组件。

核心功能和特性

核心功能

• 异步任务处理：处理平台生成的各类异步任务，如邮件发送、通知推送、用户行为数据处理等
• 定时任务执行：支持预设时间或周期性任务的调度与执行，如周期性报表生成、用户活跃度分析等
• 任务队列管理：高效管理任务队列，按优先级有序执行任务，避免任务阻塞
• 错误重试机制：对失败任务提供自动重试功能，支持自定义重试策略，保障任务最终一致性

主要特性

• 轻量级设计，资源占用低
• 与Dittofeed主平台无缝集成，共享配置与数据
• 支持多队列隔离，可按任务类型区分处理
• 提供详细日志输出，便于问题排查

使用场景和适用范围

使用场景

• 部署完整的Dittofeed客户参与平台时，作为必要组件运行
• 扩展Dittofeed平台的任务处理能力，通过水平扩展Worker实例提升并发处理能力
• 替换或升级现有Dittofeed部署中的后台工作器组件

适用范围

• 开发环境：用于功能测试和任务流程验证
• 测试环境：模拟生产负载，验证任务处理性能
• 生产环境：支撑实际业务场景下的异步任务处理，如客户营销自动化、多渠道消息推送等

使用方法和配置说明

前置条件

• 已部署Dittofeed主应用服务
• 已准备PostgreSQL数据库（存储任务状态和配置）
• 已准备Redis服务（用于任务队列管理）

镜像获取

通过Docker Hub拉取官方镜像：

bash
docker pull dittofeed/worker:latest

基本使用（Docker Run）

bash
docker run -d \
  --name dittofeed-worker \
  -e DATABASE_URL="postgresql://<user>:<password>@<db-host>:5432/dittofeed" \
  -e REDIS_URL="redis://<redis-host>:6379/0" \
  -e LOG_LEVEL="info" \
  -e WORKER_CONCURRENCY=4 \
  dittofeed/worker:latest

Docker Compose配置示例

yaml
version: '3.8'

services:
  worker:
    image: dittofeed/worker:latest
    container_name: dittofeed-worker
    restart: always
    environment:
      - DATABASE_URL=postgresql://dittofeed:secret@db:5432/dittofeed
      - REDIS_URL=redis://redis:6379/0
      - LOG_LEVEL=info
      - WORKER_CONCURRENCY=4
      - QUEUE_NAME=default
    depends_on:
      - db
      - redis

  # 依赖服务示例（需与Dittofeed主应用共享）
  db:
    image: postgres:14
    environment:
      - POSTGRES_USER=dittofeed
      - POSTGRES_PASSWORD=secret
      - POSTGRES_DB=dittofeed
    volumes:
      - postgres-data:/var/lib/postgresql/data

  redis:
    image: redis:alpine
    volumes:
      - redis-data:/data

volumes:
  postgres-data:
  redis-data:

配置参数说明

注意事项

• 依赖服务：需确保PostgreSQL数据库和Redis服务已启动并可访问，且与Dittofeed主应用使用相同的数据库实例
• 版本兼容性：需使用与Dittofeed主应用匹配的Worker镜像版本，版本不匹配可能导致功能异常
• 资源配置：根据任务量调整WORKER_CONCURRENCY参数，避免资源过度占用
• 日志管理：默认日志输出至stdout，可通过Docker日志驱动配置日志持久化或集中管理