可以使用DolphinDB中的getRunningQueries()函数和getCompletedQueries()函数 查询当前节点正在运行的查询语句: getRunningQueries() 查询集群所有节点正在运行的查询语句: pnodeRun(getRunningQueries) 查询集群所有节点的历史查询语句: pnodeRun(getCompletedQueries{100})
回答于 2021-07-09 10:08
可以自定义个函数,然后输入表名就可以返回一个bool值: def existsVariable(varName){ return objs(true).name.find(varName)>=0 } existsVariable(`tb1)
回答于 2021-07-09 10:01
可以使用下面的语句,转换成DolphinDB中的LONG类型: long(temporalFormat(2021.07.08T15:12:34.500, "yyyyMMddHHmmssSSS"))
回答于 2021-07-09 09:27
截止1.30.11版本,DolphinDB的单个定时任务(scheduleJob)的最小执行时间间隔是15分钟。 如果要低于该频率执行一些定时任务,可以设置多个定时任务,然后把执行时间错开就可以了。
回答于 2021-07-03 09:21
如果是简单的测试触发handler的时间话,可以按照下面的示例进行设计: def triggerTime(mutable tmpTable, msg) { update msg set triggerTime=now() tmpTable.append!(msg) } temTable是一个临时内存表,handler对传入的数据表msg的处理工作是增加了一列triggerTime,保存触发handler的时间,并存入临时表temTable,...
回答于 2021-06-30 21:51
可以执行下面的语句查询: //查询当前节点的历史查询语句 getRunningQueries() //查询集群所有节点的历史查询语句 pnodeRun(getRunningQueries)
回答于 2021-06-24 17:46
原因1: python api脚本中s.run("scripts")的scripts非常长,超过限制的话,python脚本会执行失败,并报类似的错误
回答于 2021-06-24 17:44
触发场景1: python api脚本中s.run("scripts")的scripts非常长,超过限制的话,python脚本会执行失败,并报类似的错误。
回答于 2021-06-24 17:37
测试版本:1.30.9 2021.05.17 注意:dfs表的delete、update从1.30.6版本才开始支持 内存表的删除方法: t = table(1 2 3 as id, 4 NULL 6 as v1, 7..9 as v2) delete from t where isNull(v1) dfs表的删除方法: if(existsDatabase("dfs://hashdb")){ dropDatabase("dfs://hashdb") } db = database("dfs://h...
回答于 2021-06-24 16:08