InfluxDB 连续查询中的 RESAMPLE 用法详解 - 未来AI笔记

发布时间: 2026-07-07 · 来源: 新能源产业网 · 阅读量: 6048
cloud image 1 innovation image 2

091Z lvl=info msg="Finished continuous query" written=0 根因分析 数据延迟:VPN 设备每 5 分钟上报一次数据,但上报时间有 3-8 分钟的延迟 CQ 扫描范围太小:默认只查询最近 5 分钟的数据 时序不匹配:08:00 执行的 CQ 查询 07:55-08:00 的数据,但该时段的数据在 08:05 才到达 解决方案 DROP CONTINUOUS QUERY vpn_traffic_5m ON monitor; CREATE CONTINUOUS QUERY vpn_traffic_5m ON monitor RESAMPLE EVERY 5m FOR 30m -- 关键修改:扫描最近 30 分钟 BEGIN SELECT non_negative_derivative(max(byte_in), 1s) / 125000 AS rx_mbps, non_negative_derivative(max(byte_out), 1s) / 125000 AS tx_mbps INTO autogen.

(7)发布垃圾广告及灌水信息 多次发布非CSDN官方允许的包含售卖产品、提供服务、宣传推广内容的垃圾广告;购买或出售账号之间虚假的互动,发布干扰社区秩序的推广内容及相关交易;使用严重影响用户体验的违规手段进行恶意营销;使用特殊符号、图片等方式规避垃圾广告内容审核的广告内容;恶意注册使用CSDN账号或恶意绕过CSDN规则进行批量下载、获益、经营、进行线下买卖等行为;利用其他平台搜索收录规则,恶意发布垃圾广告信息。

.appendQr_wrap{border:1px solid #E6E6E6;padding:8px;} .

sum 的第二个参数是初始值,默认为 0。21.3 序列操作 💡 代码说明:序列操作内置函数:len(长度)、sorted(排序返回新列表)、reversed(反向)、enumerate(枚举)、zip(打包)、filter(过滤)、map(映射)、any/all(逻辑判断): # len() - 长度 print(len("hello")) # 5 print(len([1, 2, 3])) # 3 # sorted() - 排序(返回新列表) nums = [3, 1, 4, 1, 5] print(sorted(nums)) # [1, 1, 3, 4, 5] print(sorted(nums, reverse=True)) # [5, 4, 3, 1, 1] print(nums) # [3, 1, 4, 1, 5](原列表不变) # reversed() - 反向迭代器 for i in reversed([1, 2, 3]): print(i) # 3, 2, 1 # range() - 范围 print(list(range(5))) # [0, 1, 2, 3, 4] # enumerate() - 枚举 for i, v in enumerate(['a', 'b', 'c'], start=1): print(f"{i}: {v}") # 1: a, 2: b, 3: c # zip() - 打包 a = [1, 2, 3] b = ['a', 'b', 'c'] print(list(zip(a, b))) # [(1, 'a'), (2, 'b'), (3, 'c')] # filter() - 过滤 nums = [1, 2, 3, 4, 5, 6] evens = list(filter(lambda x: x % 2 == 0, nums)) print(evens) # [2, 4, 6] # map() - 映射 squared = list(map(lambda x: x**2, nums)) print(squared) # [1, 4, 9, 16, 25, 36] # any() / all() print(any([False, False, True])) # True(至少一个为真) print(all([True, True, False])) # False(必须全部为真) 🔑 要点总结:sorted() 不改变原序列,any() 和 all() 在条件检查中非常实用。

= NIL) { forboth(lp, glob->subplans, lr, glob->subroots) { Plan *subplan = (Plan *) lfirst(lp); PlannerInfo *subroot = lfirst_node(PlannerInfo, lr); SS_finalize_plan(subroot, subplan); } SS_finalize_plan(root, top_plan); } 核心函数: SS_finalize_plan() 6.

配图