XTP Python Api 接口编译

下载xtp官方提供的python接口: https://github.com/ztsec/xtp_api_python

简单介绍一下各个文件夹的作用（虽然里面有文档介绍了）

bin: 编译好的python接口和对应的demo

doc: 编译文档

source: 编译用到的代码

XTP_API_20200824_2.2.25.5: cxx xtp 接口

因为我不喜欢官方对python api的命名，所以我要自己改，然后重新编译

准备工作

doc 文件夹里有对应操作系统的编译文档，虽然不是很详细，但是也能看懂

我差不多把所有的 Python Api 都给修改了

对于非回调函数，只需要修改其def的函数名即可，如果是回调函数，则需要将C++中对应的函数也给修改了，否则会找不到这个函数

编译 boost python

按照文档所说的，首先要编译一份 boost python，直接去boost官网下载最新的boost源码，然后只编译python版本的。

生成b2编译工具, 指定你python命令所在的路径, 如果你不知道的话可以用 where python 来找到

$ ./bootstrap.sh --with-libraries=/usr/bin/python3

然后编译.

toolset: 这里用的gcc，没试过可不可以用clang

include: 因为要用到Python.h，所以这里需要指定你在生成b2时设置的python对应的头文件路径，一般在你安装python的时候就会装好，如果没有装好，在ubuntu、debian系统你可以这样安装: sudo apt-get install python-dev -y

$ ./b2 --toolset=gcc-10.2.0 --with-python include="/usr/include/python3.9" --with-thread --with-date_time --with-chrono

不出意外就编译成功了，会在你stage文件夹里输出编译好的python lib

boost 这一步就算完成了

编译 xtp python

在 source 文件夹里有编译用到的源码，使用对应你系统版本的即可

编辑 `CMakeLists.txt` 修改几个地方

1、修改你python 的lib和头文件所在目录，和上面编译boost时设置的一致

# 设置Python所在的目录
set(PYTHON_LIBRARY /usr/local/python389/lib/)
set(PYTHON_INCLUDE_PATH /usr/local/python389/include/python3.8/)

2、然后是boost配置，主要修改boost所在路径(BOOST_ROOT) 以及boost的版本(如find_package中的1.75.0)，以及find_package中的python版本

# 链接boost库，anaconda /python3用的是python3.6没有用Anaconda
set(BOOST_ROOT )
set(Boost_USE_MULTITHREADED      ON)
set(BOOST_ROOT   /home/x2h1z/Downloads/boost_1_75_0_py389/)
find_package(Boost 1.75.0 COMPONENTS python3 thread date_time system chrono REQUIRED) # 如果boost库没有完全编译，需要将编译的库明确地指出，否者message(${Boost_LIBRARIES})会出错
if(Boost_FOUND)include_directories(${Boost_INCLUDE_DIRS})
endif()

修改完cmake后，然后就直接编译

$ mkdir build && cd build
$ cmake .. && make - -j 8

不出意外就会在lib文件夹中输出编译好的so

如果出意外了，那么就是find_package中python版本不对，或者你Boost版本不对之类的

反正就这几个地方，一个个检查就行了

测试

然后就写个demo测试一下

import os
import sys
import timefrom vnxtpquote import QuoteApiCONFIG = {"ip": "120.27.164.138","port": 6002,"user": "","password": "","local_ip": "0","socket_type": 1
}class MdApi(QuoteApi):def __init__(self):super(MdApi, self).__init__()def on_disconnected(self, error_id: int):passdef on_error(self, error_info: dict):passdef sub_market_data(self, symbols: list[dict], exchange_id: int):assert(exchange_id in [1, 2, 3])self.subscribe_market_data(symbols, len(symbols), exchange_id)def on_sub_market_data(self, ticker: dict, error_info: dict, is_last: bool):if error_info is None or error_info['error_id'] == 0:print(f"subscribe success tickers: {ticker}")else:print(f"subscribe error, id: {error_info['error_id']}, msg: {error_info['error_msg']}")def on_depth_market_data(self, data: dict, bid1_qty_list: list, bid1_counts: int, max_bid1_count: int,ask1_qty_list: int, ask1_count: int, max_ask1_count: int):print(data)if __name__ == '__main__':md_api = MdApi()md_api.create_quote_api(1, os.getcwd(), 4)# 设置心跳检测时间间隔，单位为秒md_api.set_heart_beat_interval(2)# 设置采用UDP方式连接时的接收缓冲区大小md_api.set_udp_buffer_size(128)# 使用UDP接收行情时，设置接收行情线程绑定的cpumd_api.set_udp_recv_thread_affinity(2)# 使用UDP接收行情时，设置解析行情线程绑定的cpumd_api.set_udp_parse_thread_affinity(2)# 设定UDP收行情时是否输出异步日志md_api.set_udp_seq_logout_put_flag(1)s = md_api.login(CONFIG['ip'], CONFIG['port'], CONFIG['user'], CONFIG['password'], CONFIG['socket_type'], CONFIG['local_ip'])if s != 0:print(f"login failed, status:{s}", end=", ")error = md_api.get_api_last_error()print("error: ", error)sys.exit(1)api_version = md_api.get_api_version()print(f"login success. api version: {api_version}")# 因为不明原因，合在一起订阅没收到推送的行情md_api.subscribe_market_data([{"ticker": "000300"}], 1, 1)md_api.subscribe_market_data([{"ticker": "399905"}], 1, 2)md_api.subscribe_market_data([{"ticker": "000016"}], 1, 1)# sleep为了删除接口对象前将回调数据输出，不sleep直接删除回调对象会自动析构，无法返回回调的数据try:while True:time.sleep(5)except:md_api.release()sys.exit(1)

你只需要把编译好的so放在demo.py一起即可

你可能会疑惑，为什么python可以import so，那是因为编译的时候使用到了Python.h

最后

blog: https://zckun.github.io/

公众号: the2hcode

Mail: zckuna@163.com