需要修改一下createPartitionedTable的第2个参数: tableSchema=table(1:0,`hardwareId`ts`temp1`temp2`temp3,[INT,TIMESTAMP,DOUBLE,DOUBLE,DOUBLE]) dfsTable = db.createPartitionedTable(tableSchema,"sensorTemp",`ts`hardwareId)
回答于 2021-05-20 17:22
没有要求,可以乱序写入。DolphinDB是分区之间的数据是有顺序的。分区内是不排序的,是按照你的插入顺序的。查询或计算的时候,如果对顺序敏感,可以在线排序。
回答于 2021-05-20 17:21
很可能是环境变量未配置全,导致pip无法找到ssl相关模块,请将"[Anaconda安装目录]\Library\bin"加入PATH试试。https://blog.csdn.net/JerkSpa...
回答于 2021-05-20 16:57
python api订阅函数目前还不支持batchSize,我们分析一下可行性,可行的话开发一下。
回答于 2021-05-20 16:54
使用append!或tableInsert函数往分布式数据表中插入数据。即使只插入一条数据,也要用表的形式来表示新增的数据。上面代码可改为如下: loadTable(dbName, `pt).tableInsert(table(int(val[0]) as col1, timestamp(val[1]) as col2, double(val[2]) as col3,double(val[3]) as col4,double(val[4]) as col5))
回答于 2021-05-20 10:54
分布式表建议用context by去重: select top 1 * from tb_kline context by DT,Code 如果要取最后一条记录,可以用limit -1: select * from tb_kline context by DT, Code limit -1
回答于 2021-05-20 10:53
用process monitor,注意在把dolphindb.exe加入filter时,Column要选Process Name,如下图
回答于 2021-05-20 10:53
export LD_LIBRARY_PATH只是临时设置变量 LD_LIBRARY_PATH,它是基于shell的,也就是说只有在当前设置了的shell里才会有作用。若用web启动数据节点,实际是由agent代理节点启动的。因此需要在设置的shell中重启代理节点后,再启动数据节点。
回答于 2021-05-20 10:52
DolphinDB API的处理问题的方式是抛出异常,因此需要try catch一下exception,比如: try { ConstantSP cmdVec = conn.run("add{a+b)"); } catch (exception &ex) { cout << "Failed to run with error: " << ex.what(); return -1; }
回答于 2021-05-20 10:51