行情连接池 API (实验阶段)

连接池API只针对特定的场景下使用,它还在非常早期的开发阶段

描述

它即可以在普通行情api上使用,也可以在扩展行情api中使用,它的基础的逻辑为: 我们需要提供一组ip,他们被划分为3类角色

  • 一个正在进行通讯的主连接 我们命名它为M
  • 一个热备选连接,它通过心跳包和备选服务器连接, 它为 H
  • 一组备选连接池,它们周期性的重拍顺序(可能是根据连接服务器的速度),始终准备替换上面两个连接。 我们命名它们为P

当主连接P的接口调用出现问题时,我们将:

  • 热备选连接H 转化为主连接M,重发主连接的请求
  • 从连接池P中选出最快的一个连接,重新成为热备选连接H, 并通过心跳包维持服务器的链接
  • 连接M回到备选连接池P中。

如此,保证我们的API请求的可靠性

例子:

from pytdx.hq import TdxHq_API
from pytdx.pool.ippool import AvailableIPPool
from pytdx.config.hosts import hq_hosts
import random
import logging
import pprint

ips = [(v[1], v[2]) for v in hq_hosts]
# 获取5个随机ip作为ip池
random.shuffle(ips)
ips5 = ips[:5]

## IP 池对象
ippool = AvailableIPPool(TdxHq_API, ips5)

## 选出M, H
primary_ip, hot_backup_ip = ippool.sync_get_top_n(2)

print("make pool api")
## 生成hqpool对象,第一个参数为TdxHq_API后者 TdxExHq_API里的一个,第二个参数为ip池对象。
api = TdxHqPool_API(TdxHq_API, ippool)

## connect 函数的参数为M, H 两组 (ip, port) 元组
with api.connect(primary_ip, hot_backup_ip):
    ## 这里的借口和对应TdxHq_API 或者 TdxExHq_API里的一样,我们通过反射调用正确的接口
    ret = api.get_xdxr_info(0, '000001')
    print("send api call done")
    pprint.pprint(ret)

results matching ""

    No results matching ""