StreamTpslUpdates gRPC Method

请注意，此方法的计费是根据数据消耗量计算的，按 0.0165 MB = 10 个 API 积分 进行计费。

参数

coins

repeated string

正在加载...

退货

流

stream<TpslUpdatesUpdate>

正在加载...

时间

uint64

正在加载...

高度

uint64

正在加载...

snapshot

bool

正在加载...

diffs

array<TpslOrderDiff>

正在加载...

请求

1
// StreamTpslUpdates Example - Stream TP/SL trigger-order updates via gRPC
2
包 main
3

4
import (
5
	"上下文"
6
	“flag”
7
	"fmt"
8
	"io"
9
	“日志”
10
	"数学"
11
	“字符串”
12
	“时间”
13

14
	"google.golang.grpc"
15
	"google.golang.grpc"
16
	"google.golang.grpc"
17
	"google.golang.grpc"
18
	"google.golang.grpc"
19

20
	pb "hyperliquid"
21
)
22

23
const (
24
	grpcEndpoint = "endpoint.mainnet.quiknode.pro:10000"
25
	authToken    = "您的认证令牌"
26
	maxRetries   = 10
27
	baseDelay    = 2 * time.秒
28
)
29

30
func streamTpslUpdates(coins []string) error {
31
	fmt.PrintlnPrintln字符串.重复("=", 60))
32
	fmt.Printf("Streaming TP/SL Updates for %s\n", strings.Join(coins, ", "))
33
	fmt.Println("自动重连：true")
34
	fmt.PrintlnPrintln字符串.重复("=", 60) + "\n")
35

36
	retryCount := 0
37

38
	for retryCount < maxRetries {
39
		creds := 凭证.NewClientTLSFromCert(nil, "")
40
		conn, err := grpc.Dial(grpcEndpoint,
41
			grpc.WithTransportCredentials(creds)，
42
			grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(100*1024*1024)))
43
		如果 err != nil {
44
			返回 fmt.Errorf("连接失败：%w", err)
45
		}
46

47
		client := pb.NewOrderBookStreamingClient(conn)
48
		ctx := 元数据.AppendToOutgoingContext(context.背景(), “x-token”, authToken)
49

50
		request := &pb.TpslUpdatesRequest{
51
			Coins: coins,
52
		}
53

54
		if retryCount > 0 {
55
			fmt.Printf("\n🔄 正在重新连接（尝试 %d/%d）...\n", retryCount+1, maxRetries)
56
		} else {
57
			fmt.Printf("正在连接到 %s...\n", grpcEndpoint)
58
		}
59

60
		stream, err := client.StreamTpslUpdates(ctx, request)
61
		如果 err != nil {
62
			conn.关闭()
63
			返回 fmt.Errorf("启动流失败：%w", err)
64
		}
65

66
		msgCount := 0
67
		shouldRetry := false
68

69
		用于 {
70
			更新， err := 流.Recv()
71
			如果 err == io.EOF {
72
				换行
73
			}
74
			如果 err != nil {
75
				st， 好的 := 状态.FromError(err)
76
				如果 好的 && st.代码() == 代码.DataLoss {
77
					fmt.Printf("\n⚠️  服务器已重新初始化：%s\n", st.消息())
78
					retryCount++
79
					if retryCount < maxRetries {
80
						延迟 := baseDelay * time.Duration(数学.Pow(2, float64(重试次数-1)))
81
						fmt.Printf("⏳ 等待 %v 后再重新连接……\n", 延迟)
82
						时间.睡眠(延迟)
83
						shouldRetry = true
84
						换行
85
					} else {
86
						fmt.Printf("\n❌ 达到最大重试次数 (%d)。放弃。\n", maxRetries)
87
						conn.关闭()
88
						返回 nil
89
					}
90
				}
91
				conn.关闭()
92
				返回 fmt.Errorf("流错误：%w", err)
93
			}
94

95
			msgCount++
96
			如果 msgCount == 1 {
97
				fmt.Println("✓ First TP/SL update received!\n")
98
				retryCount = 0 // 成功后重置
99
			}
100

101
			// Display update
102
			fmt.Println("\n" + 字符串.重复("─", 60))
103
			snapshotLabel := ""
104
			if update.Snapshot {
105
				snapshotLabel = " | SNAPSHOT"
106
			}
107
			fmt.Printf("Block: %d | Time: %d%s | Diffs: %d\n", update.Height, update.Time, snapshotLabel, len(update.Diffs))
108
			fmt.PrintlnPrintln字符串.重复("─", 60))
