bpmonline/gs-scheduler

BPM索引队列调度器镜像文档

镜像概述

本镜像提供一个调度器服务，核心功能是定期从BPM（业务流程管理）数据库中提取记录，并将其填充到索引队列，以支持后续的索引构建流程。该调度器通过自动化的周期性任务，确保BPM数据库中的记录能够及时进入索引流程，适用于需要持续同步BPM数据到索引系统的场景。

核心功能与特性

• 定期调度：支持基于Cron表达式的灵活调度策略，可配置执行周期（如每小时、每天等）
• 数据库连接：兼容主流关系型数据库，支持配置数据库连接参数（主机、端口、认证信息等）
• 队列填充：将从BPM数据库查询到的待索引记录按指定格式推送到消息队列
• 记录过滤：支持配置过滤条件，仅处理符合条件的BPM记录（如特定状态、时间范围等）
• 日志监控：提供详细的运行日志，便于跟踪任务执行状态和排查问题

使用场景与适用范围

• BPM系统数据索引：适用于需要将BPM数据库记录同步到搜索引擎（如Elasticsearch）的业务场景
• 定期数据同步：用于需要周期性提取BPM数据并推送至下游处理系统的流程
• 企业业务流程管理：支持业务流程记录的实时或准实时索引，提升数据检索效率

使用方法与配置说明

基础使用（Docker Run）

bash
docker run -d \
  --name bpm-index-scheduler \
  -e DB_HOST=bpm-db.example.com \
  -e DB_PORT=5432 \
  -e DB_USER=bpm_user \
  -e DB_PASSWORD=secure_password \
  -e DB_NAME=bpm_database \
  -e SCHEDULE_CRON="0 */1 * * *" \  # 每小时执行一次
  -e QUEUE_TYPE=rabbitmq \
  -e QUEUE_URL=amqp://queue-user:queue-pass@rabbitmq:5672 \
  -e QUEUE_NAME=bpm_index_queue \
  -e RECORD_FILTER="status='active' AND updated_at > NOW() - INTERVAL '1 hour'" \
  your-registry/bpm-index-scheduler:latest

Docker Compose配置

yaml
version: '3'
services:
  bpm-index-scheduler:
    image: your-registry/bpm-index-scheduler:latest
    container_name: bpm-index-scheduler
    environment:
      - DB_HOST=bpm-db
      - DB_PORT=5432
      - DB_USER=bpm_user
      - DB_PASSWORD=secure_password
      - DB_NAME=bpm_database
      - SCHEDULE_CRON="0 */6 * * *"  # 每6小时执行一次
      - QUEUE_TYPE=kafka
      - QUEUE_URL=kafka:9092
      - QUEUE_NAME=bpm_index_topic
      - RECORD_BATCH_SIZE=1000  # 每次处理记录数量
    restart: unless-stopped
    depends_on:
      - bpm-db
      - rabbitmq  # 或kafka等队列服务

环境变量配置说明

注意事项

• 确保数据库和队列服务在调度器启动前已正常运行
• Cron表达式需符合标准格式，建议使用Cron表达式生成工具验证
• 生产环境中建议通过Docker Secrets或环境变量管理工具存储敏感信息（如数据库密码）
• 根据BPM数据库数据量调整RECORD_BATCH_SIZE，避免单次任务处理过大导致性能问题