SuperAPI AI 工具集

fp

数据与分析

查看项目

更新于 10-15 22:17

技能介绍

用途:fp worker 在 worker 之间搬运批量数据,避免大值经由模型路由。fp::pipe 一次调用运行短管道:每步触发一个函数,结果写入下一步 payload 的 into(默认 /value);调用方只收到每步大小与预览,不返回值本身。十个 fp::* 变换对应 lodash 同名函数,从 value 取输入,作为管道步骤内联执行并向下传递变换后的值;其 { value } 包装仅在独立直接调用时出现(适合小值)。

主要能力:fp::pipe(through 步骤列表、preview_chars);fp::get/pick/omit(指针提取、键子集、键删除);fp::take/drop(字符串与数组的前 n/跳过 n);fp::map/filter/uniq(数组提取、部分对象匹配、去重);fp::split/join(字符串与数组互转);fp::size/nth(计数、按索引取元素,负数从末尾计);fp::getOr(带默认值的指针提取);fp::compact/flatten(去 null、展平一层);fp::sortBy/reverse(按指针稳定升序,空串表示元素本身;反转)。

使用方式:典型如 scrapling::fetch → fp::get {path: "/content"} → fp::take {n: 20000} → state::set 放在一个 fp::pipe 内;也可把大结果移入另一函数参数、在 worker 侧重塑列表、做 Top-N、用错误路径探测结果结构。

限制:管道步骤以 fp worker 权限运行,而非调用 agent 的逐步调度策略,故 fp::pipe 默认不可被 agent 调用(需批准),纯变换可以。被拒绝作为步骤的包括 shell::/coder::、触发器控制、嵌套管道及 agent 策略硬拒绝类;state::* 仍允许。第一步不接收传递值,需以生产者或 payload.value 起始。1–12 步,每总线步 120 秒,整条管道须符合调用方调度超时。类型不匹配会报错而非静默传递 {};map 在路径不匹配任何元素时报错。