109

110
			for _, diff := range update.Diffs {
111
				side := "ASK"
112
				if diff.Side == "B" {
113
					side = "BID"
114
				}
115
				sz := diff.Sz
116
				if diff.IsPositionTpsl {
117
					sz = "position-sized"
118
				}
119

120
				switch diff.DiffType {
121
				case pb.TpslDiffType_TPSL_DIFF_TYPE_ADD:
122
					fmt.Printf("  ADD    %s oid: %d | %s | %s sz: %s\n", diff.Coin, diff.Oid, diff.OrderType, side, sz)
123
					fmt.Printf("         trigger: %s | limit px: %s | reduce-only: %t\n", diff.TriggerCondition, diff.LimitPx, diff.ReduceOnly)
124
				case pb.TpslDiffType_TPSL_DIFF_TYPE_REMOVE:
125
					fmt.Printf("  REMOVE %s oid: %d | %s | reason: %s\n", diff.Coin, diff.Oid, diff.OrderType, diff.Reason)
126
				}
127
			}
128

129
			fmt.Printf("\n  已接收消息：%d\n", msgCount)
130
		}
131

132
		conn.关闭()
133

134
		如果 !shouldRetry {
135
			换行
136
		}
137
	}
138

139
	返回 nil
140
}
141

142
func main() {
143
	coinsFlag := flag.String("coins", "ETH", "Comma-separated coin symbols to stream (e.g., ETH,BTC)")
144

145
	flag.解析()
146

147
	coins := strings.Split(*coinsFlag, ",")
148

149
	fmt.Println("\n" + 字符串.重复("=", 60))
150
	fmt.Println("Hyperliquid StreamTpslUpdates Example")
151
	fmt.Printf("Endpoint：%s\n", grpcEndpoint)
152
	fmt.PrintlnPrintln字符串.重复("=", 60))
153

154
	if err := streamTpslUpdates(coins); err != nil {
155
		log.致命(err)
156
	}
157
}
158

1
// StreamTpslUpdates Example - Stream TP/SL trigger-order updates via gRPC
2
包 main
3

4
import (
5
	"上下文"
6
	“flag”
7
	"fmt"
8
	"io"
9
	“日志”
10
	"数学"
11
	“字符串”
12
	“时间”
13

14
	"google.golang.grpc"
15
	"google.golang.grpc"
16
	"google.golang.grpc"
17
	"google.golang.grpc"
18
	"google.golang.grpc"
19

20
	pb "hyperliquid"
21
)
22

23
const (
24
	grpcEndpoint = "endpoint.mainnet.quiknode.pro:10000"
25
	authToken    = "您的认证令牌"
26
	maxRetries   = 10
27
	baseDelay    = 2 * time.秒
28
)
29

30
func streamTpslUpdates(coins []string) error {
31
	fmt.PrintlnPrintln字符串.重复("=", 60))
32
	fmt.Printf("Streaming TP/SL Updates for %s\n", strings.Join(coins, ", "))
33
	fmt.Println("自动重连：true")
34
	fmt.PrintlnPrintln字符串.重复("=", 60) + "\n")
35

36
	retryCount := 0
37

38
	for retryCount < maxRetries {
39
		creds := 凭证.NewClientTLSFromCert(nil, "")
40
		conn, err := grpc.Dial(grpcEndpoint,
41
			grpc.WithTransportCredentials(creds)，
42
			grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(100*1024*1024)))
43
		如果 err != nil {
44
			返回 fmt.Errorf("连接失败：%w", err)
45
		}
46

47
		client := pb.NewOrderBookStreamingClient(conn)
48
		ctx := 元数据.AppendToOutgoingContext(context.背景(), “x-token”, authToken)
49

50
		request := &pb.TpslUpdatesRequest{
51
			Coins: coins,
52
		}
53

54
		if retryCount > 0 {
55
			fmt.Printf("\n🔄 正在重新连接（尝试 %d/%d）...\n", retryCount+1, maxRetries)
56
		} else {
57
			fmt.Printf("正在连接到 %s...\n", grpcEndpoint)
58
		}
59

60
		stream, err := client.StreamTpslUpdates(ctx, request)
61
		如果 err != nil {
62
			conn.关闭()
63
			返回 fmt.Errorf("启动流失败：%w", err)
64
		}
65

66
		msgCount := 0
67
		shouldRetry := false
68

