fix: show consistent missing percentage values in network overview

DEPLOYMENT-v1.2.2-2026-10-14.md

@@ -1,3 +1,5 @@
 # 树莓派接入插件 v1.2.2
 
 2026-10-14 网络卡片改为按 network.link 显示已连接/已断开，字段缺失显示状态未确认，与 NAS 的接口连接语义一致。页面不再把 network.internet 用作接口状态文案。Agent 的既有互联网探测和告警逻辑不修改。两项后端测试及全页三尺寸中英文主题浏览器验证通过。部署使用停服一致性数据备份 /volume1/homes/way/pigway-console-backup-synology-vpi-link-v1.2.2-20261014/data.tar.gz，目录 0700；旧树莓派插件保存在数据卷 adapter-backups/vpi-link-v1.2.2/pigway-agent。
+
+生产安装并启用 1.2.2，实际 UI 已使用 network.link 且不存在“互联网正常”文案；认证 API 两设备在线，实时流量和历史指标保留。验证会话删除。Tea ZIP 与 SHA256 附件下载校验一致。

DEPLOYMENT-v1.3.0-2026-10-15.md

@@ -0,0 +1,5 @@
+# pigway-console-adapter-raspberry-pi v1.3.0
+
+2026-10-15 已与 Console v2.4.0 部署。声明每秒缓存读取并透传 Agent 的 system/network 真实采样时间。树莓派网络仍每 5 秒采样，历史去重验证通过。
+
+生产两设备在线。认证 API 连续观测确认树莓派缓存每秒、网络 5 秒、NAS 实时约 10 秒；最近三个网络 10 秒历史桶各 2 个样本，没有每秒重复入库。Console 保留原名称、证书、存储缓存和一年历史策略。部署详情见 Console [生产记录](https://tea.pigway.com/way/pigway-device-console/src/branch/main/docs/DEPLOYMENT-v2.4.0-2026-10-15.md)。

DEPLOYMENT-v1.3.2-2026-10-15.md

@@ -0,0 +1,7 @@
+# pigway-console-adapter-raspberry-pi v1.3.2 实测调优
+
+2026-10-15 生产调优结论：统一 4 秒读取 CPU、内存、温度及网络速率。曾试 2 秒，但这台 DSM 的 utilization 实际采样时间通常每 4 秒更新，连续细粒度观察 CPU 时间为 7853/7857/7861/7865 等相差 4 秒的样本；不能把两次相同样本当成更快采样。只读接口测量 System.info 约 0.05–0.07 秒、Utilization.get 约 1.03–1.09 秒，请求耗时与真实样本周期不同。
+
+最终 40 秒连续观测：两设备各 10 个独立实时样本、10 个网络样本，中位间隔均 4 秒；无离线或缺失采集组，缓存 API 最大耗时 0.032 秒（这是 Console 缓存读取，不是 DSM 接口耗时）。Pi 本地 CPU 等继续 1 秒，网络配置已从 5 秒改为 2 秒；Console 每 4 秒读取，覆盖更快缓存。NAS 网络配置 60 秒、存储 24 小时保持。
+
+插件生产版本 Pi 1.3.2、NAS 1.6.1，Console 仍 2.4.0、Agent 仍 3.9.0。3 项 Pi 回归和 14 项 NAS 回归通过。停服一致性数据备份 /volume1/homes/way/pigway-console-backup-balanced-4s-20261015/data.tar.gz，目录 0700；旧插件在数据卷 adapter-backups/balanced-4s-20261015。Pi 原配置备份 /home/way/pigway-timing-backup-20261015.conf，权限 0600。仅保留 Console 原 latest 镜像，没有新增镜像。

README.md

@@ -32,3 +32,7 @@ v1.1.0 已与 Console v2.1.0 部署，真实树莓派在线并开始记录历史
 当前网络卡片以实时上下行速率为主文字，详见 [v1.2.1 部署记录](DEPLOYMENT-v1.2.1-2026-10-14.md)。
 
 网络连接文案统一为接口链路状态，见 [v1.2.2](DEPLOYMENT-v1.2.2-2026-10-14.md)。
+
+生产 v1.3.0 与按设备周期采集的核验见 [部署记录](DEPLOYMENT-v1.3.0-2026-10-15.md)。
+
+当前生产实时指标统一 4 秒读取，实测及版本 v1.3.2 见 [调优记录](DEPLOYMENT-v1.3.2-2026-10-15.md)。

plugin/manifest.json

@@ -1,7 +1,7 @@
 {
   "id": "pigway-agent",
   "name": "PIGWay Raspberry Pi Agent",
-  "version": "1.2.2",
+  "version": "1.3.3",
   "protocol_version": 1,
   "entrypoint": "worker.py",
   "runtime": "python3",
@@ -38,5 +38,8 @@
     "contract": "console-ui-v1",
     "entrypoint": "ui/index.js"
   },
-  "legacy_connection_fields": true
+  "legacy_connection_fields": true,
+  "collection": {
+    "interval_seconds": 4
+  }
 }

