SuperAPI AI 工具集

expanso-enforce-schema

数据与分析

查看项目

更新于 10-15 21:39

技能介绍

用途:该技能用于数据管道中的模式(Schema)校验,对每条记录进行验证,把不符合模式的无效记录写入死信队列,避免脏数据继续流入下游。

主要能力:提供模式校验与死信队列两项核心功能,无效记录不会被直接丢弃,而是被隔离保存以便后续检查。

使用方式:资料给出两种运行方式。运行示例数据可执行 ./run.sh;也可直接用 Expanso CLI 运行,命令为 expanso run -c pipeline.yaml。pipeline.yaml 中包含完整的 Expanso 配置。测试可执行 ./test.sh。

前置要求:需要安装 Expanso Edge,安装命令为 clawhub install expanso;并需配置所需凭据,具体环境变量见 pipeline.yaml。

适用场景:适合需要在数据进入处理流程前做质量把关、并保留无效记录用于审计或重处理的管道场景。

限制:资料未提供支持的具体模式格式、死信队列的存储位置与保留策略、性能指标及收费信息,这些内容暂未提供。