69
		用于 {
70
			更新， err := 流.Recv()
71
			如果 err == io.EOF {
72
				换行
73
			}
74
			如果 err != nil {
75
				st， 好的 := 状态.FromError(err)
76
				如果 好的 && st.代码() == 代码.DataLoss {
77
					fmt.Printf("\n⚠️  服务器已重新初始化：%s\n", st.消息())
78
					retryCount++
79
					if retryCount < maxRetries {
80
						延迟 := baseDelay * time.Duration(数学.Pow(2, float64(重试次数-1)))
81
						fmt.Printf("⏳ 等待 %v 后再重新连接……\n", 延迟)
82
						时间.睡眠(延迟)
83
						shouldRetry = true
84
						换行
85
					} else {
86
						fmt.Printf("\n❌ 达到最大重试次数 (%d)。放弃。\n", maxRetries)
87
						conn.关闭()
88
						返回 nil
89
					}
90
				}
91
				conn.关闭()
92
				返回 fmt.Errorf("流错误：%w", err)
93
			}
94

95
			msgCount++
96
			如果 msgCount == 1 {
97
				fmt.Println("✓ First TP/SL update received!\n")
98
				retryCount = 0 // 成功后重置
99
			}
100

101
			// Display update
102
			fmt.Println("\n" + 字符串.重复("─", 60))
103
			snapshotLabel := ""
104
			if update.Snapshot {
105
				snapshotLabel = " | SNAPSHOT"
106
			}
107
			fmt.Printf("Block: %d | Time: %d%s | Diffs: %d\n", update.Height, update.Time, snapshotLabel, len(update.Diffs))
108
			fmt.PrintlnPrintln字符串.重复("─", 60))
109

110
			for _, diff := range update.Diffs {
111
				side := "ASK"
112
				if diff.Side == "B" {
113
					side = "BID"
114
				}
115
				sz := diff.Sz
116
				if diff.IsPositionTpsl {
117
					sz = "position-sized"
118
				}
119

120
				switch diff.DiffType {
121
				case pb.TpslDiffType_TPSL_DIFF_TYPE_ADD:
122
					fmt.Printf("  ADD    %s oid: %d | %s | %s sz: %s\n", diff.Coin, diff.Oid, diff.OrderType, side, sz)
123
					fmt.Printf("         trigger: %s | limit px: %s | reduce-only: %t\n", diff.TriggerCondition, diff.LimitPx, diff.ReduceOnly)
124
				case pb.TpslDiffType_TPSL_DIFF_TYPE_REMOVE:
125
					fmt.Printf("  REMOVE %s oid: %d | %s | reason: %s\n", diff.Coin, diff.Oid, diff.OrderType, diff.Reason)
126
				}
127
			}
128

129
			fmt.Printf("\n  已接收消息：%d\n", msgCount)
130
		}
131

132
		conn.关闭()
133

134
		如果 !shouldRetry {
135
			换行
136
		}
137
	}
138

139
	返回 nil
140
}
141

142
func main() {
143
	coinsFlag := flag.String("coins", "ETH", "Comma-separated coin symbols to stream (e.g., ETH,BTC)")
144

145
	flag.解析()
146

147
	coins := strings.Split(*coinsFlag, ",")
148

149
	fmt.Println("\n" + 字符串.重复("=", 60))
150
	fmt.Println("Hyperliquid StreamTpslUpdates Example")
151
	fmt.Printf("Endpoint：%s\n", grpcEndpoint)
152
	fmt.PrintlnPrintln字符串.重复("=", 60))
153

154
	if err := streamTpslUpdates(coins); err != nil {
155
		log.致命(err)
156
	}
157
}
158

1
// StreamTpslUpdates Example - Stream TP/SL trigger-order updates via gRPC
2
const grpc = require(grpc);
3
const protoLoader = require(grpc);
4
const 路径 = require('path');
5

6
const GRPC = endpoint.mainnet.quiknode.pro:10000';
7
const AUTH_TOKEN = '您的认证令牌';
8
const PROTO_PATH = 路径.join(__dirname, 'proto', 'orderbook.proto');
9

10
const 包定义 = protoLoader.loadSync(PROTO_PATH, {
11
  keepCase: true,
12
  多头: 字符串,
13
  枚举: 字符串,
14
  默认值: true,
15
  oneofs: true
16
});
17
const proto = grpc.loadPackageDefinition(packageDefinition).hyperliquid;
18

