流程编排功能详解

TaskPyro 专业版的流程编排功能，是一项革命性的创新设计。它将传统的"任务调度器"升维成了"轻量级 Serverless 函数计算平台"+"低代码集成网关"，实现了 Python 脚本的零 API 封装化与运行环境解耦。

功能概览

架构全景图

TaskPyro 流程编排将 Python 脚本升级为轻量级 Serverless 函数计算平台，实现"脚本即接口，调度即编排"：

流程编排架构全景图

可视化编排详解

通过拖拽构建工作流，支持顺序执行和并发执行模式：

可视化流程编排详解

平台架构概览

展示流程编排平台的完整架构和四大创新价值：

流程编排平台架构

🎯 核心一句话总结

"脚本即接口，调度即编排" —— TaskPyro 实现了 Python 脚本的零 API 封装化与运行环境解耦，使其能够无缝融入 n8n 等低代码/AI 编排生态，成为标准化的微服务节点。

💡 四大创新维度

1. 架构创新：零代码 API 化（脚本即服务 Script-as-a-Service）

痛点：以往写完一个爬虫或数据处理脚本，想要对外提供服务，必须套一个 Flask/FastAPI 的壳，写路由、做参数校验、配 WSGI 服务器，繁琐且重。

创新：TaskPyro 把底层执行引擎直接暴露为 HTTP 端点。脚本本身就是 Handler，省去了"造轮子"式的 API 样板代码，开发者 100% 的精力可以回归到 Python 业务逻辑本身。

2. 集成创新：无缝接入低代码/AI 编排生态（协议级解耦）

痛点：在 n8n、Dify、Coze 等平台中集成 Python 能力，通常需要在宿主机装环境、写自定义节点，或者用 Docker 跑沙箱，环境冲突和配置成本极高。

创新：TaskPyro 将复杂环境封装在内部，对外只提供标准的 cURL/REST 接口。n8n 等平台只需一个 HTTP Request 节点即可调用，实现了协议级的极简解耦，让 Python 脚本像 SaaS API 一样即插即用。

3. 编排创新：可视化动态流转（数据流管道化）

痛点：传统的定时任务是孤立的（A 任务跑完结束，B 任务接着跑），中间数据的传递和依赖处理较重。

创新：支持参数传入和节点间数据传递，TaskPyro 不仅是一个触发器，更变成了数据管道。配合外部（n8n）或内部的编排能力，多个 Python 脚本可以像乐高积木一样被动态串联，实现复杂的业务流。

4. 运维创新：环境屏蔽与统一托管（环境无关性）

痛点：不同脚本依赖的库版本打架（如爬虫 A 要 Selenium 3，爬虫 B 要 4），运维管理噩梦。

创新：调用方（无论是 n8n 还是其他服务）完全不需要关心 Python 环境。TaskPyro 内部通过虚拟环境隔离，把"环境配置"这个最大的坑锁死在平台内部，实现了真正的运行时环境解耦。

📊 价值总结

维度	传统模式	TaskPyro 创新模式	核心收益
开发阶段	写脚本 + 写框架 + 写API	只写脚本	降本增效，专注业务
集成阶段	宿主机装环境 / 自定义节点	cURL 直接调	极简接入，协议解耦
编排阶段	硬编码 / 强耦合调度	可视化动态传参流转	灵活组合，快速重构
运维阶段	多环境冲突，难以维护	平台托管，环境隔离	易于管理，稳定可靠

🎨 功能界面

流程编排列表

流程编排模块提供统一的流程管理界面，支持创建、编辑、运行和删除流程。

流程编排列表

可视化编排画布

通过拖拽方式构建复杂的工作流，支持顺序执行和并发执行模式。

可视化编排流程

节点属性配置

启动方式

选择脚本的执行模式：

模式	说明
函数包装运行	指定脚本中的函数作为入口，参数自动注入（推荐）
直接运行命令	直接执行脚本，不经过函数包装

入口函数

设置脚本的入口函数名（默认为 main），系统会自动调用该函数。

入参映射

为函数参数配置数据来源：

• 运行参数：从运行弹窗中手动填写
• 节点输出：引用前面节点的返回值

核心规则：只填写函数参数名（如 x），系统自动处理参数传递。

节点属性配置演示：

节点属性配置演示

上下游节点配置演示：

上下游节点配置演示

多节点并行配置演示：

多节点并行配置演示

操作说明：

• 新增参数：点击右上角的 添加 按钮，系统会自动生成一个新的参数条目（参数名为 PARAM_1、PARAM_2...）。
• 参数名 (Arg)：填写函数定义中的形参名称（注意：只填裸名称，如 x，不要加 inputs. 前缀）。
• 来源 (Source)：选择该参数的数据来源：
  • 运行参数 / 外部：该参数值从运行弹窗中手动填写（默认选项）。
  • 来自节点输出：选择流程中位于当前节点之前的某个脚本节点作为数据提供者，系统会自动拼接为 nodes.{node_id}.outputs.result。
• 输出 Key：当选中"来自节点输出"时出现，可指定前置节点返回字典中的具体字段（默认取 result）。

核心规则：参数映射只填写函数入参的裸名（如 x），系统底层自动处理拼接。严禁使用 inputs.x 前缀。

节点属性配置

定时调度配置

为流程配置 Cron 表达式，实现定时自动触发执行。

定时调度配置

外部触发配置

生成 HTTP Hook 地址，支持通过 cURL 或其他系统触发流程执行。

外部触发配置

运行拓扑展示

实时展示流程运行状态，可视化查看每个节点的执行详情和数据传递。

运行拓扑展示

运行拓扑展示

运行记录

记录流程的所有执行历史，方便追踪和排查问题：

• 版本追踪：记录每次执行的流程版本号
• 触发方式：标识手动触发、定时触发或外部触发
• 执行状态：success（成功）、stopped（停止）、failed（失败）
• 执行时间：精确记录开始时间和结束时间
• 错误摘要：失败时显示错误信息和退出码

运行记录

运行参数配置

支持为每个脚本节点配置独立的运行参数：

• 节点级参数：为每个脚本节点设置专属输入参数
• 参数预览：实时预览将发送的 node_inputs JSON 结构
• 动态传参：支持参数在节点间传递和引用

运行参数配置

🔧 使用场景

场景一：n8n、Dify、Coze 等平台集成

通过 HTTP Request 节点调用 TaskPyro 流程，实现 Python 能力与 n8n/Dify/Coze 工作流的无缝集成：

curl -X POST https://IP:PORT/workflows/hooks/xxx-token-xxx \
  -H "Content-Type: application/json" \
  -d '{"input_data": {"url": "https://example.com"}}'

场景二：内部流程编排

使用可视化编排画布，将多个 Python 脚本串联成业务流程：

1. 拖拽脚本节点到画布
2. 连接节点建立数据流转关系
3. 配置节点输入输出参数
4. 保存并运行流程

场景三：定时数据处理

配置 Cron 表达式，定期执行数据采集和处理流程：

# 每天凌晨 2 点执行
0 2 * * *

# 每周一至周五 9 点执行
0 9 * * MON-FRI

💡 核心价值

本质创新：将 Python 脚本的"执行环境"与"调用方式"彻底剥离。TaskPyro 充当了一个翻译官和绝缘层，让老旧/复杂的 Python 脚本瞬间现代化，变成 n8n 等自动化/AI 工作流中随取随用的"标准化算力零件"。

核心收益：

• 开发者：专注业务逻辑，告别 API 样板代码
• 集成者：协议级解耦，即插即用
• 运维者：环境隔离，统一管理
• 管理者：可视化编排，灵活调度