veryOrdinary
veryOrdinary

性别: 注册于 2023-02-27

向TA求助
20金币数
1210 经验值
0个粉丝
主页被访问 728 次

116 个回答

0 赞同

TSDB 引擎使用 upsert 插入,若两者去重机制不同,会影响结果吗

upsert 的参数 keyColNames 必须包含所有 sortColumns 的字段,所以 upsert 去重是在 sortColumns 基础上进行的。

回答于 2023-07-28 16:35

0 赞同

报错:TSDB engine is not enabled

请先检查一下版本是否为 2.00 版本, 1.30 版本不支持 TSDB 引擎;其次检查一下相关配置项是否已经配置,TSDB 引擎需设置TSDBCacheEngineSize 等配置后才能使用。

回答于 2023-07-28 15:43

0 赞同

python 报错 IO Error Type 6 和 IO Error Type 13

有以下几种排查思路:(1)网络问题:在出现这个错误之前,控制台会给出 Socket::write errno=110 或者 Socket::read errno=110 等 Socket 错误。请检查 API 网络、DDB Server 网络是否畅通,以及这两个网络的联通性。(2)同一个 Session 中使用多线程。同一个 Session 中使用多线程是不安全的,建议不同线程使用不同 Sess...

回答于 2023-07-28 15:33

0 赞同

模块修改后不生效

这个只针对集群的情况。只有首次对应集群数据节点或计算节点在对应的homeDir(可以通过getHomeDir()确认)没有modules目录时,系统自动会copy一份../server/modules目录的文件到对应节点的homeDir下面。后续修改方法:(1)GUI连接对应节点,同步module文件(2)修改对应节点homeDir下的modules下的文件 modules 功能在使...

回答于 2023-07-24 09:40

0 赞同

interval 输出值不符合 预期

若不指定 origin, interval 的起始值是规整后的起始值,规整规则为第一个能被 指定的起始时间 t1 前第一个能被 step 整除的 t0 值,在该例子中,step 未设置默认与 duration 相同,有因此 t0 为 00:00 这个时间点,因此第一个窗口为 00:00 00:01, 第二个窗口为 00:02 00:03...以此类推,取每个窗口的 last 结果是符合预期...

回答于 2023-07-13 09:32

0 赞同

PythonAPI:Data conversion error: unsupported type [<class '...

PythonAPI 不支持 datetime.datetime 类型的日期,需要转成 np.datetime64 类型,可以用 pd.to_datetime 进行转换。例如: 下述数据时间戳的格式为:2021.09.01T10:01:00.123 data_path = "/path/20210901tick.csv"df = pd.read_csv(data_path)df["SecurityID"] = df["SecurityID"].astype('str')+".SH"df["TradeTime"] =...

回答于 2023-07-12 15:15

0 赞同

查询不同表的数据(数据量不超过内存上限)提示 OOM

您每次加载不同的数据表,数据会缓存在内存中,您可以调用 clearAllCache 函数或者 clearCachedDatabase,去清理缓存。

回答于 2023-07-11 16:38

0 赞同

TSDB 更新数据后乱序

TSDB 只保证 level file 内部是有序的,但是 level file 间可能是无序的,您可以尝试通过调用 triggerTSDBCompaction 触发 level file 文件的合并。

回答于 2023-07-11 15:53

0 赞同

MTW 写入报错 <Exception> in insert: thread is exiting. 可能...

有几种可能的原因: 1. 写入数据中有脏数据,如类型不匹配的数据,导致数据没插入完成之前,mtw 的线程就退出了。 2. 调用 waitForThreadCompletion 后,继续用 mtw 对象写入数据。

回答于 2023-06-30 09:33

0 赞同

如何实现递归运算

可以使用 accumulate 或 reduce 高阶函数实现递归,两者区别是,前者会输出递归的中间结果,后者只输出最终结果。 a = 1..10x = adef f1(x, a){    return x.move(1) + a\2}print accumulate(f1{, a}, NULL, X)

回答于 2023-06-27 09:48