19
函数 createClient() {
20
  返回 new proto.OrderBookStreaming(
21
    GRPC,
22
    grpc.凭据.createSsl(),
23
    { 'grpc.max_receive_message_length': 100 * 1024 * 1024 }
24
  );
25
}
26

27
// Stream TP/SL trigger-order updates
28
async function streamTpslUpdates(coins, autoReconnect = true, retryCount = 0) {
29
  控制台.日志('='.重复(60));
30
  console.log(`Streaming TP/SL Updates for ${coins.length > 0 ? coins.join(', ') : 'all perp coins'}`);
31
  console.log(`Auto-reconnect: ${autoReconnect}`);
32
  控制台.日志('='.重复(60) + '\n');
33

34
  const maxRetries = 10;
35
  const baseDelay = 2000;
36

37
  while (retryCount < maxRetries) {
38
    const 客户端 = createClient();
39
    const 元数据 = new grpc.元数据();
40
    元数据.添加('x-token', AUTH_TOKEN);
41

42
    const 请求 = {
43
      coins: coins
44
    };
45

46
    试一试 {
47
      如果 (retryCount > 0) {
48
        console.log(`\n🔄 Reconnecting (attempt ${retryCount + 1}/${maxRetries})...`);
49
      } else {
50
        console.log(`Connecting to ${GRPC_ENDPOINT}...`);
51
      }
52

53
      let msgCount = 0;
54
      const call = client.StreamTpslUpdates(request, metadata);
55

56
      call。在('data', (更新) => {
57
        msgCount++;
58

59
        如果 (msgCount === 1) {
60
          console.log('✓ First TP/SL update received!\n');
61
          retryCount = 0; // 成功后重置
62
        }
63

64
        控制台.日志('\n' + '─'.重复(60));
65
        console.log(`Block: ${update.height} | Time: ${update.time}${update.snapshot ? ' | SNAPSHOT' : ''} | Diffs: ${(update.diffs || []).length}`);
66
        控制台.日志('─'.重复(60));
67

68
        (update.diffs || []).forEach(diff => {
69
          const side = diff.side === 'B' ? 'BID' : 'ASK';
70
          const sz = diff.is_position_tpsl ? 'position-sized' : diff.sz;
71

72
          if (diff.diff_type === 'TPSL_DIFF_TYPE_ADD') {
73
            console.log(`  ADD    ${diff.coin} oid: ${diff.oid} | ${diff.order_type} | ${side} sz: ${sz}`);
74
            console.log(`         trigger: ${diff.trigger_condition} | limit px: ${diff.limit_px} | reduce-only: ${diff.reduce_only}`);
75
          } else if (diff.diff_type === 'TPSL_DIFF_TYPE_REMOVE') {
76
            console.log(`  REMOVE ${diff.coin} oid: ${diff.oid} | ${diff.order_type} | reason: ${diff.reason}`);
77
          }
78
        });
79

80
        console.log(`\n  Messages received: ${msgCount}`);
81
      });
82

83
      call。在('error', (err) => {
84
        如果 (err.代码 === grpc.状态.数据丢失 && 自动重连) {
85
          console.log(`\n⚠️  Server reinitialized: ${err.message}`);
86
          retryCount++;
87
          if (retryCount < maxRetries) {
88
            const 延迟 = baseDelay * Math.pow(2, retryCount - 1);
89
            console.log(`⏳ Waiting ${delay / 1000}s before reconnecting...`);
90
            setTimeout(() => streamTpslUpdates(coins, autoReconnect, retryCount), delay);
91
          } else {
92
            console.log(`\n❌ Max retries (${maxRetries}) reached. Giving up.`);
93
          }
94
        } else {
95
          控制台.错误('\ngRPC 错误：', err.code, '-', err.message);
96
        }
97
      });
98

99
      call。在('end', () => {
100
        控制台.日志('\n流已结束');
101
      });
102

103
      // Wait for stream to complete
104
      等待 new Promise((决心) => {
105
        call。在('end', resolve);
106
        call。在('error', resolve);
107
      });
108

109
      换行; // 成功后退出重试循环
110

111
    } catch (err) {
112
      控制台.错误('错误：', err.message);
113
      换行;
114
    }
115
  }
116
}
117

118
// Parse command line args
119
const args = process.argv.slice(2);
120
const coins = (args.find(a => a.startsWith('--coins='))?.split('=')[1] || 'ETH').split(',');
121

122
控制台.日志('\n' + '='.重复(60));
123
console.log('Hyperliquid StreamTpslUpdates Example');
124
console.log(`Endpoint: ${GRPC_ENDPOINT}`);
125
控制台.日志('='.重复(60));
126

