SNMP Trap 在以太网温湿度记录仪中的应用：主动推送与轮询的时延对比

SNMP Trap 在以太网温湿度记录仪中的应用：主动推送与轮询的时延对比

背景与场景

以太网温湿度记录仪（网口温湿度变送器/记录仪）在机房监控里常见的两种数据获取方式：

• 轮询（polling）：NMS 或边缘网关周期性读 SNMP Agent 的 OID（GET/GETNEXT），或读 Modbus TCP 保持寄存器
• 主动推送（trap/inform）：记录仪端事件触发或周期上报时，主动发 SNMP Trap 到管理站

本文聚焦后者在实测工程中的时延表现，并用 Wireshark + Python 抓包验证，数据落 InfluxDB，架构跑在腾讯云侧做汇聚。

一、设备侧前提

先确认记录仪固件能力，别想当然：

• 是否支持 SNMP v1/v2c/v3 Trap 目标地址、端口（默认 162 UDP）配置
• Trap 触发条件：阈值越限、采样周期到、上下线、缓存补传
• 是否支持 inform（v2c/v3，需 Agent 端会话，工业设备常不支持）
• 同时跑 Modbus TCP 时，Trap 是独立 UDP 通道，不占用 502 端口

PoE 供电下注意：设备启动后 SNMP Agent 起来时间晚于网口 up，管理站别在 boot 阶段误判离线。

二、实验拓扑

[记录仪A PoE]──switch──┬──[边缘网关/管理站B] 本地测试
                       └──Internet──[腾讯云CVM/CLB] 远端NMS+trap接收
InfluxDB + Telegraf + Python trap daemon 在云侧或边缘侧均可

• 记录仪：固定采样周期 T_s（如 10s），阈值触发测试用外部加热/哈气
• 管理站：snmptrapd 或 Python netsnmp / pysnmp 自定义守护
• Wireshark：在管理站抓 UDP 162，或在记录仪侧镜像抓出口
• 时钟：两端 NTP 同源，否则时延基准漂移

三、时延定义（别混用）

• 检测时延 t_detect：物理量越限 → 设备内部判定（去抖/滞回后）生成事件
• 发送时延 t_send：事件 → UDP 报文离网卡
• 网络时延 t_net：出机房 NAT/防火墙 → 云侧，跨城场景重点
• 接收处理时延 t_proc：trapd 收包 → 写 InfluxDB line protocol 入库
• 端到端告警时延 t_e2e​ = t_detect + t_send + t_net + t_proc

轮询场景另算：

• 轮询周期 T_poll，最差等待 = T_poll
• 采集+解析+上报​ t_collect
• 端到端 = ceil(事件后剩余周期) + t_collect + t_net + t_proc

四、两种模式工程实现

1. Trap 接收端（Python，pysnmp）

from pysnmp.entity import engine, config
from pysnmp.carrier.asyncore.dgram import udp
from pysnmp.entity.rfc3413 import ntfrcv
import datetime, requests

app = engine.SnmpEngine()
config.addTransport(app, udp.domainName, udp.UdpTransport().openServerMode(('0.0.0.0', 162)))
config.addV1System(app, 'my-area', 'public')  # v2c community，生产用v3
ntfrcv.NotificationReceiver(app, cbFun)

def cbFun(snmpEngine, stateReference, contextEngineId, contextName,
          varBinds, cbCtx):
    execCtx = snmpEngine.observer.getExecutionContext('rfc3412.receiveMessage:request')
    ts = datetime.datetime.utcnow().isoformat()+'Z'
    fields = {}
    tags = {'host': execCtx['transportAddress'][0]}
    for oid, val in varBinds:
        fields[str(oid)] = str(val)
    # 推InfluxDB v2 API 或经Telegraf
    line = f"trap,src={tags['host']} vars=\"{fields}\",ts=\"{ts}\""
    requests.post('http://localhost:8186/write', data=line.encode())  # 示例，实际拼Line Protocol
    print(ts, fields)

app.transportDispatcher.jobStarted(1)
try:
    app.transportDispatcher.runDispatcher()
except KeyboardInterrupt:
    app.transportDispatcher.closeDispatcher()

注意：pysnmp CoRoutine 调度下阻塞调用会拖慢处理；生产建议异步或交 snmptrapd 落文件后 Telegraf tail。

2. 轮询端（Python，pymodbus + snmp GET 备选）

import time, requests
from pymodbus.client import ModbusTcpClient

