Rust智能合约开发库pyth-sdk的使用指南

概述

pyth-sdk是一个用于与Pyth网络价格预言机交互的Rust开发库。Pyth网络提供高精度、实时的金融市场数据，适用于区块链智能合约开发。该SDK使开发者能够轻松获取各种资产(加密货币、股票、外汇等)的最新价格信息。

主要功能

• 获取Pyth网络中的最新价格数据
• 解析Pyth价格账户数据
• 验证价格更新
• 支持Solana和EVM兼容链

安装方法

在Cargo.toml中添加依赖：

[dependencies]
pyth-sdk = "0.10.0"
solana-sdk = "1.14.0"  # 如果开发Solana程序需要添加

基本使用方法

1. 初始化客户端

use pyth_sdk_solana::{load_price_feed_from_account, PriceFeed};

// 从Solana账户加载价格数据
let price_account_data: &[u8] = ...; // 从链上获取的账户数据
let price_feed: PriceFeed = load_price_feed_from_account(price_account_data).unwrap();

2. 获取最新价格

// 获取当前价格
if let Some(current_price) = price_feed.get_current_price() {
    println!(
        "Price: {} ± {} ({} confidence)",
        current_price.price,
        current_price.confidence,
        current_price.publish_time
    );
}

3. 获取EMA(指数移动平均)价格

if let Some(ema_price) = price_feed.get_ema_price() {
    println!(
        "EMA Price: {} ± {}",
        ema_price.price,
        ema_price.confidence
    );
}

完整示例(Solana程序)

use pyth_sdk_solana::{load_price_feed_from_account, PriceFeed};
use solana_program::{
    account_info::AccountInfo,
    entrypoint,
    entrypoint::ProgramResult,
    msg,
    pubkey::Pubkey,
};

entrypoint!(process_instruction);

fn process_instruction(
    _program_id: &Pubkey,
    accounts: &[AccountInfo],
    _instruction_data: &[u8],
) -> ProgramResult {
    // 第一个账户是Pyth价格账户
    let pyth_price_account = &accounts[0];
    
    // 加载价格数据
    let price_f feed = load_price_feed_from_account(&pyth_price_account.data.borrow())
        .map_err(|e| {
            msg!("Failed to load price feed: {:?}", e);
            ProgramError::InvalidAccountData
        })?;
    
    // 获取当前价格
    if let Some(current_price) = price_feed.get_current_price() {
        msg!("Current price: {}", current_price.price);
        msg!("Confidence interval: ±{}", current_price.confidence);
        msg!("Last updated: {}", current_price.publish_time);
    } else {
        msg!("No current price available");
    }
    
    Ok(())
}

EVM链使用示例

use pyth_sdk::*;
use std::str::FromStr;

#[tokio::main]
async fn main() {
    // 初始化Pyth客户端
    let pyth = PythClient::new(
        "https://xc-mainnet.pyth.network".to_string(),
        "https://rpc.ankr.com/eth".to_string(),
    ).await.unwrap();
    
    // 获取ETH/USD价格ID
    let price_id = PriceIdentifier::from_str(
        "0xff61491a931112ddf1bd8147cd1b641375f79f5825126d665480874634fd0ace"
    ).unwrap();
    
    // 获取最新价格更新数据
    let price_update = pyth.get_price_update(&price_id).await.unwrap();
    
    println!("ETH/USD Price: {}", price_update.price.price);
    println!("Confidence: ±{}", price_update.price.confidence);
    println!("Exponent: {}", price_update.price.expo);
}

注意事项

1. 价格数据需要定期更新，确保使用最新数据
2. 检查价格置信区间，避免使用低质量数据
3. 处理价格不可用的情况
4. 考虑价格延迟问题
5. 在生产环境中添加适当的错误处理

进阶功能

• 订阅价格更新
• 批量获取多个价格对
• 验证价格更新签名
• 处理跨链价格数据

完整示例代码

Solana完整示例

use pyth_sdk_solana::{load_price_feed_from_account, PriceFeed};
use solana_program::{
    account_info::{AccountInfo, next_account_info},
    entrypoint,
    entrypoint::ProgramResult,
    msg,
    program_error::ProgramError,
    pubkey::Pubkey,
};

// 定义程序入口点
entrypoint!(process_instruction);

fn process_instruction(
    program_id: &Pubkey,
    accounts: &[AccountInfo],
    _instruction_data: &[u8],
) -> ProgramResult {
    // 获取账户迭代器
    let accounts_iter = &mut accounts.iter();
    
    // 获取Pyth价格账户
    let pyth_price_account = next_account_info(accounts_iter)?;
    
    // 验证程序ID
    if pyth_price_account.owner != program_id {
        msg!("Account does not have the correct program id");
        return Err(ProgramError::IncorrectProgramId);
    }
    
    // 加载价格数据
    let price_feed = load_price_feed_from_account(&pyth_price_account.data.borrow())
        .map_err(|e| {
            msg!("Failed to load price feed: {:?}", e);
            ProgramError::InvalidAccountData
        })?;
    
    // 获取当前价格
    if let Some(current_price) = price_feed.get_current_price() {
        msg!("Current price: {}", current_price.price);
        msg!("Confidence interval: ±{}", current_price.confidence);
        msg!("Last updated: {}", current_price.publish_time);
        
        // 获取EMA价格
        if let Some(ema_price) = price_feed.get_ema_price() {
            msg!("EMA Price: {}", ema_price.price);
            msg!("EMA Confidence: ±{}", ema_price.confidence);
        }
    } else {
        msg!("No current price available");
    }
    
    Ok(())
}

EVM完整示例

use pyth_sdk::{PythClient, PriceIdentifier, PriceUpdate};
use std::str::FromStr;
use tokio;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    // 初始化Pyth客户端
    let pyth = PythClient::new(
        "https://xc-mainnet.pyth.network".to_string(),
        "https://rpc.ankr.com/eth".to_string(),
    ).await?;
    
    // 定义要查询的价格对ID
    let price_ids = vec![
        // ETH/USD
        "0xff61491a931112ddf1bd8147cd1b641375f79f5825126d665480874634fd0ace",
        // BTC/USD
        "0xe62df6c8b4a85fe1a67db44dc12de5db330f7ac66b72dc658afedf0f4a415b43",
    ];
    
    // 批量获取价格更新
    for price_id_str in price_ids {
        let price_id = PriceIdentifier::from_str(price_id_str)?;
        
        match pyth.get_price_update(&price_id).await {
            Ok(price_update) => {
                println!("Price ID: {}", price_id_str);
                println!("Price: {}", price_update.price.price);
                println!("Confidence: ±{}", price_update.price.confidence);
                println!("Exponent: {}", price_update.price.expo);
                println!("Publish Time: {}", price_update.price.publish_time);
                println!("-----------------------------------");
            }
            Err(e) => {
                eprintln!("Failed to get price update for {}: {}", price_id_str, e);
            }
        }
    }
    
    Ok(())
}

以上示例展示了如何在Solana和EVM链上使用pyth-sdk获取价格数据。Solana示例是一个完整的智能合约程序，而EVM示例是一个命令行工具，可以查询多个价格对的数据。