127
streamTpslUpdates(coins);
128

1
// StreamTpslUpdates Example - Stream TP/SL trigger-order updates via gRPC
2
const grpc = require(grpc);
3
const protoLoader = require(grpc);
4
const 路径 = require('path');
5

6
const GRPC = endpoint.mainnet.quiknode.pro:10000';
7
const AUTH_TOKEN = '您的认证令牌';
8
const PROTO_PATH = 路径.join(__dirname, 'proto', 'orderbook.proto');
9

10
const 包定义 = protoLoader.loadSync(PROTO_PATH, {
11
  keepCase: true,
12
  多头: 字符串,
13
  枚举: 字符串,
14
  默认值: true,
15
  oneofs: true
16
});
17
const proto = grpc.loadPackageDefinition(packageDefinition).hyperliquid;
18

19
函数 createClient() {
20
  返回 new proto.OrderBookStreaming(
21
    GRPC,
22
    grpc.凭据.createSsl(),
23
    { 'grpc.max_receive_message_length': 100 * 1024 * 1024 }
24
  );
25
}
26

27
// Stream TP/SL trigger-order updates
28
async function streamTpslUpdates(coins, autoReconnect = true, retryCount = 0) {
29
  控制台.日志('='.重复(60));
30
  console.log(`Streaming TP/SL Updates for ${coins.length > 0 ? coins.join(', ') : 'all perp coins'}`);
31
  console.log(`Auto-reconnect: ${autoReconnect}`);
32
  控制台.日志('='.重复(60) + '\n');
33

34
  const maxRetries = 10;
35
  const baseDelay = 2000;
36

37
  while (retryCount < maxRetries) {
38
    const 客户端 = createClient();
39
    const 元数据 = new grpc.元数据();
40
    元数据.添加('x-token', AUTH_TOKEN);
41

42
    const 请求 = {
43
      coins: coins
44
    };
45

46
    试一试 {
47
      如果 (retryCount > 0) {
48
        console.log(`\n🔄 Reconnecting (attempt ${retryCount + 1}/${maxRetries})...`);
49
      } else {
50
        console.log(`Connecting to ${GRPC_ENDPOINT}...`);
51
      }
52

53
      let msgCount = 0;
54
      const call = client.StreamTpslUpdates(request, metadata);
55

56
      call。在('data', (更新) => {
57
        msgCount++;
58

59
        如果 (msgCount === 1) {
60
          console.log('✓ First TP/SL update received!\n');
61
          retryCount = 0; // 成功后重置
62
        }
63

64
        控制台.日志('\n' + '─'.重复(60));
65
        console.log(`Block: ${update.height} | Time: ${update.time}${update.snapshot ? ' | SNAPSHOT' : ''} | Diffs: ${(update.diffs || []).length}`);
66
        控制台.日志('─'.重复(60));
67

68
        (update.diffs || []).forEach(diff => {
69
          const side = diff.side === 'B' ? 'BID' : 'ASK';
70
          const sz = diff.is_position_tpsl ? 'position-sized' : diff.sz;
71

72
          if (diff.diff_type === 'TPSL_DIFF_TYPE_ADD') {
73
            console.log(`  ADD    ${diff.coin} oid: ${diff.oid} | ${diff.order_type} | ${side} sz: ${sz}`);
74
            console.log(`         trigger: ${diff.trigger_condition} | limit px: ${diff.limit_px} | reduce-only: ${diff.reduce_only}`);
75
          } else if (diff.diff_type === 'TPSL_DIFF_TYPE_REMOVE') {
76
            console.log(`  REMOVE ${diff.coin} oid: ${diff.oid} | ${diff.order_type} | reason: ${diff.reason}`);
77
          }
78
        });
79

80
        console.log(`\n  Messages received: ${msgCount}`);
81
      });
82

83
      call。在('error', (err) => {
84
        如果 (err.代码 === grpc.状态.数据丢失 && 自动重连) {
85
          console.log(`\n⚠️  Server reinitialized: ${err.message}`);
86
          retryCount++;
87
          if (retryCount < maxRetries) {
88
            const 延迟 = baseDelay * Math.pow(2, retryCount - 1);
89
            console.log(`⏳ Waiting ${delay / 1000}s before reconnecting...`);
90
            setTimeout(() => streamTpslUpdates(coins, autoReconnect, retryCount), delay);
91
          } else {
92
            console.log(`\n❌ Max retries (${maxRetries}) reached. Giving up.`);
93
          }
94
        } else {
95
          控制台.错误('\ngRPC 错误：', err.code, '-', err.message);
96
        }
97
      });
98

99
      call。在('end', () => {
100
        控制台.日志('\n流已结束');
101
      });
102

103
      // Wait for stream to complete
104
      等待 new Promise((决心) => {
105
        call。在('end', resolve);
106
        call。在('error', resolve);
107
      });
108

109
      换行; // 成功后退出重试循环
110

111
    } catch (err) {
112
      控制台.错误('错误：', err.message);
113
      换行;
114
    }
115
  }
116
}
117

