下面的代码中,prepareData函数可为每批100个测点产生所有记录,writeData把数据批量写入分布式表,loopWrite是把100万个测点用cut函数分割后用loop循环执行。 def prepareData(idVec, startTime,n){ idSize=size(idVec) records= n * idSize id = array(INT, records) for(i in 0:idSize) id[(i*n) : (...
回答于 2021-06-15 16:32
升级不影响现有数据。升级步骤如下:1.下载。到官网下载新版本。在linux上可通过执行命令下载: wget http://www.dolphindb.com/downloads/DolphinDB_Linux64_v1.10.11.zip 注意:上述命令中不同版本的号会有不同的文件名。2.解压。比如unzip DolphinDB_Linux64_v1.10.11.zip -d dolphindbv11011解压到dolphindbv11011...
回答于 2021-06-15 16:31
这个D:/dolphindb/test/scripts目录应该是你GUI的工作区目录(workspace)。要想包含DolphinDB服务器上的文件,需要在GUI中设置Remote Directory,点击菜单栏“Edit Server”打开编辑,如下图所示: 设置后,相当于建立了当前GUI worksapce与Remote Directory的映射关系。
回答于 2021-06-15 16:31
建库表的代码可以简化如下: db1=database(, VALUE, 2019.03.22d..2019.04.11d) db2=database(, RANGE, 0..9999*100+800000) db=database("dfs://VALUE3", COMPO,[db1, db2]) pt=db.createPartitionedTable(tmp,`pt, `time`id );
回答于 2021-06-15 16:30
可用datetime模块中的datetime.now()得到当前时间,代码修改如下: from datetime import datetime import dolphindb as ddb import numpy as np import pandas as pd s = ddb.session() c=s.connect("192.168.1.125", 8848, "admin", "123456") s.run("tableInsert{demoSt}", [1,np.datetime64( datetime.now(),"ms"),...
回答于 2021-06-15 16:29
DolphinDB database中有个timer函数可用于计算一条命令的执行时间。上面的例子,写成如下代码即可: timer select * from t
回答于 2021-06-15 16:29
流数据写入时,要求类型一致。因此字符串需要用uuid函数转换一下: insert into t\_complete\_warning\_stream\_data values("0000100888",uuid("256065fd-74d0-4004-bb55-c15d5982a531"),"748865688JA002AP3S6000000000","福建宁德3# 科尼 110KW 3号厂房 AB2 JA002AP3S6","1","200mS","","","告警","null",2020.03.11T0...
回答于 2021-06-15 16:28
分布式表顾名思义,包含了很多分区。这里虽然只查一条记录,但涉及很多分区。一个query涉及的分区越多,需要耗费资源的越多。maxPartitionNumPerQuery指定一个query最多可以使用多少个分区。默认值是65535。这个分区数目怎么来决定呢?并不是计算实际用到的分区,而是根据datbase中的分区定义信息以及sql语句的where子句...
回答于 2021-06-15 16:27