2.00.10

amdQuote

新功能

  • 新增支持接收委托表(order)和成交表(trade )按交易所原始频道代码(ChannelNo)多线程异步写入 server 中的目标表。同一个原始频道代码的委托表和成交表将写入同一张表,且保证其写入顺序。

  • 接口 amdQuote::connect 新增支持参数 outputElapsed,用于统计插件内部的时延。

  • 新增支持订阅输出至非流数据表。

  • amdQuote398 插件支持 Linux X86-64 ABI=1 DolphinDB server。(2.00.10.12.1

故障修复

  • 修复在订阅一个错误市场后,无法使用 amdQuote::unsubscribe 取消该订阅的问题。

  • 修复了在长时间订阅后,行情数据偶现无法正确写入流数据表的问题。

AWSS3

功能优化

优化了 loadS3Object 对临时文件的处理方法。

故障修复

  • 接口 loadS3Object 增加对参数 threadCount 可用最大线程数的限制。

  • 接口 getS3Object 增加对参数 outputFileName 有效性的检查。

CTP

功能优化

  • 优化了部分报错信息,同时增加了一些捕获自第三方库函数调用异常的报错信息。

  • CTP 的连接优化为单例模式,用户在同一 DolphinDB 进程中只能连接一个 CTP 源。

  • 优化了输出表的字段类型,将 CTP 插件输出表中 TradingDay 的字段类型由 DT_STRING 更改为 DT_DATE。

EFH

首次发布,用于对接盛立 EFH 行情服务软件,将上交所和深交所的 Level-2 实时行情接入 DolphinDB。。(2.00.10.13

HBase

功能优化

增强了多线程并行时的稳定性。

故障修复

  • 避免下载数据时对非法格式的 minute 类型数据进行解析。

  • 修复在使用 hbase::load 导入 disable table 捕获到异常后未中止运行,导致后续 server 宕机的问题。

  • 增加下载数据时对 CHAR 类型数据的转换限制,若输入 string 值的长度超过1,则将返回空值。

  • 增加下载数据时对 SECOND 类型转换的检查。

  • 增加对连接有效性的检查。

  • connect 函数增加对参数 isFramed 非法输入值的检查。

HDF5

功能优化

优化接口 hdf5::saveHDF5 的报错信息。

故障修复

  • 修复使用方法 hdf5::ls 执行特定类型的 hdf5文件后 server 宕机的问题。

  • 修复并行导入多个文件时 server 宕机的问题。

HDFS

功能优化

  • connect 函数新增支持配置集群环境。

  • 优化部分报错信息。

故障修复

  • 修复对空文件夹调用 getListDirectory 时报错的问题。

  • 修复使用 readFile 循环读取文件时,由于未关闭文件句柄导致打开的文件句柄过多,进而导致 hadoop 数据节点不可用、连接断开无法继续读取文件的问题。

  • 修复了由于 connect 底层共用 hdfs 连接导致的函数行为混乱的问题。

httpClient

新功能

  • 增加对传入字典类型参数的校验。

  • 增加对待发送数据的字节长度的校检。

功能优化

  • 优化 sendEmail 函数的功能(2.00.10.16):

    • 新增可选参数 msg,支持填入完整的邮件正文信息。

    • subject, body 参数改为可选,同时将通过这两个参数发送的邮件正文中的换行符修改为标准换行符。

删除接口 httpCreateSubJob,httpCreateMultiParserSubJob,httpCancelSubJob,httpGetJobStat。

INSIGHT

故障修复

  • 修复了在断网时取消订阅失败的问题。

  • 修复了在执行 insight::close 后,再次执行 insight::getStatus 时 server 宕机的问题。

  • 修复了当首次连接时输入错误密码,后续连接一直报错的问题。

Kafka

功能优化

函数 eventGetParts , getOffsetPosition , getOffsetCommitted 增加了返回值。

故障修复

  • 修复了接口 kafka::pollByteStream 不能接收非 JSON 格式数据的问题。

  • 修复了多线程操作导致的 server 宕机问题。

kdb+

新功能

新增支持读取 kdb+ char 型 nested list。

故障修复

  • 修复调用 loadTable 时不指定参数 symPath 导致 server 宕机的问题。

  • 修复 loadTable 无法正确解析用户自定义 sym 文件名的问题。

  • 修复在关闭插件 kdb+的进程后,再次执行 loadTable 导致 server 宕机的问题。

mat

新功能

新增支持多线程读写 mat 文件。

故障修复

接口 mat::writeMat 新增对参数 varName 非法输入值的报错。

MongoDB

功能优化

  • 优化了部分报错信息。

  • 加强了 mongodb::aggregate, mongodb::load, mongodb::connect 的参数校检。

故障修复

  • [DPLG-3303] MongoDB 的浮点数转换为 DolphinDB 整型时,结果错误。(2.00.10.17)
  • [DPLG-3304] 在查询返回的数据里,若第一行的 oid 类型列的值为空,会导致 server 崩溃。(2.00.10.17)
  • [DPLG-3312] 在查询数据时,若某列的前 1024 行都是空值,会导致 server 崩溃。(2.00.10.17)

MQTT

新功能

  • 接口mqtt::connect 新增参数 sendbufSize,用于指定发送缓冲区的大小。(2.00.10.12

  • 接口 mqtt::subscribe 新增参数 recvbufSize,用于指定接收缓冲区的大小。(2.00.10.12

功能优化

优化了部分场景下的报错信息。

故障修复

  • 当 MQTT 服务器关闭时,通过 mqtt::connect 进行连接将收到错误提示。

  • 优化了 connect 函数中关于参数 batchsize 默认值的报错信息。

  • 修复了当 mqtt::publish, mqtt::createCsvFormatter 参数的输入值为 NULL 时可能出现的宕机或卡住的问题。

  • 修复了若发布消息中包含空值,订阅端无法接收到数据的问题。

  • 修复了若发布数据中包含类型为 CHAR, MONTH 数据时,订阅端会接收到错误类型数据的问题。

mseed

故障修复

  • 接口 mseed::write 新增对参数 startTime 非法输入值的报错。

  • 接口 mseed::parseStreamInfo 新增对非法数据或非法 SID(Station Identifier)的报错。

  • 接口 mseed::parse 新增对空字符串数据的检查。

  • 接口 mseed::read 新增对非法参数输入值的检查。

MySQL

新功能

  • 支持 Decimal 类型。(2.00.10.12

  • 新增函数 close。(2.00.10.12

功能优化

  • mysql::loadmysql::loadEx 接口支持在加载 DECIMAL 数据时通过 schema 参数指定小数精度。(2.00.10.12.1
  • mysql::extractSchema 接口支持在提取 DECIMAL 类型数据时显示其小数精度。(2.00.10.12.1

故障修复

  • 增加对传入连接有效性的校检。

  • 修复 load、loadEx 传入长字符串截断的问题。(2.00.10.12

ODBC

新功能

  • 新增函数 setLogLevel用于设置插件输出日志的等级,同时新增函数 getLogLevel,用于获取插件当前的输出日志等级。(2.00.10.18

功能优化

  • 在创建数据库连接时,如果 dataBaseType 参数指定为 “ClickHouse” 以外的值,则不会对该连接加锁。(2.00.10.18

  • 优化了部分报错信息。

  • 增加对接口 odbc::close 输入参数的校验。

故障修复

  • 修复多线程使用 ClickHouse ODBC 驱动时插件 crash 的问题。
  • 修复了关闭 ODBC 的连接时偶现 server 宕机的问题。

  • 修复了读取 Oracle 的中文标点数据时出现乱码的问题。

  • 修复了多个线程共用一个连接进行并发查询和写入时 server 宕机的问题。

OPC

故障修复

修复了用同一个连接多次订阅后取消订阅时 server 宕机的问题。

OPCUA

故障修复

修复了多线程作业相关的 server 宕机的问题。

ORC

功能优化

优化了时间类型和字符串类型数据导入为数值类型的处理方法。

故障修复

修复了读取时间类型空值数据时输出结果不正确的问题。

Parquet

功能优化

优化了部分报错信息。

故障修复

  • 新增接口 parquet::setReadThreadNum(num),用于设置插件的最大读线程数。(2.00.10.12

  • 新增接口 parquet::getReadThreadNum(),用于获取插件的最大读线程数。(2.00.10.12

RabbitMQ

功能优化

将 RabbitMQ 同时可以创建的最大连接数为限定为 200。(2.00.10.1

SchemalessWriter

新功能

新增无模式写入插件 SchemalessWriter。

Signal

故障修复

  • 修复接口 signal::ifft 中参数 n( 傅立叶变换后输出向量的长度)的计算逻辑问题。(2.00.10.12

  • 修复了频繁调用 signal::secc 等接口时内存泄漏的问题。

  • 修复多线程并发访问 signal::fft, signal::ifft, signal::secc 等接口时 Signal 插件宕机的问题。

  • 修复当 signal::fft 函数的输入数据为偶数个时,输出值的正负符号错误的问题。

TCPSocket

首次发布用于创建 TCP 连接并与指定 IP 和端口进行数据交互的 TCPSocket 插件。

SVM

功能优化

接口 svm::fit 新增对参数 params 中键值"nu"输入值范围的检查。

故障修复

修复了多线程执行 svm::fit 导致 server 宕机的问题。

Zip

新功能

  • 新增支持 Windows 系统。

  • 支持压缩文件夹。(2.00.10.12

  • 接口 unzip 新增 password 参数,支持对压缩包输入密码进行解密后解压。(2.00.10.12

功能优化

  • 优化了部分报错信息。

  • 优化了终端的输出日志。

故障修复

修复使用 zip::unzip 时若抛出异常时,已有 handle 未及时关闭的问题。

Zlib

新功能

新增支持压缩同一个文件下的所有文件。

功能优化

优化了部分报错信息。

ZMQ

功能优化

优化了部分报错信息。

故障修复

接口 zmq::cancelSubJob 增加传入参数限制,只接受标量。