client = ModbusTcpClient(host='192.168.1.10', port=502, timeout=1)
T_POLL = 5.0
last = 0.0
while True:
    t0 = time.time()
    if client.connect():
        rr = client.read_holding_registers(0, 2, unit=1)
        if not rr.is_error():
            temp = rr.registers[0]/10.0
            humi = rr.registers[1]/10.0
            line = f"env,host=roomA temp={temp},humi={humi} {int(t0 * 1e9)}"
            requests.post('http://localhost:8186/write', data=line.encode())
    dt = time.time()-t0
    sleep_for = max(0, T_POLL - dt)
    time.sleep(sleep_for)

Modbus TCP 轮询受连接复用影响，别每次建连；长连接时注意对端空闲断开，加 keepalive 或定期重连。

五、Wireshark 验证与计时

抓包过滤：

udp.port==162 || tcp.port==502

• Trap 场景：在管理站抓 snmp/udp，看 Agent IP → NMS IP，payload 含绑定变量
• 记录设备侧事件时间戳（或记录仪 syslog/内部日志）与管理站收到帧的 frame.time_epoch
• 跨城场景在两端分别抓包，NTP 对齐后算 Δ

补充：云侧 CLB/DNS/安全组需放通 UDP 162 入站；腾讯云 CVM 默认安全组拒入站，别漏。

六、时延实测对比（参考量级，非你环境数值）

实验室同网段 + 跨城混合测试，T_s=10s，T_poll=5s，滞回去抖 1 次确认。

关键观察：

1. 事件驱动下 Trap 尾时延更低且确定性好——不用等下一个轮询窗口。越限事件平均早检出半个周期以上。
2. 轮询时延上限由周期决定：T_poll=5s 时理论最坏额外等待 5s；现场常把周期设 30–60s，告警时延随之放大到数十秒级，不适合快速响应场景。
3. Trap 丢包风险在 UDP/162：跨城公网无重传，NAT 会话超时（默认30s–5min）可能导致返回路径不通；inform 可补偿但设备支持度低。
4. 云侧接收端瓶颈：单线程 pysnmp 守护在高并发 trap 风暴时 t_proc 上升，建议 snmptrapd + 队列，或边缘网关聚合后批量上云。
5. PoE 重启/掉电恢复后：Agent 冷启动到注册完成前，Trap 目标未加载，期间事件丢失；轮询侧同理，需设备上线自检。

七、工程选型建议

• 机房本地动环：边缘网关轮询 Modbus TCP + 本地阈值联动，断网缓存补传；Trap 作补充事件通道
• 跨城集中监控上腾讯云：边缘网关收敛协议，MQTT over TLS 上报，别在公网直接收 Trap——UDP 162 入站+NAT 反射不友好
• 确需 Trap 上云：边缘侧 snmptrapd 接收 → 转 MQTT/HTTP 转发云侧，或 GRE/VPN 隧道内回传，勿暴露 Agent 管理平面
• 时延敏感告警：Trap + 本地继电器联动双保险，云侧告警通知异步兜底
• InfluxDB 写入：trap 事件型数据用 measurement 分离，加 tag host/room/city；轮询时序数据降采样，连续查询降负载

八、腾讯云侧落地要点

• IoT Explorer/云开发 CloudBase 不直接收 SNMP Trap；边缘侧做协议收敛后上报属性/事件
• CVM 上跑接收守护，安全组放通入站 UDP 162（或前置 VPN）；更优：边缘网关在机房内收 Trap，经 MQTTS 8883 上云
• InfluxDB v2 自建容器或腾讯云托管；Telegraf inputs.socket_listener / exec 插件桥接
• 告警：Flux 任务或外部规则引擎触发企业微信/短信，别在采集端硬编码

九、踩坑提示

• 记录仪 Trap 目标只能配单播，多管理站时需中继；v2c community 明文，跨公网友情提醒
• 华为/纵横通/研华等私有 MIB，OID 不在标准 HOST-RESOURCES，先 snmpwalk 确认
• Wireshark 抓不到云侧入站包时，确认 CLB 后端健康检查、安全组、iptables NFLOG
• Python pysnmp v3 配置繁琐，原型期用 snmptrapd -d 转文件更快
• 别把轮询周期和采样周期混淆：记录仪内部采样 10s，轮询 5s 不代表分辨率更高，插值无意义

十、小结

Trap 把"事件传播时延"从轮询周期等待中解耦出来，工程上更适合作越限告警通道；代价是 UDP 不可靠、管理平面暴露、设备端事件模型需验证。生产系统通常是混合架构：边缘轮询保时序数据，Trap/inform 保事件实时性，云侧统一收敛、去重、幂等入库 InfluxDB，大屏与告警分离。

物联网 #Modbus #TCP/IP #UDP #POE供电 #腾讯云 #Wireshark #Python #InfluxDB #以太网温湿度传感器 #网口温湿度变送器 #机房监控