magneticio/vamp-workflow-agent

Vamp Workflow Agent

镜像概述

Vamp Workflow Agent是一款用于动态获取并执行工作流脚本的工具，通过confd从键值存储（如Zookeeper）获取JavaScript文件，利用Node.js运行时执行，并提供执行周期和超时控制功能，适用于自动化工作流场景。

核心功能

1. 脚本获取：使用confd工具从键值存储中读取工作流JavaScript文件；
2. 脚本执行：启动Node.js运行时执行获取到的脚本；
3. 参数配置：支持通过命令行参数或环境变量设置执行周期、超时时间等关键参数；
4. 跨平台构建：提供脚本支持多架构二进制文件和Docker镜像构建。

使用场景

• 自动化定时任务：如周期性数据处理、日志分析；
• 动态工作流更新：从配置中心获取最新脚本并执行，无需重启服务；
• 微服务流程调整：在微服务架构中动态调整业务逻辑。

配置说明

命令行参数

./vamp-workflow-agent -help
Usage of ./vamp-workflow-agent:
  -help                打印使用帮助
  -workflow string     工作流文件路径（默认：/usr/local/vamp/workflow.js）
  -executionPeriod int 连续执行间隔秒数（0表示禁用）
  -executionTimeout int 最大执行超时秒数（0表示无超时）

环境变量

• VAMP_KEY_VALUE_STORE_TYPE：键值存储类型（对应confd的-backend参数）
• VAMP_KEY_VALUE_STORE_CONNECTION：键值存储连接地址（对应confd的-node参数）
• VAMP_KEY_VALUE_STORE_PATH：confd使用的键路径
• VAMP_WORKFLOW_EXECUTION_PERIOD：执行周期（与executionPeriod参数对应）
• VAMP_WORKFLOW_EXECUTION_TIMEOUT：执行超时（与executionTimeout参数对应）

Docker部署示例

bash
docker run -e VAMP_KEY_VALUE_STORE_TYPE=zookeeper \
           -e VAMP_KEY_VALUE_STORE_CONNECTION=localhost:2181 \
           -e VAMP_KEY_VALUE_STORE_PATH=/scripts \
           -e VAMP_WORKFLOW_EXECUTION_PERIOD=0 \
           -e VAMP_WORKFLOW_EXECUTION_TIMEOUT=10 \
           magneticio/vamp-workflow-agent:katana

该示例从Zookeeper的/scripts路径读取JavaScript文件，执行一次（周期为0），超时时间10秒。