replay回放时,同一个时刻数据在同一批次输出。控制一下replay的速度,可以让它变得更慢。但是不能保证进来的是一条的。你的message handler必须能够应对批量的情况。
回答于 2021-05-26 09:56
可以通过schema参数指定日期和时间类型的格式,即把time的数据类型指定为SECOND,format指定为HHmmss,示例代码如下: db=database("dfs://moneyFlow",VALUE,2011.01.01..2011.12.31) columns=`ticker`date`time`open`close`high`low`tvrvalue`tvrvolume types=[SYMBOL,DATE,TIME,DOUBLE,DOUBLE,DOUBLE,DOUBLE,DOUBLE,DOUB...
回答于 2021-05-26 09:55
把s.table部分修改一下: s.table(data=createDataFrame(), tableAliasName="df") 具体关于python api的教程可以参考:https://gitee.com/dolphindb/T...
回答于 2021-05-26 09:54
DolphinDB在使用loadText函数或ploadText函数,将csv文件导入内存表时,可以通过schema参数指定日期和时间类型的格式。示例代码如下: filePath ="F:/Data/test.csv" schemaTB = extractTextSchema(filePath) update schemaTB set type="DATETIME" where name="time" //指定读取原始数据的格式,根据2017/6/21 6:16指定 sc...
回答于 2021-05-26 09:53
我们可以先通过loadTextEx函数把csv数据先导入dolphindb数据库,入库的时候指定数据的格式即可,上面的例子可以根据下面的代码修改: //创建分区数据库和表 def createDatabaseAndTable(dbUrl, tableName){ if(existsDatabase(dbUrl)){ dropDatabase(dbUrl) } dbDate = database("", RANGE, date(date...
回答于 2021-05-26 09:53
DolphinDB中的asof函数可以实现上述的功能,示例代码如下: x = 1 3 5 7 9 11 y = 7 asof(x, y) 返回结果如下: 3
回答于 2021-05-26 09:52
方法一: DolphinDB提供了accumulate函数可以实现上述的功能,示例代码如下: x = 2 5 7 accumulate(add, x) 返回: 方法二: 可以直接用cumsum函数实现: x = 2 5 7 cumsum(x)
回答于 2021-05-26 09:50
select ts_code, trade_date, move(mavg(open, 10), -10) from t context by ts_code 可以结合move和mavg使用。
回答于 2021-05-25 17:29