SuperAPI AI 工具集

build-data-pipeline

数据与分析

查看项目

更新于 10-16 08:46

技能介绍

用途:引导开发者构建 Solana 链上数据管道或索引器,覆盖数据摄取、转换与存储全流程,适用于索引器、数据分析与链上事件追踪等场景。

主要能力:支持通过 webhook、WebSocket、geyser 插件或 RPC 轮询进行实时事件流摄取;支持历史数据回填;账户状态索引;构建查询友好的存储;推荐使用 Helius 增强交易获取已解析数据。

使用方式:先检查 .superstack/build-context.md,若无则询问所需数据类型(交易、账户状态、代币转账、程序事件)及实时/历史需求,并写入上下文文件;随后参考 references/indexing-patterns.md 选择摄取方式、references/data-storage.md 设计存储模式;按里程碑实现摄取、解析器、数据库模式、写入路径与查询 API,先用 devnet 测试再切主网,最后监控摄取延迟并处理丢失事件。

快速开始示例: curl -X POST https://api-mainnet.helius-rpc.com/v0/webhooks?api-key=YOUR_KEY
-H 'Content-Type: application/json'
-d '{ "webhookURL": "https://your-app.com/webhook", "transactionTypes": ["TRANSFER"], "accountAddresses": ["YOUR_PROGRAM_ID"] }' WebSocket 方式可参考 solana logs <PROGRAM_ID> --url mainnet-beta 或 @solana/web3.js Connection.onLogs()。

限制与非硬性要求:需实现幂等写入以应对重复投递;必须包含回填机制;不应未经解析直接存储原始交易数据;建议用 Helius 增强交易代替原始 RPC;需存储 slot 以便排序与去重;需监控摄取延迟。数据库与托管选择(PostgreSQL/Redis/SQLite,Railway/Fly.io/AWS/GCP)依据实际需求,资料未给出统一推荐。该技能属于 Idea → Build → Launch 中的 Build 阶段,并包含遥测提示与事件上报流程。