Skip to main content Home Creators cas-bigdatalab piflow piflow-skill-generator
piflow-skill-generator PiFlow 技能生成器。当用户完成了一次完整并成功的数据处理任务时调用，根据当前 skills/generated 的本地约定和 references/piflow_skill_template.md 通用模板创建、更新或校验 PiFlow-compatible skill，包括 UTF-8 编码的 SKILL.md、DAG 可读的 input_params/output_params、version/tag 元数据、skill.json、scripts/references/assets 资源目录，以及本地校验脚本。仅在用户明确要求生成或保存 skill，或某次数据处理任务已经完成并需要把已验证成功的操作流程沉淀为 skill 时使用；默认不要因为“可能需要 skill”或“当前能力不足”而优先触发此 skill。
Jump to install Skills Marketplace Discover and explore AI skills built by the community.
Install with Codex or Claude Copy this prompt, paste it into Codex, Claude, or another assistant, and let it review the skill page and install it for you.
Show prompt details A direct command skips the review prompt. Inspect the source before running it.
npx skills add https://github.com/cas-bigdatalab/piflow --skill piflow-skill-generatorThe command stays on one line. Scroll horizontally to inspect it before copying.
Prefer a local copy? Download the files currently available to SkillsMP.
Download Zip Downloading... More from this repository
Related occupations SOC
Based on SOC occupation classification
name piflow-skill-generator description PiFlow 技能生成器。当用户完成了一次完整并成功的数据处理任务时调用，根据当前 skills/generated 的本地约定和 references/piflow_skill_template.md 通用模板创建、更新或校验 PiFlow-compatible skill，包括 UTF-8 编码的 SKILL.md、DAG 可读的 input_params/output_params、version/tag 元数据、skill.json、scripts/references/assets 资源目录，以及本地校验脚本。仅在用户明确要求生成或保存 skill，或某次数据处理任务已经完成并需要把已验证成功的操作流程沉淀为 skill 时使用；默认不要因为“可能需要 skill”或“当前能力不足”而优先触发此 skill。
name_zh PiFlow 算子生成器 version 1.1.2 allowed-tools ["process"] input_params [{"name":"spec_path","type":"string","required":false,"description":"技能规格 JSON 文件路径，必须使用 UTF-8 编码；与 flow_path 二选一"},{"name":"output_root","type":"string","required":false,"default":"skills/generated","description":"输出根目录；deepagent 虚拟文件环境默认写入 skills/generated（相对于 workspace 根）"},{"name":"overwrite","type":"bool","required":false,"default":false,"description":"是否覆盖已存在的技能目录"},{"name":"flow_path","type":"string","required":false,"description":"已验证成功的流程摘要 JSON 路径；与 spec_path 二选一"},{"name":"restored_spec_out","type":"string","required":false,"description":"使用 flow_path 时恢复出的 spec 草稿输出路径"},{"name":"rewrite_followup_hint","type":"string","required":false,"default":"","description":"可选提示语；当 skill 生成完成后，如用户随后给出新的流程，可提示是否进入生成器内部改写链路继续改写"}] output_params [{"name":"skill_dir","type":"directory","description":"生成后的技能目录"},{"name":"skill_md","type":"markdown_file","description":"生成后的 SKILL.md"},{"name":"rewrite_followup_suggestion","type":"json_file","description":"生成完成后的改写 follow-up 建议信息"}] tag AI处理 publisher COMMUNITY
PiFlow Skill Generator
核心规则
除去对运行/测试时的产物进行分析，其他工作应尽量提前计划和生成，避免在安装或测试阶段才发现文档不完整、脚本缺失或资源错误。技能生成器的目标是一次性生成一个完整、可靠、符合约定的技能目录，能直接被 PiFlow 识别和使用，但它不是默认优先入口。
生成能被 PiFlow 理解的技能目录。所有文本文件必须以 UTF-8 读写，尤其是中文内容；Python 读写文件时显式使用 encoding="utf-8"，JSON 输出使用 ensure_ascii=False。
按库内技能的粒度控制内容：SKILL.md 只放触发、流程和必要契约；可执行逻辑放 scripts/；较长规则、字段说明和领域资料放 references/；模板、图标、示例素材放 assets/。
生成正文时优先参照 references/piflow_skill_template.md。当 spec 中提供 core_features、trigger_conditions、processing_logic、supported_formats、output_structure、output_examples 等字段时，将它们填入模板对应章节。
本技能必须能在没有其他技能辅助的环境中独立生成可靠技能：只依赖当前技能目录内的 SKILL.md、references/piflow_skill_template.md、references/rewrite_followup_internal.md、scripts/generate_piflow_skill.py、scripts/generate_skill_files.py、scripts/register_skill_artifacts.py、scripts/rewrite_piflow_skill.py 和 scripts/validate_piflow_skill.py。生成时不要假设另一个 skill 会补全文档、脚本或元数据。本技能负责 skill 化与沉淀，不负责代替用户完成所有真实处理任务本身。
本技能支持三条触发链路：
手动生成链路
当用户明确要求“生成 skill”“保存为 skill”“封装为 skill”“创建自定义技能”时，直接进入 skill 生成阶段，行为与当前链路一致。
回调式沉淀链路
当现有技能库无法直接满足需求时，应先在 skill 层面声明当前没有可直接复用的现成 skill，并优先引导大模型先帮助用户解决问题本身，例如生成脚本、处理流程、输入输出约定、验证步骤等。只有在这些处理流程已经跑通、结果已验证后，才回调进入本技能，并提示用户是否根据之前的成功操作流程将其封装为 skill。
生成后改写链路
当一个 skill 已经生成完成并经过基础校验后，如果用户随后又提供了一个新的成功流程、更新后的脚本或更合理的输入输出设计，不要默认忽略这些新信息；应主动询问用户，是否要以这个新的流程为指引，对刚生成的 skill 做一次最小改写；若用户确认，则优先进入生成器内部改写链路，以“保留原 skill 名称 + overwrite 重建”的方式做最小改写，而不是要求用户重新生成一个同义的新 skill。
因此，本技能不是默认优先入口，但也不再只局限于“任务完全结束后人工另起一轮对话”；它可以作为缺 skill 场景下的回调式沉淀终点。
此外，本技能提供一个最小“生成后再改写”的后续触发路径：
当一个 skill 已经生成完成后，如果用户随后又给出了新的成功流程、新的输入输出约定或新的脚本实现，可以询问用户：
“是否要以这次新的流程作为指引，对刚生成的 skill 再做一次改写？”
若用户同意，则应进入生成器内部改写链路，对刚生成的 skill 做最小重写，而不是要求用户重新生成一个同义的新 skill。
详细依赖与调用关系见 references/rewrite_followup_internal.md。
在涉及安装、环境准备或可执行脚本验证时，优先完成最小必要依赖，再运行一个简单冒烟测试确认关键入口可执行、基础参数可解析、输出路径可写。若安装或测试失败，允许自动重试，单个阶段最多重试 5 次；若 5 次后仍失败，停止流程并把失败原因、失败步骤和最后一次错误返回给用户。
安装依赖或配置前置环境时，若不明确安装的流程或操作，需要调用网络工具获取安装指南或官方文档，或者直接调用搜索查询安装步骤，不要假设已经知道如何安装或配置。
路径规则
deepagent 的虚拟文件环境以 workspace 为根。生成的技能必须放在
skills/generated/<skill-name>
默认 output_root 使用 skills/generated，表示 <workspace>/skills/generated。
write_file/read_file 等工具调用时使用相对于 workspace 根的虚拟路径（如 skills/generated/<skill_name>/），不要带 workspace/ 前缀 。Shell 命令中使用 --output-root skills/generated。
如果用户传入旧路径 workspace/skills 或 flow-deepagents/workspace/skills，脚本会归一化为当前 deepagent workspace 下的 skills/generated。
spec_path、icon、script.source、references[].source、assets[].source 可以使用相对路径；脚本会先按当前工作目录解析，再按 deepagent workspace 根解析。不要把生成目录写到仓库外层、flow-deepagents/workspace/workspace/skills 或 workspace/skills/skills。
PiFlow 技能结构 skill-name/
├── SKILL.md
├── skill.json # 推荐，DAG 执行/画板读取的结构化元数据
├── scripts/ # 推荐，稳定可执行逻辑
├── references/ # 可选，按需读取的长文档
└── assets/
└── icon.png # 必须选定的主图标；若没有自定义图标，需明确兜底到分类图标
SKILL.md SKILL.md 由 YAML frontmatter 和 Markdown body 组成。
name：必须与目录名完全一致。description：主要触发入口。必须同时说明技能做什么、用户在什么表达或场景下应触发。触发信息写在这里，不要只写在正文。version：技能版本，默认 1.0.0。input_params：PiFlow DAG 面板读取的输入参数列表，必须保留。output_params：PiFlow DAG 面板读取的输出参数列表，必须保留。allowed-tools、compatibility、license、metadata：仅在确实需要时添加。tag：面向 DAG 面板的技能类型；当前入库逻辑会读取 tag 作为 skill_type。 - name: input_path
type: string
required: true
default: optional-default
description: 输入文件路径
SKILL.md frontmatter 的参数项禁止包含 role。role 是 DAG 专用元数据，只应写入 skill.json；生成器会依据参数的 type、name 和 description 在 JSON 中推断 input_data、output_data 或 data。
skill.json 当 skill_json 未显式设为 false 时生成。该文件用于 DAG 执行链路和画板解析，包含：
name、version、descriptionlanguagescript_pathentrypointinput_params、output_params，其中参数保留 rolecommand_template可选 tag
只在用户或 spec 明确提供时写入 dependencies 或 policy 等扩展字段。
Bundled Resources
scripts/：放确定性脚本、算子封装、批处理逻辑。脚本应可通过 python scripts/<name>.py ... 调用，并使用 UTF-8 读写。references/：放长规则、字段字典、API 说明、数据 schema、复杂示例。正文中必须说明何时读取哪个引用文件。assets/：放图标、模板、示例素材、字体或输出需要复制的资源。每个 skill 在生成阶段都应明确一个主图标方案：优先提供 assets/icon.png；若暂时没有自定义图标，也必须在设计与交付时明确兜底使用对应分类图标，不要让图标策略处于未定义状态。 不要生成与执行无关的 README.md、安装指南、变更日志或重复说明文档；这些内容会稀释技能目录的信号。
生成流程
A. 手动生成链路
先判断用户是否明确要求生成或保存 skill。若是，则直接进入本链路。
明确具体用例。优先收集用户会怎样调用技能、输入输出文件长什么样、是否需要脚本、是否有字段规则或外部依赖。
规划资源分层。重复且要求稳定的逻辑进入 scripts/；长规则进入 references/；图标和模板进入 assets/。这一阶段同时确定图标策略：选一个主图标来源，并明确一个兜底图标。
规范命名。已有业务技能名可保留大小写和下划线，例如 QC3_NumericDataThresholdCheck、Pi_DataSorting；新通用技能优先使用 lowercase snake_case 或 hyphen-case；目录名必须等于 name。
生成 SKILL.md。正文按 references/piflow_skill_template.md 的章节顺序组织：功能说明、触发条件、核心功能、处理逻辑、支持的文件格式、使用方法、参数说明、输出参数、示例、输出格式/输出结构、依赖、注意事项。
生成资源目录。只有在 spec 提供或任务需要时写入脚本、引用资料和素材；图标必须有明确结论：若 spec 提供 icon，复制为 assets/icon.png 作为主图标；若未提供自定义图标，则记录并验证可兜底到分类图标。
校验并迭代。运行 validate_piflow_skill.py，检查 UTF-8、YAML、参数契约、目录名、资源布局和 UI metadata。
安装后冒烟测试。若该技能需要额外依赖或运行时环境，在环境配置完成后先执行一个最小可运行示例或健康检查脚本，确认关键入口能正常启动并完成一次基础输入输出。
失败重试与兜底。安装与冒烟测试过程中若失败，先重试再继续；单阶段最多 5 次。若 5 次都失败，停止自动化流程并把失败原因、失败步骤和最后一次错误返回给用户。
B. 回调式沉淀链路
当现有技能库无法直接满足需求时，先明确声明当前没有可直接复用的现成 skill。
不要立刻要求用户完整填写所有 skill 字段；应先引导大模型帮助用户完成问题本身，例如脚本、流程、步骤、输入输出约定与验证方式。
在直接解决过程中，持续保留可蒸馏信息，例如成功脚本、关键步骤、参数约定、输出目录结构、样例输入输出和验证结果。
一旦判断处理流程已经跑通、结果可信，应回调询问用户是否根据之前的成功操作流程封装为 skill。
若用户同意沉淀，则优先把之前成功流程恢复为 spec 草稿，而不是让用户从头重新描述。
仅对恢复不出的字段补问，例如技能命名、分类、触发表达、图标策略、依赖说明等。
然后复用与手动生成链路相同的生成、校验、注册和冒烟测试流程。
C. 生成后改写链路
当一个 skill 已经生成完成并经过基础校验后，若用户又提供了一个新的成功流程、更新后的脚本或更合理的输入输出设计，不要默认忽略这些新信息。
应主动询问用户，是否要以这个新的流程为指引，对刚生成的 skill 做一次最小改写。
若用户确认，则优先进入生成器内部改写链路。
改写时默认复用原 skill 名称和目录位置，避免生成第二个含义重复的新 skill。
改写完成后，继续执行与主技能一致的校验和注册逻辑。
三层调用模型
生成层
负责把 spec 落成技能目录本身，包括 SKILL.md、skill.json、scripts/、references/、assets/ 等内容。
对应脚本：scripts/generate_skill_files.py
注册层
负责把已生成好的技能接入 PiFlow 可见索引，包括更新 docs/skill分类.txt，以及同步 storage/skills 下的技能图标与分类图标。
对应脚本：scripts/register_skill_artifacts.py
一键封装层
按顺序调用“生成层 -> 注册层”，适合默认使用。
对应脚本：scripts/generate_piflow_skill.py
调用建议
当你需要“先生成草稿、再人工检查、最后再发布/注册”时：
先调用生成层，再调用 validate_piflow_skill.py --mode files-only，确认通过后再调用注册层。
当你需要“一次性生成并接入系统可见列表”时：
直接调用一键封装层。
当你只是想更新技能正文、脚本、资源，但暂时不希望污染全局分类列表或图标存储时：
只调用生成层，不调用注册层。
当技能目录已经存在，只是因为分类列表或图标丢失，需要补注册时：
只调用注册层。
当你是从一次成功的真实处理流程回调进入本技能时：
优先先恢复流程草稿 spec，再补缺失字段，然后根据是否需要立即可见，选择“只生成”或“一键生成并注册”。
当你已经生成完一个 skill，但用户随后提供了新的流程指引时：
不要要求重新从零生成；应提示可以进入内部改写链路，以“保留原 skill 名称 + overwrite 重建”的方式做最小改写。
Spec 字段
name：必填，技能目录名和 frontmatter 名称。title：可选，正文标题和 UI 显示名的候选值。description：必填，技能能力说明。仅在用户明确要求生成/保存 skill，或任务完成后需要沉淀成功流程时描述 skill 生成能力；不要把宽泛的数据处理诉求直接写成触发词。description：必填，技能能力说明。若来自手动生成链路，描述用户如何显式触发此 skill；若来自回调式沉淀链路，描述应收敛为“成功流程完成后可封装为 skill”这类收尾触发，而不要把原始任务诉求直接写成默认优先入口。version：可选，默认 1.0.0。triggers：可选，触发短语列表，会并入 frontmatter description。触发短语应收敛为“生成 skill”“保存为 skill”“把这次流程沉淀成 skill”等手动或收尾场景，不要把“数据清洗”“数据分析”“处理文件”等本应先直接执行的任务写成优先触发短语。tag：可选，写入 frontmatter 和 skill.json，用于 DAG 技能类型。language：可选，写入 skill.json，默认按脚本推断为 python。script_path、entrypoint、command_template：可选，写入 skill.json；缺省时由脚本路径和参数推断。input_params、output_params：PiFlow 参数契约。参数项可包含 role。input_params、output_params 在 SKILL.md frontmatter 和 skill.json 中都必须是“参数对象数组”，禁止写成 { params: {...} }、{input_path: {...}} 或任何对象映射形状；每个参数必须独立占一个数组元素。command：可选，显式命令；缺省时根据 script.path 和输入参数生成。script：可选对象，支持 path、content、source；也可用 scripts 列表生成多个脚本。script / scripts：在回调式沉淀链路中，优先从之前成功运行的脚本、流程文件或实现产物恢复，而不是重新凭空编写。references：可选列表，支持 path + content 或 source。assets：可选列表，支持 path + content 或 source；icon 会复制为 assets/icon.png。无论是否提供自定义 icon，都必须在生成时明确一个兜底图标方案，默认可回退到分类图标。dependencies：可选，正文依赖列表。examples：可选，正文示例列表。core_features、trigger_conditions、processing_logic、supported_formats、output_structure、output_examples：可选，填入通用模板对应章节。body_sections：可选，自定义正文段落。skill_json：可选，默认 true；设为 false 时不生成 skill.json。metadata：可选；若来自回调式沉淀链路，可用于记录流程来源、验证摘要、沉淀时间或回调上下文。rewrite_followup_hint：可选；用于在生成结果中覆盖默认的改写 follow-up 提示语。
命令 python scripts/generate_piflow_skill.py --spec path/to/spec.json
也可以显式传 --output-root skills：
python scripts/generate_piflow_skill.py --spec path/to/spec.json --output-root skills
如果是从一次已经跑通的成功流程回调式沉淀 skill，也可以直接传流程摘要：
python scripts/generate_piflow_skill.py --flow path/to/flow-summary.json --restored-spec-out path/to/restored-spec.json --output-root skills
若 skill 已生成完成，且用户随后提供了新的流程作为改写指引：
python scripts/rewrite_piflow_skill.py --skill-dir skills/<skill-name> --flow path/to/new-flow-summary.json --restored-spec-out artifacts/rewrite-spec.json
references/rewrite_followup_internal.md
python scripts/generate_piflow_skill.py --spec path/to/spec.json --overwrite
python scripts/generate_skill_files.py --spec path/to/spec.json --output-root skills
若只想把成功流程恢复为 draft spec 再人工检查：
python scripts/restore_flow_to_spec.py --flow path/to/flow-summary.json --output path/to/restored-spec.json
python scripts/generate_skill_files.py --flow path/to/flow-summary.json --restored-spec-out path/to/restored-spec.json --output-root skills
python scripts/register_skill_artifacts.py --spec path/to/spec.json --skill-dir skills/<skill-name>
若当前只有成功流程摘要，也可以直接在注册时恢复 spec：
python scripts/register_skill_artifacts.py --flow path/to/flow-summary.json --restored-spec-out path/to/restored-spec.json --skill-dir skills/<skill-name>
python scripts/validate_piflow_skill.py skills/<skill-name>
python scripts/validate_piflow_skill.py skills/<skill-name> --mode files-only
Spec 示例 {
"name" : "clean_example_transformer" ,
"title" : "Clean Example Transformer" ,
"description" : "清理文本中的示例片段。" ,
"version" : "1.0.0" ,
"triggers" : [ "清理示例" , "删除示例片段" ] ,
"tag" : "数据清洗" ,
"language" : "python" ,
"input_params" : [
{ "name" : "input_path" , "role" : "input_data" , "type" : "string" , "required" : true , "description" : "输入 JSON 文件路径" } ,
{ "name" : "output_path" , "role" : "output_data" , "type" : "string" , "required" : true , "description" : "输出 JSON 文件路径" }
] ,
"output_params" : [
{ "name" : "output_path" , "role" : "output_data" , "type" : "json_file" , "description" : "清理后的 JSON 文件" }
] ,
"script" : {
"path" : "scripts/run_clean_example_transformer.py" ,
"content" : "import argparse\n\n# TODO: implement operator\n"
} ,
"command_template" : [ "python" , "{script_path}" , "--input_path" , "{input_path}" , "--output_path" , "{output_path}" ] ,
"references" : [
{ "path" : "references/rules.md" , "content" : "# 清理规则\n\n- 删除示例片段。" }
] ,
"dependencies" : [ "Python 3.x" ] ,
"examples" : [
{
"title" : "基本调用" ,
"command" : "python scripts/run_clean_example_transformer.py --input_path input.json --output_path output.json"
}
]
}
必要的测试
<workspace>/skills/<name>/SKILL.md 可被 PiFlow 发现；在 deepagent 环境中不要生成到其他根目录。name 与目录名一致，description 包含触发语义。暴露机器可读的 version、tag、input_params 和 output_params。
生成的 skill.json 包含 entrypoint、script_path、command_template 和带 role 的参数元数据。
正文足够让另一个 agent 调用或继续实现技能，不依赖隐含上下文。
长规则没有塞进正文，而是放入 references/ 并在正文指明何时读取。
脚本、JSON和 Markdown 都能 UTF-8 往返，中文不转义、不乱码。
可执行脚本已明确生成、复制或有意省略。
技能通过 validate_piflow_skill.py。
需要运行时依赖的技能，在环境就绪后已完成一次轻量冒烟测试。
安装或测试失败时已进行重试；若达到 5 次仍失败，则已向用户反馈明确错误。
触发表达已经改写为“仅手动指定或任务完成后沉淀”语义，没有把本技能写成默认优先入口。
如果 skill 生成后用户又提供了新的成功流程，已考虑是否提示进入内部改写链路继续做最小改写。
如果 skill 声明了报告文件或类似结果工件，则失败路径也已实测验证：脚本会优先落盘最小失败摘要和问题清单，再以非零状态码结束，而不是未经兜底直接抛异常退出。
失败路径可观测性约束 复盘结论：对于会生成报告文件或其他结果工件的 skill，不能只设计成功路径；失败路径也必须可观测、可追溯。入口脚本应优先捕获异常、尽可能落盘最小失败摘要与问题清单，明确失败步骤、原因和上下文，再以非零状态码结束；不要在核心流程中未经兜底地直接抛出异常后退出。
若 spec 定义了摘要、问题清单、报告或其他结果工件，脚本必须同时实现成功和失败两条输出路径。
strict_mode 或其他失败条件触发时，不应在关键失败产物尚未落盘前直接中断。若只能生成部分结果，也应先写出部分结果，并在失败摘要中标明失败阶段、最后一次错误和未完成项。
不要记录以下内容（这些会变成长期存在的自我约束，并在环境变化后反过来带来影响）：
环境相关故障：缺失二进制文件、全新安装错误、迁移后路径不匹配、command not found、未配置凭据、未安装软件包等。用户可以修复这些问题，它们不是持久规则。
关于工具或功能的负面断言：如“浏览器工具无法工作”、“X 工具已损坏”、“远程资源不包含 Y”等。这些会固化成长期拒绝理由，即使实际问题早已被修复。
会话中已经解决的临时错误。如果重试后成功了，应记录重试模式，而不是原始失败。
一次性任务叙述。用户要求“总结今天的市场”或“分析这个 PR”，并不构成一个值得创建技能的工作类别。
自测引导 除 validate_piflow_skill.py 外，生成中等及以上复杂度 skill 时，至少执行以下自测：
语法检查：对入口脚本和内部模块运行 python -m py_compile ...，先排除最基础的语法问题。
正常样例测试：准备一组最小有效输入，实跑入口脚本，确认关键输出工件全部实际生成，并核对 summary 与核心报告内容。
失败样例测试：故意缺少关键输入、配置或依赖，再运行一次，确认脚本返回非零状态码，同时仍能落盘最小失败摘要和问题清单。
输出核对：检查 skill.json 中声明的关键输出参数，在正常路径和失败路径下都能找到对应产物，或至少有明确的失败说明。
严格模式核对：若存在 strict_mode，必须额外做一次 strict_mode 实测，确认它改变的不只是退出码，还包括完整的失败可观测行为。
