可以通过dolphindb中的rpc函数实现上面的功能,示例如下: rpc(getControllerAlias(), getClusterChunksStatus) 返回信息如下
回答于 2021-06-09 16:53
传入到createPartitionedTable函数中的table不能是stream table,上面的建表语句可以这么写: login("admin", "123456") dbPath="dfs://thermalDB" dbDate = database(, VALUE, 2021.03.17..2031.03.17) dbID = database(, HASH, [SYMBOL, 50]) db=database(dbPath, COMPO, [dbDate, dbID]) t = table(1:0,`id`ts`t...
回答于 2021-06-09 16:53
可以通过dolphindb中的format(X, format)函数把指定格式应用到给定对象。例如创建一个这样的表: t = table(1..100 as id, (1..100 + 2018.01.01) as date, rand(100.0, 100) as price, rand(10000, 100) as qty) 可以通过format对输出的内容进行格式转换: select id, date.format("MM/dd/yyyy") as date, price.form...
回答于 2021-06-09 16:51
DolphinDB中的strReplace(str, pattern, replacement)功能和上述python的format()函数功能相似,示例代码如下: strReplace("The ball is red.", "red", "green") 返回: The ball is green.
回答于 2021-06-09 16:50
share streamTable(10000:0,`ts`temp, [TIMESTAMP,DOUBLE]) as subTable1 share streamTable(10000:0,`ts`temp, [TIMESTAMP,DOUBLE]) as subTable2 上面2行重新定义了表subTable1和subTable2,执行后,2个订阅的handler就找不到原先的表了。
回答于 2021-06-09 16:50
有一种情况是在这个长连接没有关闭的这几个小时里出现网络波动,造成连接实际上已经断开。 解决方法1:重新执行以下函数的定义声明。 解决方法2:重新创建一个新的连接,重新执行一遍所有脚本。
回答于 2021-06-09 16:49
分布式时序数据库DolphinDB的流计算框架目前已支持时序聚合引擎、横截面聚合引擎、异常检测引擎和自定义流计算引擎: 异常检测引擎(Anomaly Detection Engine)能实时检测数据是否符合用户自定义的警报指标,但这个需求不适用。异常检测引擎是按设备分组进行处理的。每次有新数据流入才触发计算,或每隔一段时间,在固定长...
回答于 2021-06-09 16:49
这是由于Linux系统的glibc版本太低,而插件编译时使用了较高版本的glibc引起的,因此需要升级glibc。 具体步骤请参阅:csdn博客
回答于 2021-06-09 16:48
IPADDR表示类型,应该用ipaddr函数转换: t=table(take(['AMZN','NFLX', 'NVDA'], 10) as str , 1..10 as id, rand([ipaddr("192.168.1.253")],10) as ip )
回答于 2021-06-09 16:48
SYMBOL是特殊的字符串类型,它相当于枚举类型,如果一个表中某一个字段的数据重复度较大,不同字符串取值的总数又不超过2097152(2的21次方)个,就可以用SYMBOL类型。 用SYMBOL类型,相比字符串类型STRING,它的有点是占用磁盘空间小,检索速度快。
回答于 2021-06-09 16:47