实时 MEV、小费和奖励：使用 Bitquery API 构建生产级的验证者仪表盘

实时交易小费数据正成为以太坊验证者监控中最重要的组成部分之一。验证者收入的很大一部分现在来自执行层的小费和 MEV，这些都在每个区块中直接支付。对于质押运营商、机构和分析平台而言，实时跟踪这些小费对于理解性能、收益率和网络行为至关重要。

然而，访问实时的验证者和质押数据在技术上具有挑战性。运行自己的信标节点和执行节点、维护存储、解析余额更新以及流式传输实时事件需要大量的基础设施和工程资源。

Bitquery’s real-time Ethereum staking APIs 移除这种复杂性，无需运行自有节点或索引器，即可即时获取验证者余额、奖励事件、MEV 交易小费及区块性能数据。

本文探讨了以太坊验证者监控的工作原理，实时小费数据的重要性，以及 Bitquery 的 API 栈如何使您能够在几分钟而不是几个月内构建专业级的质押仪表盘。

目录

1. 概述：以太坊质押数据的挑战

2. 理解以太坊验证者监控

3. Bitquery 质押 API 架构

4. staking-rewards-api：简化的以太坊质押数据访问

5. 构建生产级质押仪表盘

6. 真实世界用例

7. 快速入门指南

8. 对比分析：传统方法 vs. 基于 API 的方法

9. 验证者监控的未来

10. 参考文献

概述：以太坊质押数据的挑战

自从合并到权益证明（Proof of Stake）以来，以太坊质押生态系统呈指数级增长。随着超过 100 万个验证者保障网络安全以及数十亿美元被质押，对复杂的验证者监控工具的需求变得至关重要。然而，访问实时质押数据带来了重大的技术挑战：

传统方法的问题：

• 基础设施复杂性：运行信标链节点和执行层节点需要大量资源

• 数据索引开销：解析原始区块链数据以跟踪验证者小费在计算上是昂贵的

• 实时流式传输：为实时质押更新实现 WebSocket 连接需要复杂的工程

• 维护负担：保持基础设施与网络升级同步需要持续关注

Bitquery 的以太坊实时质押 API 通过提供对验证者数据、交易小费和余额变化的生产级访问，解决了这些挑战，且无需基础设施开销。

//

Figure 1: Landing Page of the staking dashboard

在线演示: https://staking-dashboard-self-beta.vercel.app/

理解以太坊验证者监控

什么是以太坊质押?

以太坊质押涉及锁定 32 ETH 成为验证者，参与网络共识，并赚取验证者奖励。质押机制包括：

1. 共识层 (信标链): 管理验证者注册、证明和区块提议

2. 执行层: 处理交易和智能合约

3. 验证者职责: 提议区块、为区块作证、参与同步委员会

关键质押指标

有效的质押监控需要跟踪多个数据点：

• 验证者余额变化: 跟踪每个 epoch 的前余额和后余额

• 区块奖励: 监控区块提议的奖励（原因码 2）

• 交易小费/MEV: 跟踪区块构建者赚取的优先费（原因码 5）

• 提款：监控信标链提款（原因码 3）

• 性能指标：计算 APR、正常运行时间和错过的证明

实时质押数据的重要性

对于质押池运营商和机构验证者而言，实时数据能够：

• 性能优化：立即识别表现不佳的验证者

• 收益透明：为质押者提供准确、最新的收益数据

• 风险管理：在验证者问题影响回报之前检测到它们

• 竞争分析：与顶级验证者进行性能基准比较

Bitquery 质押 API 架构

核心组件

Bitquery 的以太坊验证者跟踪系统由三个主要组件构成：

1. Transaction Balance Tracker API

验证者监控的基础是 Bitquery 提供的 GraphQL API 和 WebSocket 流，例如：

subscription {
  EVM(network: eth) {
    TransactionBalances(
      where: { TokenBalance: { BalanceChangeReasonCode: { in: [2, 3, 5] } } }
    ) {
      Block {
        Time
        Number
      }
      TokenBalance {
        Address
        PreBalance
        PostBalance
        BalanceChangeReasonCode
        PostBalanceInUSD
      }
      Transaction {
        Hash
      }
    }
  }
}

