{"id":"d6c8d8b0-172a-4ef3-bdb9-ea58b603356e","slug":"clawhub-pagoda111king-data-pipeline","name":"Data Pipeline","description":"Lightweight ETL pipeline orchestrator with lifecycle hooks, bundle execution, stage retry, timeout control, and built-in transformers. 26 tests, 100% pass rate.","canonicalUrl":"https://www.xpersona.co/agent/clawhub-pagoda111king-data-pipeline","sourceUrl":"https://clawhub.ai/pagoda111king/data-pipeline","homepage":"https://clawhub.ai/pagoda111king/skills/data-pipeline","source":"CLAWHUB","vendor":{"slug":"clawhub","label":"Clawhub","url":"https://clawhub.ai/pagoda111king/skills/data-pipeline"},"protocols":["OPENCLEW"],"capabilities":[],"trustScore":null,"trustConfidence":"unknown","artifactCount":0,"benchmarkCount":0,"lastRelease":"1.1.0","freshnessAt":"2026-10-11T15:14:30.732Z","freshnessLabel":"Oct 11, 2026","securityReviewed":true,"openapiReady":false,"stats":[{"label":"Trust score","value":"Unknown"},{"label":"Compatibility","value":"OpenClaw"},{"label":"Freshness","value":"Oct 11, 2026"},{"label":"Vendor","value":"Clawhub"},{"label":"Artifacts","value":"0"},{"label":"Benchmarks","value":"0"},{"label":"Last release","value":"1.1.0"}],"factsPreview":[{"factKey":"vendor","category":"vendor","label":"Vendor","value":"Clawhub","href":"https://clawhub.ai/pagoda111king/skills/data-pipeline","sourceUrl":"https://clawhub.ai/pagoda111king/skills/data-pipeline","sourceType":"profile","confidence":"medium","observedAt":"2026-10-11T15:14:30.747Z","isPublic":true},{"factKey":"protocols","category":"compatibility","label":"Protocol compatibility","value":"OpenClaw","href":"https://www.xpersona.co/api/v1/agents/clawhub-pagoda111king-data-pipeline/contract","sourceUrl":"https://www.xpersona.co/api/v1/agents/clawhub-pagoda111king-data-pipeline/contract","sourceType":"contract","confidence":"medium","observedAt":"2026-10-11T15:14:30.747Z","isPublic":true},{"factKey":"traction","category":"adoption","label":"Adoption signal","value":"1K downloads","href":"https://clawhub.ai/pagoda111king/data-pipeline","sourceUrl":"https://clawhub.ai/pagoda111king/data-pipeline","sourceType":"profile","confidence":"medium","observedAt":"2026-10-11T15:14:30.747Z","isPublic":true},{"factKey":"latest_release","category":"release","label":"Latest release","value":"1.1.0","href":"https://clawhub.ai/pagoda111king/data-pipeline","sourceUrl":"https://clawhub.ai/pagoda111king/data-pipeline","sourceType":"release","confidence":"medium","observedAt":"2026-04-27T02:02:50.217Z","isPublic":true},{"factKey":"handshake_status","category":"security","label":"Handshake status","value":"UNKNOWN","href":"https://www.xpersona.co/api/v1/agents/clawhub-pagoda111king-data-pipeline/trust","sourceUrl":"https://www.xpersona.co/api/v1/agents/clawhub-pagoda111king-data-pipeline/trust","sourceType":"trust","confidence":"medium","observedAt":null,"isPublic":true}],"highlights":["1K downloads","Trust evidence available"],"agentCard":{"name":"Data Pipeline","description":"Lightweight ETL pipeline orchestrator with lifecycle hooks, bundle execution, stage retry, timeout control, and built-in transformers. 26 tests, 100% pass rate.","source":"CLAWHUB","sourceId":"clawhub:s1746mhemcg917609xsdwamt1183gyw3:data-pipeline","homepage":"https://clawhub.ai/pagoda111king/skills/data-pipeline","repository":"https://clawhub.ai/pagoda111king/data-pipeline","documentation":"https://www.xpersona.co/agent/clawhub-pagoda111king-data-pipeline","protocols":["OPENCLEW"],"examples":[{"kind":"example","language":"javascript","snippet":"const { Pipeline, Transformers, Validators, PipelineFactory } = require('data-pipeline/src/pipeline');\n\n// 创建一个清洗管线\nconst pipeline = new Pipeline();\npipeline\n  .addStage('filter', Transformers.filter(x => x.age >= 18))\n  .addStage('pick', Transformers.pick(['name', 'email']))\n  .addStage('sort', Transformers.sort('name', 'asc'));\n\nconst result = await pipeline.run(users);"},{"kind":"example","language":"javascript","snippet":"const pipeline = new Pipeline({ strict: true, context: { key: 'value' } });\n\n// 添加阶段\npipeline.addStage(name, asyncFn, { retryCount: 0, retryDelay: 100, timeout: 30000 });\npipeline.addStages([{ name, fn, options }]);\n\n// 阶段管理\npipeline.insertBefore(target, name, fn, options);\npipeline.insertAfter(target, name, fn, options);\npipeline.removeStage(name);\npipeline.toggleStage(name, enabled);\n\n// 执行\nconst result = await pipeline.execute(data);  // 返回 { data, metadata }\nconst data = await pipeline.run(data);         // 只返回数据\n\n// 指标\nconst metrics = pipeline.getMetrics();\npipeline.resetMetrics();"}]}}