data-pipelineLightweight ETL pipeline orchestrator with lifecycle hooks, bundle execution, stage retry, timeout control, and built-in transformers. 26 tests, 100% pass rate.
Install via ClawdBot CLI:
clawdbot install pagoda111king/data-pipelineGrade Fair — based on market validation, documentation quality, package completeness, maintenance status, and authenticity signals.
Calls external URL not in known-safe list
https://api.example.com/dataAudited Apr 26, 2026 · audit v1.0
Generated Oct 7, 2026
使用 Pipeline 的 filter、dedup、pick 等转换器对每日订单数据进行清洗，去除重复订单、过滤无效记录并提取关键字段。结合 Validators.schema 验证订单格式，确保下游分析的准确性。
通过 PipelineFactory.createETL 构建提取-转换-加载流程，从多个广告平台拉取数据后统一字段命名、聚合指标，最终加载到数据仓库生成 ROI 分析报表。支持 retryCount 与 timeout 选项处理不稳定的外部 API。
使用 Validators.schema 批量验证员工档案，检查邮箱格式、年龄范围与角色枚举，再通过 groupBy 与聚合函数按部门统计人数和平均薪资。错误报告直接反馈给 HR 团队修正数据。
利用 groupBy、reduce、sort 转换器对海量传感器读数按设备分组，计算均值、最大值等指标，并分页输出用于实时看板展示。PipelineError 中的 lastData 与 stageResults 便于快速定位异常设备。
对交易流水执行 schema 验证，结合自定义 validate 函数校验金额阈值与账户格式，过滤异常交易后合并多数据源。getMetrics 提供各阶段调用耗时，帮助满足审计与合规要求。
以订阅制提供在线数据管线搭建工具，用户通过可视化或代码方式组合转换器与验证器，无需自建基础设施。按处理数据量或管线数量分级收费。
为企业客户定制数据清洗、ETL 与验证方案，基于 data-pipeline 快速交付可维护的管线代码。包含架构设计、培训与后续维护合同。
核心库保持开源吸引开发者社区，企业版提供高级验证器、监控面板、优先支持与合规审计功能。通过授权费与技术支持实现盈利。
💬 Integration Tip
该库 API 设计直观、零外部依赖，可直接在 Node.js 项目中使用；建议从 PipelineFactory 的预设管线入手，逐步替换为自定义阶段以匹配业务需求。
Scored Oct 7, 2026
Automation skill for DELLIGHT CRO Revenue Operations.
Partnership outreach, market research, competitor analysis, and proposal generation. Transform your AI agent into a strategic business development partner that identifies and cultivates growth opportunities.
CRM integration, lead tracking, outreach automation, and pipeline management. Transform your AI agent into a sales assistant that never lets leads slip through the cracks.
Free cold outreach templates — 5 proven email formulas for B2B outreach. Generate personalized openers, follow-ups, and value props. Upgrade to Pro for autom...
使用卖家精灵数据在亚马逊上查找和分析竞品，覆盖12个站点，包含销量、BSR、定价、评分和增长趋势等商品指标。当用户提到竞品查询、竞品分析、ASIN反查、竞争商品研究、查找相似商品、市场竞品发现、商品对标、竞品销量估算、分析竞争Listing、competitor analysis, ASIN reverse lo...
ActiveCampaign CRM integration for lead management, deal tracking, and email automation. Use for syncing demo leads, managing clinic sales pipeline, and triggering follow-up sequences.