trustgraph/trustgraph-flow

处理流程处理组件镜像文档

概述

该Docker镜像为一款轻量级处理流程处理组件，旨在提供标准化的流程定义、任务调度与执行能力，支持自动化处理流水线的构建与运行。镜像内置流程解析引擎、任务执行器及状态管理模块，可适配多种业务场景下的流程化处理需求。

核心特性

• 流程定义灵活：支持JSON/YAML格式的流程配置文件，可定义串行/并行任务依赖关系
• 任务调度能力：提供定时触发、事件触发及手动触发三种任务启动方式
• 状态可视化：实时记录流程各节点执行状态（待执行/运行中/成功/失败），支持状态查询接口
• 可扩展性：支持自定义任务插件集成，通过挂载外部脚本扩展处理能力
• 轻量高效：基于Alpine基础镜像构建，镜像体积<50MB，启动时间<10秒

使用场景

• 数据处理流水线：如日志清洗→数据转换→存储入库的自动化流程
• 业务流程自动化：如订单审核→库存扣减→物流通知的交易流程
• 定时任务执行：如每日数据报表生成、周期性系统巡检等定时处理场景

部署示例

基础运行命令

bash
docker run -d \n  --name processing-component \n  -v /host/path/process-config:/app/config \n  -v /host/path/logs:/app/logs \n  -e PROCESS_INTERVAL=300 \n  -e LOG_LEVEL=info \n  processing-flow-component:latest

参数说明

• -v /host/path/process-config:/app/config：挂载主机流程配置文件目录（需包含流程定义文件flow.yaml）
• -v /host/path/logs:/app/logs：挂载日志目录，存储流程执行日志
• -e PROCESS_INTERVAL：流程循环执行间隔（秒），默认300秒
• -e LOG_LEVEL：日志级别，可选值：debug/info/warn/error，默认info

配置文件规范

流程配置文件（flow.yaml）示例：

yaml
process_id: data_cleaning_flow
steps:
  - name: step1_data_extract
    type: script
    command: /app/scripts/extract.sh
    timeout: 60
  - name: step2_data_transform
    type: python
    script_path: /app/scripts/transform.py
    depends_on: [step1_data_extract]

环境变量配置

注意事项

1. 挂载配置目录时需确保主机目录权限正确（建议设置权限755）
2. 流程中涉及的外部脚本需通过挂载方式注入，并赋予可执行权限
3. 高并发场景下建议调整容器CPU/内存资源限制（推荐最低配置：1核CPU，512MB内存）