为对接华泰 INSIGHT 行情服务软件,DolphinDB 开发了 INSIGHT 插件。通过该插件获取交易所的行情。
INSIGHT 插件目前支持版本:relsease200, release130。您当前查看的插件版本为 release200,请使用 DolphinDB 2.00.X 版本 server。若使用其它版本 server,请切换至相应插件分支。
注意:INSIGHT 插件仅支持 Linux 系统
注意: 编译之前请确保 libDolphinDB.so 在 gcc 可搜索的路径中。可使用 LD_LIBRARY_PATH 指定其路径,或者直接将其拷贝到 build 或 lib 目录下。
cd /path/to/PluginInsight
mkdir build && cd build
cmake ..
make
编译完成后,build 目录下将生成加载插件所需要的 libPluginInsight.so 文件。
加载插件前,需要将 cert 文件夹放到 dolphindb 可执行文件同目录下,执行以下命令:
cp -r /path_to_insight/include/cert /path_to_server/
export LD_LIBRARY_PATH=/path_to_insight/lib:$LD_LIBRARY_PATH
insight::connect(handles, ip, port, user, password, [workPoolThreadCount])
handles
:类型为 Dictionary,Dictionary 的键为'StockTick', 'IndexTick', 'FuturesTick', 'StockTransaction' 或 'StockOrder',值为 table。请注意,table 不能为 DFS 表。
ip
:服务器地址,类型为字符串标量。
port
:服务器端口,类型为整型标量。
user
:用户名,类型为字符串标量。
password
:密码,类型为字符串标量。
workPoolThreadCount
:可选,处理线程池的线程数,类型为整型标量,默认为 5。
注册消息接收接口并连接服务器,返回表示 tcpClient 的句柄。
insight::subscribe(tcpClient, marketDataTypes, securityIDSource, securityType)
tcpClient
:connect 的返回值。
marketDataTypes
:字符串向量,表示行情数据类型,支持以下值:'MD_TICK', 'MD_ORDER' 和 'MD_TRANSACTION'。
securityIDSource
:字符串标量,表示交易所类型,支持以下值:'XSHE', 'XSHG' 'CCFX', 'CSI'。
securityType
:字符串标量,表示产品类型,支持以下值:'StockType', 'IndexType', 'FuturesType'。
订阅数据,并将所订阅的数据保存在由 connect 的 handles 参数指定的表中。
insight::close(tcpClient)
tcpClient
:connect 的返回值。
关闭连接。
insight::close(tcpClient)
insight::getSchema(dataType)
dataType
:'StockTick', 'IndexTick', 'FuturesTick', 'StockTransaction' 或 'StockOrder'。
获取对应表结构。返回一个表,包含 name 和 type 两列。
insight::getStatus(tcpClient)
tcpClient
:connect 的返回值。
返回保存订阅信息的表,包含三列,分别是 marketType, securityIdSource 和 securityType。
insight::unsubscribe(tcpClient)
tcpClient
:connect 的返回值。
取消当前所有订阅。
- 加载插件
pluginFile = “path_to_insight/PluginInsight.txt”;
loadPlugin(pluginFile);
- 创建用于保存订阅数据的表
stockTickSchema = insight::getSchema(`StockTick);
share streamTable(10000:0, stockTickSchema[`name], stockTickSchema[`type]) as stockTickTable;
- 连接服务器
ip = "168.61.69.192";
port = 10317;
user = "mdc-flow-client-25-36";
password = "mdc-vss-shlv1";
handles = dict([`StockTick], [stockTickTable]);
tcpClient = insight::connect(handles, ip, port, user, password);
- 订阅
insight::subscribe(tcpClient, `MD_TICK`MD_ORDER`MD_TRANSACTION, `XSHG, `StockType);
- 取消订阅
insight::unsubscribe(tcpClient);
- 关闭连接
insight::close(tcpClient);
- 修复了在断网时取消订阅失败的问题。(2.00.10)
- 修复了在执行 insight::close 后,再次执行 insight::getStatus 时 server 宕机的问题。(2.00.10)
- 修复了当首次连接时输入错误密码,后续连接一直报错的问题。(2.00.10)