用途:根据实时 schema 生成可用于生产的 Kestra Flow YAML,并支持修改、扩展与调试现有流程。
主要能力:从零生成流程;修改或调试已有 YAML;把工作流描述翻译为有效 Kestra YAML。生成时仅使用 schema 中明确定义的 task 类型与属性,不臆造类型或属性名;保留根级 id 与 namespace;修改请求只改动相关部分;按需添加触发器,未明确要求周期性执行时不加 Schedule 触发器;集合重复用 ForEach,条件循环用 LoopUntil;跨执行状态检测用 KV 任务;JDBC 任务设置 fetchType: STORE;日期运算用 dateAdd 与 date 过滤器,数值比较前加 | number;不硬编码密钥,使用 SECRET 输入或 {{ secret('MY_SECRET') }};优先公共 API,不假设本地端口。
使用方式:先执行 curl -s https://api.kestra.io/v1/plugins/schemas/flow 拉取完整 schema 并直接读取原始 JSON,不要通过解释器管道处理;在 schema 可用前不生成内容。随后从用户消息中收集 id、namespace、现有 YAML 及操作类型(新增/删除/修改/重写)。输出仅原始 YAML,无说明文字、无 Markdown 围栏,可在顶部用 # 注释写注意事项,并可直接粘贴到 Kestra UI 或通过 kestractl 部署。若无法仅用 schema 定义的类型和属性完成请求,输出固定语句:I cannot generate a valid Kestra Flow YAML for this request based on the available schema.
适用场景:按小时抓取公共 API 并写入 KV 存储;为现有流程添加任务失败时的 Slack 通知;在 prod.data 命名空间读取 Postgres 并写入 S3;调试触发器变量引用不存在的 YAML。
限制:必须依赖实时 schema;不得编造类型或属性;触发器输出只能使用其声明的输出变量;仅当用户明确要求返回执行值时才包含流程级 outputs;未提供的信息(如具体插件清单、收费与平台细节)暂未提供。