2. 余额变化原因码

通过标准化代码理解验证者奖励类型:

• 代码2: BalanceIncreaseRewardMineBlock - 区块提议奖励

• 代码 3: BalanceIncreaseWithdrawal - 信标链提款

• 代码 5: BalanceIncreaseRewardTransactionFee - 交易小费 (MEV 奖励)

3. 通过 WebSocket 进行实时流式传输

对于实时质押仪表盘更新，Bitquery 提供了 WebSocket 订阅：

const ws = new WebSocket('wss://streaming.bitquery.io/graphql');

ws.send(JSON.stringify({
  type: 'start',
  payload: {
    query: `subscription { ... }`
  }
}));

ws.onmessage = (event) => {
  const reward = JSON.parse(event.data);
  console.log('New validator reward:', reward);
};

构架图 ┌─────────────────────────────────────────────────────────┐ │ Ethereum Network │ │ (Consensus Layer + Execution Layer) │ └────────────────────┬────────────────────────────────────┘ │ ▼ ┌─────────────────────────────────────────────────────────┐ │ Bitquery Indexing Layer │ │ • Beacon Chain Data │ │ • Transaction Balances │ │ • Validator Rewards │ │ • MEV Data │ └────────────────────┬────────────────────────────────────┘ │ ▼ ┌───────── ────────────────────────────────────────────────┐ │ Bitquery GraphQL API + WebSocket │ │ • Query Historical Data │ │ • Stream Real-Time Updates │ │ • Aggregate Metrics │ └────────────────────┬────────────────────────────────────┘ │ ▼ ┌─────────────────────────────────────────────────────────┐ │ staking-rewards-api (npm Package) │ │ • Simplified JavaScript Interface │ │ • Connection Management │ │ • Error Handling │ └────────────────────┬────────────────────────────────────┘ │ ▼ ┌─────────────────────────────────────────────────────────┐ │ Your Staking Dashboard Application │ │ • Validator Monitoring │ │ • Pool Analytics │ │ • Reward Tracking │ └─────────────────────────────────────────────────────────┘

**

staking-rewards-api: 简化的以太坊质押数据访问

包概述

The staking-rewards-api npm 包将 Bitquery 复杂的 GraphQL 查询封装成一个简单、对开发者友好的 JavaScript SDK，用于加密质押应用。

NPM 包: https://www.npmjs.com/package/staking-rewards-api
GitHub 仓库: https://github.com/Kshitij0O7/staking-rewards-api 

安装

npm install staking-rewards-api

核心功能

1. 顶级验证者查询

跟踪任何时间段内收入最高的验证者:

import { getTopValidatorsETH, getValidatorRewardsETH, runValidatorRewardsStreamETH } from 'staking-rewards-api';

// Get top 10 validators from last 24 hours
const topValidators = await getTopValidatorsETH({
  process.env.BITQUERY_TOKEN,
  limit: 10,
  hours: 24
});

console.log(topValidators);

2. 验证者奖励历史

检索任何以太坊验证者的全面奖励历史:

// Get specific validator's rewards
const validatorData = await getValidatorRewardsETH({
  token: process.env.BITQUERY_TOKEN,
  address: '0x4838b106fce9647bdf1e7877bf73ce8b0bad5f97',
  hours: 168 // Last week
});

console.log(validatorData);

3. 实时验证者流式传输

通过实时 WebSocket 更新监控验证者，用于验证者监控：

// Stream rewards for a specific validator
runValidatorRewardsStreamETH(
  process.env.BITQUERY_TOKEN,
  '0x4838b106fce9647bdf1e7877bf73ce8b0bad5f97',
  (reward) => {
    console.log('New reward received:', reward);
  }
);

// Stream all network validator rewards
runAllValidatorRewardsStreamETH(
process.env.BITQUERY_TOKEN,
(reward) => {
  console.log('Network reward:', reward);
});

API 设计理念

该包为以太坊质押开发者遵循以下原则：

1. 简单性: 复杂的 GraphQL 查询隐藏在简单的函数调用之后

2. 类型安全: 包含完整的 TypeScript 定义