118
// Parse command line args
119
const args = process.argv.slice(2);
120
const coins = (args.find(a => a.startsWith('--coins='))?.split('=')[1] || 'ETH').split(',');
121

122
控制台.日志('\n' + '='.重复(60));
123
console.log('Hyperliquid StreamTpslUpdates Example');
124
console.log(`Endpoint: ${GRPC_ENDPOINT}`);
125
控制台.日志('='.重复(60));
126

127
streamTpslUpdates(coins);
128

1
#!/usr/bin/env python3
2
"""
3
StreamTpslUpdates Example - Stream TP/SL trigger-order updates via gRPC
4

5
设置：
6
    pip install grpcio grpcio-tools protobuf zstandard
7
    python -mgrpc.protoc -I../../proto --python_out=.grpc. ../../proto/orderbook.proto
8

9
用法：
10
    python stream_tpsl_example.py --coins ETH,BTC
11
"""
12

13
import grpc
14
import sys
15
import 时间
16
import argparse
17

18
试一试：
19
    import orderbook_pb2 作为 pb
20
    import orderbook_pb2_grpc 为 pb_grpc
21
except ImportError:
22
    打印("错误：未生成 Proto 文件。请运行：")
23
    打印("  python -mgrpc.protoc -I../../proto --python_out=.grpc. ../../proto/orderbook.proto")
24
    sys.exit(1)
25

26
# 配置
27
GRPC= "endpoint.mainnet.quiknode.pro:10000"
28
AUTH_TOKEN = "您的认证令牌"
29

30

31
def stream_tpsl_updates(coins: list, auto_reconnect: bool = True):
32
    """
33
    Stream TP/SL trigger-order updates for one or more coins.
34

35
    参数：
36
        coins: Symbols to stream (e.g., ["ETH", "BTC"]). Empty list means all perp coins
37
        auto_reconnect：在发生 DATA_LOSS 错误时自动重新连接（默认值为 True）
38
    """
39
    打印(f"\n{'='*60}")
40
    print(f"Streaming TP/SL Updates for {', '.join(coins) if coins else 'all perp coins'}")
41
    print(f"Auto-reconnect: {auto_reconnect}")
42
    打印(f"{'='*60}\n")
43

44
    retry_count = 0
45
    max_retries = 10
46
    base_delay = 2
47

48
    while retry_count < max_retries:
