概览

pip install chainstream-sdk

go get github.com/chainstream-io/chainstream-go-sdk

# 添加到 Cargo.toml
[dependencies]
chainstream-sdk = "0.1"

from chainstream import ChainStreamClient
from chainstream.stream import Resolution

client = ChainStreamClient(access_token='YOUR_ACCESS_TOKEN')

# REST API 调用
token = await client.token.get_metadata('sol', 'TOKEN_ADDRESS')

# WebSocket 订阅
await client.stream.subscribe_token_candles(
    chain='sol',
    token_address='TOKEN_ADDRESS',
    resolution=Resolution.S1,
    callback=lambda data: print(data)
)

import chainstream "github.com/chainstream-io/chainstream-go-sdk"

client, _ := chainstream.NewChainStreamClient(accessToken, &chainstream.ChainStreamClientOptions{})

// REST API 调用
resp, _ := client.Token.GetToken(ctx, "sol", "TOKEN_ADDRESS")

// WebSocket 订阅
client.Stream.SubscribeTokenCandles("sol", "TOKEN_ADDRESS", token.N1s, func(data stream.TokenCandle) {
    fmt.Println(data)
}, "")

use chainstream_sdk::{ChainStreamClient, stream::{Resolution, TokenCandle}};

let client = ChainStreamClient::new("YOUR_ACCESS_TOKEN", None);

// WebSocket 订阅
client.stream.subscribe_token_candles(
    "sol",
    "TOKEN_ADDRESS",
    Resolution::X1s,
    |candle: TokenCandle| {
        println!("{:?}", candle);
    },
    None,
).await?;