3. 错误处理：自动重试逻辑和连接管理

4. 性能：为频繁访问的数据内置缓存

5. 灵活性：支持自定义查询和过滤器

构建一个生产级质押仪表盘

仪表盘架构

我们的参考质押仪表盘演示了真实世界的实现：

在线演示: https://staking-dashboard-self-beta.vercel.app/
GitHub 仓库: https://github.com/Kshitij0O7/staking-dashboard 

技术栈

前端:

├── Next.js 14 (App Router)

├── React 18

├── Tailwind CSS

└── TypeScript

后端:

├── Next.js API Routes

├── staking-rewards-api

└── WebSocket/Server-Sent Events

部署:

└── Vercel (Production)

关键功能实现

1. 顶级验证者排行榜

显示收入最高的验证者并实时更新:

Source Code for Top Validators API Calling

Source Code for Validators Dashboard Page UI

2. 实时验证者流

实时奖励跟踪，用于全面的质押监控:

Source Code for Streaming for All Validator Rewards

Source Code for Widget Showing All Live Validator Updates

3. 验证者详情页

深入了解单个验证者奖励:

Source Code for Individual Validator Details Page

4. 监控验证者组件

通过实时更新跟踪特定的验证者：

Source Code for Monitor Wallet Widget

安全最佳实践

实现安全的加密货币质押仪表盘：

// .env.local
BITQUERY_TOKEN=ory_at_********************************

// Server-side only - never exposed to client
// app/api/dashboard/route.ts
const token = process.env.BITQUERY_TOKEN;

if (!token) {
  throw new Error('BITQUERY_TOKEN not configured');
}

真实世界用例

1. 质押池运营

挑战: 质押池需要监控数百个验证者，并向质押者提供透明的报告。

Bitquery 解决方案:

// Monitor a list of pool validators
const poolValidators = [
  '0x1234...',
  '0x5678...',
  // ... 500+ validators
];

// Get aggregate pool performance
const poolStats = await Promise.all(
  poolValidators.map(address => 
   getMultipleValidatorRewards({ process.env.BITQUERY_TOKEN, address, hours: 24 })
  )
);

const totalPoolRewards = poolStats.reduce(
  (sum, validator) => sum + validator.totalRewardsETH,
  0
);

console.log(`Pool earned ${totalPoolRewards} ETH in 24h`);

优势:

• 跨所有验证者的实时性能跟踪

• 透明的奖励分配

• 为质押者提供自动化报告

• 及早发现表现不佳的验证者

2. 验证者性能分析

挑战: 研究人员和分析师需要关于验证者经济学和 MEV 分布的全面数据。

Bitquery 解决方案:

// Analyze MEV distribution across validators
const topValidators = await getTopValidators({
  process.env.BITQUERY_TOKEN,
  limit: 100,
  hours: 168 // 7 days
});

const mevAnalysis = topValidators.map(validator => ({
  address: validator.address,
  mevShare: validator.totalTips / validator.totalRewardsETH,
  averageTipPerBlock: validator.totalTips / validator.blockProposals
}));

// Find validators with highest MEV efficiency
const topMEVValidators = mevAnalysis
  .sort((a, b) => b.mevShare - a.mevShare)
  .slice(0, 10);

优势:

• 全面的验证者经济学研究

• MEV 分布分析

• 网络健康监控

• 竞争情报 

3. 机构质押者的投资组合跟踪

挑战: 机构投资者需要对跨多个验证者和质押池的质押头寸进行统一视图。

Bitquery 解决方案:

// Track institution's entire staking portfolio
const institutionValidators = [
  { address: '0xabc...', allocation: 1000 }, // ETH staked
  { address: '0xdef...', allocation: 2500 },
  { address: '0x789...', allocation: 500 }
];

// Get portfolio performance
const portfolioPerformance = await Promise.all(
  institutionValidators.map(async (v) => {
    const rewards = await getValidatorRewards({
      process.env.BITQUERY_TOKEN,
      address: v.address,
      hours: 720 // 30 days
    });

    return {
      address: v.address,
      allocation: v.allocation,
      totalRewardsETH: rewards.totalRewardsETH,
      apr: (rewards.totalRewardsETH / v.allocation) * 12 * 100
    };
  })
);