plugin/ui/overview.js

@@ -20,5 +20,7 @@ export function agentHostCard(entry) {
     memTotal = y.memory_total_bytes,
     diskUsed = y.disk_used_bytes,
     diskTotal = y.disk_total_bytes;
-  return `<article class="panel host-panel"><div class="host-head"><div><div class="host-title"><h2>${esc(m.name || h.name || m.id)}</h2><span class="uptime-badge">${esc(formatUptime(s.uptime_seconds))}</span></div><div class="device-details"><span>ID ${esc(m.id || h.id)}</span><span>${appState.LANG === "zh" ? "主机名" : "Hostname"} ${esc(m.hostname || v.hostname || "--")}</span><span>${esc(v.manufacturer || "")} ${esc(v.model || "--")}</span><span>${appState.LANG === "zh" ? "序列号" : "Serial"} ${esc(v.serial || "--")}</span><span>${appState.LANG === "zh" ? "硬件版本" : "Revision"} ${esc(v.revision || "--")}</span><span>${esc(v.os || "--")}</span><span>${appState.LANG === "zh" ? "内核" : "Kernel"} ${esc(v.kernel || "--")}</span><span>${esc(v.architecture || "--")} · CPU ${esc(v.cpu_count || "--")}</span><span>${appState.LANG === "zh" ? "程序版本" : "Agent"} ${esc(s.version || "--")}</span></div></div><span class="badge good">${tr("在线")}</span></div><div class="host-grid"><div class="metric"><div class="muted">${tr("处理器负载")}</div><div class="value">${esc(y.cpu_percent)}%</div>${meter(y.cpu_percent)}<div class="muted">${appState.LANG === "zh" ? "频率" : "Frequency"} ${esc(y.cpu_freq_mhz)} MHz · ${esc(y.temperature_c)}°C${fanMetric(s.plugins || {})}</div></div><div class="metric"><div class="muted">${tr("内存占用")}</div><div class="value">${esc(y.memory_percent)}%</div>${meter(y.memory_percent)}<div class="muted">${bytes(memUsed)} / ${bytes(memTotal)} · ${appState.LANG === "zh" ? "可用" : "Available"} ${bytes(y.memory_available_bytes)}</div></div><div class="metric"><div class="muted">${tr("磁盘占用")}</div><div class="value">${esc(y.disk_percent)}%</div>${meter(y.disk_percent)}<div class="muted">${bytes(diskUsed)} / ${bytes(diskTotal)} · ${appState.LANG === "zh" ? "剩余" : "Free"} ${bytes(y.disk_free_bytes)}</div></div><div class="metric"><div class="muted">${tr("主网络")}</div><div class="value">↓ ${bytes(n.rx_bytes_per_second)}/s · ↑ ${bytes(n.tx_bytes_per_second)}/s</div><div class="muted">${esc(n.interface || "--")} · ${n.kind === "WIF" ? `${esc(n.metric)} dBm · ` : n.link_speed_mbps ? `${esc(n.link_speed_mbps)} Mbps · ` : ""}${esc(n.ip_label)} ${esc(n.ip)} · ${n.link === true ? (appState.LANG === "zh" ? "已连接" : "Connected") : n.link === false ? (appState.LANG === "zh" ? "已断开" : "Disconnected") : (appState.LANG === "zh" ? "状态未确认" : "Unconfirmed")}</div></div><div class="metric"><div class="muted">${tr("显示状态")}</div><div class="value">${esc(ownerName(d.owner))}</div><div class="muted">${appState.LANG === "zh" ? "告警状态独立于硬件插件" : "Alert state is independent of hardware plugins"}</div></div><div class="metric"><div class="muted">${tr("当前告警")}</div><div class="value">${(d.alerts || []).length}</div><div class="muted">${(d.alerts || []).map((a) => esc(ownerName(a.id))).join(" · ") || tr("无告警")}</div></div></div>${pluginSummary(s.plugins || {}, h.id)}<div class="group"><h3>${tr("服务与进程监控")}</h3><div class="rows">${(s.watches || []).map((w) => `<div class="row"><span>${esc(w.name)} · ${esc(w.target)}</span><span class="badge ${w.up ? "good" : "bad"}">${tr(w.up ? "正常" : "停止")}</span></div>`).join("") || `<div class="muted">${tr("暂无数据")}</div>`}</div></div></article>`;
+  const percent = n => Number.isFinite(n) ? `${n.toFixed(1)}%` : "--";
+  const progress = n => Number.isFinite(n) ? meter(n) : "";
+  return `<article class="panel host-panel"><div class="host-head"><div><div class="host-title"><h2>${esc(m.name || h.name || m.id)}</h2><span class="uptime-badge">${esc(formatUptime(s.uptime_seconds))}</span></div><div class="device-details"><span>ID ${esc(m.id || h.id)}</span><span>${appState.LANG === "zh" ? "主机名" : "Hostname"} ${esc(m.hostname || v.hostname || "--")}</span><span>${esc(v.manufacturer || "")} ${esc(v.model || "--")}</span><span>${appState.LANG === "zh" ? "序列号" : "Serial"} ${esc(v.serial || "--")}</span><span>${appState.LANG === "zh" ? "硬件版本" : "Revision"} ${esc(v.revision || "--")}</span><span>${esc(v.os || "--")}</span><span>${appState.LANG === "zh" ? "内核" : "Kernel"} ${esc(v.kernel || "--")}</span><span>${esc(v.architecture || "--")} · CPU ${esc(v.cpu_count || "--")}</span><span>${appState.LANG === "zh" ? "程序版本" : "Agent"} ${esc(s.version || "--")}</span></div></div><span class="badge good">${tr("在线")}</span></div><div class="host-grid"><div class="metric"><div class="muted">${tr("处理器负载")}</div><div class="value">${percent(y.cpu_percent)}</div>${progress(y.cpu_percent)}<div class="muted">${appState.LANG === "zh" ? "频率" : "Frequency"} ${esc(y.cpu_freq_mhz)} MHz · ${esc(y.temperature_c)}°C${fanMetric(s.plugins || {})}</div></div><div class="metric"><div class="muted">${tr("内存占用")}</div><div class="value">${percent(y.memory_percent)}</div>${progress(y.memory_percent)}<div class="muted">${bytes(memUsed)} / ${bytes(memTotal)} · ${appState.LANG === "zh" ? "可用" : "Available"} ${bytes(y.memory_available_bytes)}</div></div><div class="metric"><div class="muted">${tr("磁盘占用")}</div><div class="value">${percent(y.disk_percent)}</div>${progress(y.disk_percent)}<div class="muted">${bytes(diskUsed)} / ${bytes(diskTotal)} · ${appState.LANG === "zh" ? "剩余" : "Free"} ${bytes(y.disk_free_bytes)}</div></div><div class="metric"><div class="muted">${tr("主网络")}</div><div class="value">↓ ${bytes(n.rx_bytes_per_second)}/s · ↑ ${bytes(n.tx_bytes_per_second)}/s</div><div class="muted">${esc(n.interface || "--")} · ${n.kind === "WIF" ? `${esc(n.metric)} dBm · ` : n.link_speed_mbps ? `${esc(n.link_speed_mbps)} Mbps · ` : ""}${esc(n.ip_label)} ${esc(n.ip)} · ${n.link === true ? (appState.LANG === "zh" ? "已连接" : "Connected") : n.link === false ? (appState.LANG === "zh" ? "已断开" : "Disconnected") : (appState.LANG === "zh" ? "状态未确认" : "Unconfirmed")}</div></div><div class="metric"><div class="muted">${tr("显示状态")}</div><div class="value">${esc(ownerName(d.owner))}</div><div class="muted">${appState.LANG === "zh" ? "告警状态独立于硬件插件" : "Alert state is independent of hardware plugins"}</div></div><div class="metric"><div class="muted">${tr("当前告警")}</div><div class="value">${(d.alerts || []).length}</div><div class="muted">${(d.alerts || []).map((a) => esc(ownerName(a.id))).join(" · ") || tr("无告警")}</div></div></div>${pluginSummary(s.plugins || {}, h.id)}<div class="group"><h3>${tr("服务与进程监控")}</h3><div class="rows">${(s.watches || []).map((w) => `<div class="row"><span>${esc(w.name)} · ${esc(w.target)}</span><span class="badge ${w.up ? "good" : "bad"}">${tr(w.up ? "正常" : "停止")}</span></div>`).join("") || `<div class="muted">${tr("暂无数据")}</div>`}</div></div></article>`;
 }

