where 里可以用 rowOr( col like:R ["%新能源%", "%光伏%"]), 元编程可参考下述脚本 pattern = ["%新能源%", "%光伏%"]colMeta = "flagName"whereCond = makeCall(def(colMeta, pattern){return rowOr(colMeta like:R pattern)}, sqlCol(colMeta), pattern)t = table(["新能源01", "新能源02", "电力01"] as flagName, 1 2...
回答于 2023-10-13 11:40
普通的升降频需求可以用 interval 函数实现,但是由于当前场景是 weekEnd,而 interval 的 ‘w’ 精度仅仅是按 7 天做划分。可以使用 transFreq 进行分组: select last(tradetime) as tradetime, last(securityid) as securityid, first(open) as open, max(high) as high, min(low) as low, last(clos...
回答于 2023-10-13 09:59
可以改成这样 where=[parseExpr(ColName+" is not null")] parseExpr 将字符串转成元代码,<>是声明元代码的,< parseExpr(ColName) is not null > 相当于把这个函数包在元代码里,是不会被执行的,where 这里主要是填一个条件元代码,所以可以直接拼接字符串让 parseExpr 转成元代码。
回答于 2023-09-22 17:13
缺的这个符号是ddb插件API中的Util::createSystemProcedure函数,不是三方的依赖库,编译时需用 cmake .. -DLIBDOLPHINDB=path_to_libDolphinDB
回答于 2023-09-22 15:17
因为分区是按月,而写入任务是按天提交的,所以可能造成一个分区同时有多个写入任务在写入,所以造成了同一分区的写入冲突。 详细可以参考 https://docs.dolphindb.cn/zh/help/200/ErrorCodeList/S00002/index.html
回答于 2023-09-22 14:51
pickle 协议不支持 decimal 需要改成 ddb 协议,可参考这个教程配置参数 https://github.com/dolphindb/api_python3/blob/master/README_CN_NEW/3_AdvancedOperations/3.1_DataTypeCasting/3.1.1_PROTOCOL_DDB.md
回答于 2023-09-22 14:43
方法一. 调用取数函数 v.tail(2).head(1) 方法二. 索引 len=v.size() v[(len-2):(len-1)] 方法三. 移动取最后一个 last(move(v, 1))
回答于 2023-09-08 14:09
在数据量比较大时,发布端是一批一批发到订阅端的,若订阅端来不及处理,是有可能超过消息队列的最大深度的。具体可以参考教程 https://gitee.com/dolphindb/Tutorials_CN/blob/master/streaming_tutorial.md#8-%E6%80%A7%E8%83%BD%E8%B0%83%E4%BC%98
回答于 2023-09-07 16:46