// Calculate weighted average APR
const totalAllocation = institutionValidators.reduce(
  (sum, v) => sum + v.allocation, 0
);

const weightedAPR = portfolioPerformance.reduce(
  (sum, v) => sum + (v.apr * v.allocation / totalAllocation),
  0
);

console.log(`Portfolio APR: ${weightedAPR.toFixed(2)}%`);

优势:

• 统一的投资组合视图

• 按验证者进行性能归因

• 加权 APR 计算

• 为利益相关者提供自动化报告

快速入门指南

在本地运行质押仪表盘应用的分布指南。

先决条件

• 已安装Node.js 18+ 

• Bitquery API 令牌 (Get token here)

• JavaScript/TypeScript 基础知识

步骤 1: 安装包

npm install staking-rewards-api

步骤2: 配置 API 令牌

# .env.local
BITQUERY_TOKEN=your_token_here

步骤 3: 运行仪表盘

1. 克隆仪表盘仓库:

git clone https://github.com/Kshitij0O7/staking-dashboard
cd staking-dashboard

2. 安装依赖

npm install

3. 配置环境

echo "BITQUERY_TOKEN=your_token_here" > .env

4. 本地运行

   npm run dev

   对比分析：传统方法 vs. 给予 API 的方法

基础设施要求

开发比较

传统比较:

// Complex setup required
const Web3 = require('web3');
const BeaconChainAPI = require('beacon-chain-api');

// Connect to self-hosted nodes
const web3 = new Web3('http://localhost:8545');
const beacon = new BeaconChainAPI('http://localhost:5052');

// Manual balance tracking
async function getValidatorRewards(validatorIndex) {
  // Query beacon chain
  const validator = await beacon.getValidator(validatorIndex);
  const balances = await beacon.getBalances([validatorIndex]);

  // Query execution layer
  const withdrawalAddress = validator.withdrawal_credentials;
  const ethBalance = await web3.eth.getBalance(withdrawalAddress);

  // Manual calculation of rewards
  const rewards = calculateRewards(balances, ethBalance);

  return rewards;
}

Bitquery API 方法:

import { getValidatorRewards } from 'staking-rewards-api';

// Simple, production-ready
const rewards = await api.getValidatorRewards({
  process.env.BITQUERY_TOKEN,
  address: '0x4838b106fce9647bdf1e7877bf73ce8b0bad5f97',
  hours: 24
});

功能比较

验证者监控的未来

以太坊质押的新兴趋势

1. 分布式验证者技术 (DVT)

• 多运营商验证者以提高弹性

• 需要跨运营商节点的聚合监控

• 增强的罚没风险管理

3. 再质押协议 (EigenLayer)

• 超越以太坊共识的额外奖励流

• 复杂的收益归因要求

• 多协议监控需求

5. MEV 演进

• PBS (提议者-构建者分离) 优化

• 跨域 MEV 机会

• 增强的透明度要求

7. 法规遵从

• 用于税务目的的自动化报告

• 验证者操作证明

• 审计跟踪要求

Bitquery 路线图整合

staking-rewards-api包旨在支持这些趋势：

• 多链支持: 从以太坊扩展到其他 PoS 网络

• 高级分析: 基于机器学习的性能预测

• 自定义警报: 针对验证者事件的可配置通知

• 增强的 MEV 数据: 详细的 MEV 策略分析

• 再质押集成: 支持 EigenLayer 及类似协议

结论

构建生产级的以太坊质押监控工具不再需要庞大的区块链基础设施。Bitquery 的 API，结合 staking-rewards-api SDK 和参考质押仪表盘，提供了所需的一切，以：

• 实时监控验证者奖励

• 跟踪质押池性能

• 构建透明的收益归因系统

• 创建机构级的验证者监控平台

无论您是运营质押池、构建 DeFi 协议，还是进行区块链研究，这个技术栈都能提供从原型到生产可扩展的加密货币质押数据基础设施。

开始使用:

• 📦 NPM Package

• 🔗 Live Dashboard

• 💻 GitHub Repository

• 📚 Bitquery Documentation

• 🎫 Get API Token