49
        频道 = grpc.secure_channel(
50
           GRPC,
51
            grpc.ssl_channel_credentials(),
52
            选项=[
53
                (grpc.max_receive_message_length', 100 * 1024 * 1024),
54
                (grpc.keepalive_time_ms', 30000),
55
            ]
56
        )
57
        占位符 = pb_grpc.订单流存根(channel)
58

59
        # 构建请求
60
        request = pb.TpslUpdatesRequest(coins=coins)
61

62
        msg_count = 0
63

64
        试一试：
65
            如果 retry_count > 0:
66
                打印(f"\n🔄 正在重新连接（尝试 {重试次数 + 1}/{最大重试次数})...")
67
            else:
68
                打印(f"正在连接到 {GRPC}...")
69

70
            for update in stub.StreamTpslUpdates(request, metadata=[('x-token', AUTH_TOKEN)]):
71
                msg_count += 1
72

73
                如果 msg_count == 1:
74
                    print(f"✓ First TP/SL update received!\n")
75
                    retry_count = 0  # 连接成功后重置重试计数
76

77
                # Display the update
78
                打印(f"\n{'─'*60}")
79
                snapshot_label = " | SNAPSHOT" if update.snapshot else ""
80
                print(f"Block: {update.height} | Time: {update.time}{snapshot_label} | Diffs: {len(update.diffs)}")
81
                打印(f"{'─'*60}")
82

83
                for diff in update.diffs:
84
                    side = "BID" if diff.side == "B" else "ASK"
85
                    sz = "position-sized" if diff.is_position_tpsl else diff.sz
86

87
                    if diff.diff_type == pb.TPSL_DIFF_TYPE_ADD:
88
                        print(f"  ADD    {diff.coin} oid: {diff.oid} | {diff.order_type} | {side} sz: {sz}")
89
                        print(f"         trigger: {diff.trigger_condition} | limit px: {diff.limit_px} | reduce-only: {diff.reduce_only}")
90
                    elif diff.diff_type == pb.TPSL_DIFF_TYPE_REMOVE:
91
                        print(f"  REMOVE {diff.coin} oid: {diff.oid} | {diff.order_type} | reason: {diff.reason}")
92

93
                print(f"\n  Messages received: {msg_count}")
94

95
        除了 grpc。RpcError 作为 e:
96
            如果 e.代码() == grpc.状态码.DATA_LOSS 和 auto_reconnect：
97
                print(f"\n⚠️  Server reinitialized: {e.details()}")
98
                retry_count += 1
99
                if retry_count < max_retries:
100
                    延迟 = base_delay * (2 ** (重试次数 - 1))  # 指数退避
101
                    打印(f"⏳ 正在等待 {延迟}秒后重新连接...")
102
                    时间.sleep(延迟)
103
                    频道.关闭()
104
                    继续
105
                else:
106
                    打印(f"\n❌ 最大重试次数 ({max_retries}) 已达到。放弃。")
107
                    换行
108
            else:
109
                print(f"\ngRPC error: {e.code()} - {e.details()}")
110
                换行
111
        除了 KeyboardInterrupt:
112
            print("\nStopping TP/SL stream...")
113
            换行
114
        最后:
115
            频道.关闭()
116

117
        # 如果在此处未出现错误，则退出重试循环
118
        换行
119

120

121
def main():
122
    parser = argparse.ArgumentParser(description='Stream Hyperliquid TP/SL trigger-order updates via gRPC')
123
    parser.add_argument('--coins', default='ETH', help='Comma-separated coin symbols to stream (e.g., ETH,BTC)')
124

125
    args = 解析器.parse_args()
126
    coins = [c.strip() for c in args.coins.split(',') if c.strip()]
127

128
    打印(f"\n{'='*60}")
129
    print("Hyperliquid StreamTpslUpdates Example")
130
    print(f"Endpoint: {GRPC_ENDPOINT}")
131
    打印(f"{'='*60}")
132

133
    试一试：
134
        stream_tpsl_updates(coins)
135
    除 异常 作为 e:
136
        print(f"\nError: {e}")
137
        import traceback
138
        回溯.print_exc()
139
        sys.exit(1)
140

141

142
如果 __name__ == "__main__":
143
    主()
144

1
#!/usr/bin/env python3
2
"""
3
StreamTpslUpdates Example - Stream TP/SL trigger-order updates via gRPC
4

5
设置：
6
    pip install grpcio grpcio-tools protobuf zstandard
7
    python -mgrpc.protoc -I../../proto --python_out=.grpc. ../../proto/orderbook.proto
8

9
用法：
10
    python stream_tpsl_example.py --coins ETH,BTC
11
"""
12

13
import grpc
14
import sys
15
import 时间
16
import argparse
17

18
试一试：
19
    import orderbook_pb2 作为 pb
20
    import orderbook_pb2_grpc 为 pb_grpc
21
except ImportError:
22
    打印("错误：未生成 Proto 文件。请运行：")
23
    打印("  python -mgrpc.protoc -I../../proto --python_out=.grpc. ../../proto/orderbook.proto")
24
    sys.exit(1)
25

26
# 配置
27
GRPC= "endpoint.mainnet.quiknode.pro:10000"
28
AUTH_TOKEN = "您的认证令牌"
29

30

31
def stream_tpsl_updates(coins: list, auto_reconnect: bool = True):
32
    """
33
    Stream TP/SL trigger-order updates for one or more coins.
34

35
    参数：
36
        coins: Symbols to stream (e.g., ["ETH", "BTC"]). Empty list means all perp coins
37
        auto_reconnect：在发生 DATA_LOSS 错误时自动重新连接（默认值为 True）
38
    """
39
    打印(f"\n{'='*60}")
40
    print(f"Streaming TP/SL Updates for {', '.join(coins) if coins else 'all perp coins'}")
41
    print(f"Auto-reconnect: {auto_reconnect}")
42
    打印(f"{'='*60}\n")
43

44
    retry_count = 0
45
    max_retries = 10
46
    base_delay = 2
47

48
    while retry_count < max_retries:
49
        频道 = grpc.secure_channel(
50
           GRPC,
51
            grpc.ssl_channel_credentials(),
52
            选项=[
53
                (grpc.max_receive_message_length', 100 * 1024 * 1024),
54
                (grpc.keepalive_time_ms', 30000),
55
            ]
56
        )
57
        占位符 = pb_grpc.订单流存根(channel)
58

59
        # 构建请求
60
        request = pb.TpslUpdatesRequest(coins=coins)
61

62
        msg_count = 0
63

64
        试一试：
65
            如果 retry_count > 0:
66
                打印(f"\n🔄 正在重新连接（尝试 {重试次数 + 1}/{最大重试次数})...")
67
            else:
68
                打印(f"正在连接到 {GRPC}...")
69

70
            for update in stub.StreamTpslUpdates(request, metadata=[('x-token', AUTH_TOKEN)]):
71
                msg_count += 1
72

73
                如果 msg_count == 1:
74
                    print(f"✓ First TP/SL update received!\n")
75
                    retry_count = 0  # 连接成功后重置重试计数
76

77
                # Display the update
78
                打印(f"\n{'─'*60}")
79
                snapshot_label = " | SNAPSHOT" if update.snapshot else ""
80
                print(f"Block: {update.height} | Time: {update.time}{snapshot_label} | Diffs: {len(update.diffs)}")
81
                打印(f"{'─'*60}")
82

83
                for diff in update.diffs:
84
                    side = "BID" if diff.side == "B" else "ASK"
85
                    sz = "position-sized" if diff.is_position_tpsl else diff.sz
86

87
                    if diff.diff_type == pb.TPSL_DIFF_TYPE_ADD:
88
                        print(f"  ADD    {diff.coin} oid: {diff.oid} | {diff.order_type} | {side} sz: {sz}")
89
                        print(f"         trigger: {diff.trigger_condition} | limit px: {diff.limit_px} | reduce-only: {diff.reduce_only}")
90
                    elif diff.diff_type == pb.TPSL_DIFF_TYPE_REMOVE:
91
                        print(f"  REMOVE {diff.coin} oid: {diff.oid} | {diff.order_type} | reason: {diff.reason}")
92

93
                print(f"\n  Messages received: {msg_count}")
94

95
        除了 grpc。RpcError 作为 e:
96
            如果 e.代码() == grpc.状态码.DATA_LOSS 和 auto_reconnect：
97
                print(f"\n⚠️  Server reinitialized: {e.details()}")
98
                retry_count += 1
99
                if retry_count < max_retries:
100
                    延迟 = base_delay * (2 ** (重试次数 - 1))  # 指数退避
101
                    打印(f"⏳ 正在等待 {延迟}秒后重新连接...")
102
                    时间.sleep(延迟)
103
                    频道.关闭()
104
                    继续
105
                else:
106
                    打印(f"\n❌ 最大重试次数 ({max_retries}) 已达到。放弃。")
107
                    换行
108
            else:
109
                print(f"\ngRPC error: {e.code()} - {e.details()}")
110
                换行
111
        除了 KeyboardInterrupt:
112
            print("\nStopping TP/SL stream...")
113
            换行
114
        最后:
115
            频道.关闭()
116

117
        # 如果在此处未出现错误，则退出重试循环
118
        换行
119

120

121
def main():
122
    parser = argparse.ArgumentParser(description='Stream Hyperliquid TP/SL trigger-order updates via gRPC')
123
    parser.add_argument('--coins', default='ETH', help='Comma-separated coin symbols to stream (e.g., ETH,BTC)')
124

125
    args = 解析器.parse_args()
126
    coins = [c.strip() for c in args.coins.split(',') if c.strip()]
127

128
    打印(f"\n{'='*60}")
129
    print("Hyperliquid StreamTpslUpdates Example")
130
    print(f"Endpoint: {GRPC_ENDPOINT}")
131
    打印(f"{'='*60}")
132

133
    试一试：
134
        stream_tpsl_updates(coins)
135
    除 异常 作为 e:
136
        print(f"\nError: {e}")
137
        import traceback
138
        回溯.print_exc()
139
        sys.exit(1)
140

141

142
如果 __name__ == "__main__":
143
    主()
144

还没有账号吗？

endpoint 几秒钟endpoint 创建您的Quicknode endpoint ，并开始构建

免费开始使用