EFH

• DolphinDB Server: 2.00.10 及更高版本，支持 Linux x86-64。

1. 在 DolphinDB 客户端中使用 listRemotePlugins 命令查看插件仓库中的插件信息。

   注意：仅展示当前操作系统和 server 版本支持的插件。若无预期插件，可自行编译（请自行选择对应分支下的插件）或在 DolphinDB 用户社区进行反馈。

   login("admin", "123456")
   listRemotePlugins()

2. 使用 installPlugin 命令完成插件安装。

   installPlugin("EFH")

3. 使用 loadPlugin 命令加载插件。

   loadPlugin("EFH")

语法

EFH::createHandle(configPath, handleName, [options])

详情

创建 EFH 句柄。

返回一个 EFH 句柄，用于订阅、取消订阅、连接和关闭。EFH 连接句柄不能重名。

参数

configPath STRING 类型标量，表示 EFH 行情配置文件路径。

警告：如果使用 efvi 模式，且配置的网卡不适配，在 connect 时可能会导致盛立的 SDK crash，在使用前务必确保配置文件中的网卡信息正确。

handleName STRING 类型标量，指定给该 EFH 句柄的名称。

options 一个字典, 类型为 (STRING, BOOL)，可选参数。其键支持 "outputRecvTime"，"outputElapsed"。其中：

• "outputRecvTime" 表示是否获取插件收到行情数据的时间戳。其指定为 dict (["outputRecvTime"], [true]) 时，getSchema获取的表结构中将包含插件收到行情数据的时间戳列。
• "outputElapsed" 表示是否获取 EFH 插件 接收数据处理的时延。其指定为 dict (["outputElapsed"], [true]) 时，getSchema获取的表结构中将包含插件收到行情数据的时延列时延的定义："EFH 回调函数返回数据" 到 "准备写入到共享流表前" 这段时间。

语法

EFH::getSchema(handle, market, dataType)

详情

获取行情数据的表结构。

返回一个表，包含三列：name，typeString 和 typeInt，分别表示该行情表各个字段的名称，类型名和类型枚举值。可以通过该表来创建具有相同结构的共享流表。

如果在 createHandle中指定了 options，在返回的 schema 中会增加对应的列：

• 如果指定了 outputRecvTime 为 true，则会增加一个 NANOTIMESTAMP 类型列 receivedTime。
• 如果指定了 outputElapsed 为 true，则会增加一个 LONG 类型列 perPenetrationTime。

参数

handle createHandle 返回的连接句柄。

market STRING 类型标量，需要订阅的的市场名称，可以为 "EFH_SSE_LEV2" 表示上交所，"EFH_SZE_LEV2" 表示深交所。

dataType STRING 类型标量，表示行情数据类型：

• 深交所可取以下值："afterClose"，"snapshot"，"order"，"execution"，"index"，"tree"，"ibrTree"，"turnover"，"bondSnapshot"，"bondOrder"，"bondExecution"。
• 上交所可取以下值："snapshot"，"order"，"execution"，"index"，"tree"，"option"，"bondSnapshot"，"bondTick"，"mergeTick"。

语法

EFH::subscribe(handle, outputTable, market, dataType)

详情

订阅具体的行情数据。

注意： EFH 插件是在连接建立前进行订阅，连接建立后无法进行订阅。

参数

handle createHandle 返回的连接句柄。

outputTable 一个共享流表，作为行情数据输出的目标表。流表的结构必须与 getSchema 返回的结构相同。

market STRING 类型标量，需要订阅的的市场名称，可以为 "EFH_SSE_LEV2" 表示上交所，"EFH_SZE_LEV2" 表示深交所。

dataType STRING 类型标量，表示行情数据类型：

• 深交所可取以下值："afterClose"，"snapshot"，"order"，"execution"，"index"，"tree"，"ibrTree"，"turnover"，"bondSnapshot"，"bondOrder"，"bondExecution"。
• 上交所可取以下值："snapshot"，"order"，"execution"，"index"，"tree"，"option"，"bondSnapshot"，"bondTick"，"mergeTick"。

语法

EFH::unsubscribe(handle, market, dataType)

详情

取消订阅具体的行情数据。

参数

handle createHandle 返回的连接句柄。

market STRING 类型标量，需要订阅的的市场名称，可以为 "EFH_SSE_LEV2" 表示上交所，"EFH_SZE_LEV2" 表示深交所。

dataType STRING 类型标量，表示行情数据类型：

• 深交所可取以下值："afterClose"，"snapshot"，"order"，"execution"，"index"，"tree"，"ibrTree"，"turnover"，"bondSnapshot"，"bondOrder"，"bondExecution"。
• 上交所可取以下值："snapshot"，"order"，"execution"，"index"，"tree"，"option"，"bondSnapshot"，"bondTick"，"mergeTick"。

语法

EFH::connect(handle)

详情

建立与 EFH 行情服务器之间的连接，开始接收行情数据。

参数

handle createHandle 返回的连接句柄。

语法

EFH::close(handle)

详情

关闭一个 EFH 连接句柄，在 close 之后还可以通过接口 getStatus 查看状态。

参数

handle createHandle 返回的连接句柄

语法

EFH::delete(handle)

详情

删除一个 EFH 连接句柄，在 delete 之后将无法再次连接。

参数

handle createHandle 返回的连接句柄

语法

EFH::getHandle(handleName)

详情

通过句柄名称，获取已经创建的 EFH 句柄。

参数

handleName STRING 类型标量，指定给该 EFH 句柄的名称

语法

EFH::getStatus(handle)

详情

获取对应 EFH 句柄已订阅数据的状态信息。

返回一个表格，包含各种已订阅数据的状态信息，不包含未订阅过的数据类型

参数

handle createHandle 返回的连接句柄。

语法

EFH::getHandleStatus()

详情

获取本节点所有 EFH 句柄的状态信息。

返回一个表格，包含各个 handle 的信息

参数

无