plugin/worker.py

@@ -56,6 +56,14 @@ def request(device, endpoint, method='GET', payload=None, query=None):
         raise AdapterError('RESULT_UNKNOWN' if method == 'PUT' else 'DEVICE_UNAVAILABLE') from None
 
 
+def collection_interval(value):
+    declaration = value.get('collection', {})
+    interval = declaration.get('interval_seconds') if isinstance(declaration, dict) else None
+    if not isinstance(interval, (int, float)) or isinstance(interval, bool) or not math.isfinite(interval) or not 1 <= interval <= 3600:
+        interval = MANIFEST['collection']['interval_seconds']
+    return max(MANIFEST['collection']['interval_seconds'], interval)
+
+
 def collect(device):
     value = request(device, '/status')
     if not isinstance(value.get('system'), dict) or not isinstance(value.get('machine'), dict):
@@ -80,9 +88,15 @@ def collect(device):
         rate = value.get('network', {}).get(field)
         if isinstance(rate, (int, float)) and not isinstance(rate, bool) and math.isfinite(rate) and rate >= 0:
             metrics.append({'resource_id': 'host', 'key': key, 'value': rate, 'unit': 'bytes_per_second'})
+    for metric in metrics:
+        source = value.get('network', {}) if metric['key'].startswith('network_') else value.get('system', {})
+        at = source.get('observed_at') if metric['key'] != 'uptime_seconds' else value.get('timestamp')
+        if isinstance(at, (int, float)) and not isinstance(at, bool) and math.isfinite(at) and at > 0:
+            metric['observed_at'] = at
     return {'schema_version': 1, 'observed_at': value.get('timestamp'),
             'identity': {'reported_name': value['machine'].get('name'), 'category': 'host',
                          'details': value.get('device', {})},
+            'collection': {'interval_seconds': collection_interval(value)},
             'capabilities': MANIFEST['capabilities'], 'metrics': metrics,
             'resources': [{'id': 'host', 'type': 'host'}],
             'alerts': value.get('display', {}).get('alerts', []),

tests/test_metrics.py

@@ -11,7 +11,7 @@ class MetricsTests(unittest.TestCase):
         value = {'timestamp': 123, 'machine': {'name':'Pi'}, 'system': {
             'cpu_percent': 10, 'memory_total_bytes': 8000, 'memory_used_bytes': 4000,
             'disk_total_bytes': 16000, 'disk_used_bytes': 5000},
-            'uptime_seconds': 1000, 'network': {'link_speed_mbps':1000,'rx_bytes_per_second':0,'tx_bytes_per_second':1234},
+            'uptime_seconds': 1000, 'network': {'observed_at':120,'link_speed_mbps':1000,'rx_bytes_per_second':0,'tx_bytes_per_second':1234},
             'display': {'alerts': []}}
         with patch.object(worker,'request',return_value=value): result=worker.collect({})
         values = {m['key']:m['value'] for m in result['metrics']}
@@ -20,8 +20,15 @@ class MetricsTests(unittest.TestCase):
         self.assertEqual(values['network_link_speed_mbps'],1000)
         self.assertEqual(values['network_rx_bytes_per_second'],0)
         self.assertEqual(values['network_tx_bytes_per_second'],1234)
+        self.assertEqual(next(m['observed_at'] for m in result['metrics'] if m['key']=='network_tx_bytes_per_second'),120)
+        self.assertEqual(result['collection']['interval_seconds'],4)
         self.assertTrue(result['alerts_complete'])
 
+    def test_collection_minimum_and_slower_device(self):
+        self.assertEqual(worker.collection_interval({'collection':{'interval_seconds':1}}),4)
+        self.assertEqual(worker.collection_interval({'collection':{'interval_seconds':5}}),5)
+        self.assertEqual(worker.collection_interval({'collection':{'interval_seconds':True}}),4)
+
     def test_absent_or_boolean_fields_not_invented(self):
         value={'system': {'cpu_percent': True}, 'machine':{}, 'network': {'link_speed_mbps': None, 'rx_bytes_per_second':float('nan'), 'tx_bytes_per_second':True}}
         with patch.object(worker,'request',return_value=value): result=worker.collect({})