Node-RED中MQTT传感器数值滑动平均计算结果异常问题

• 局部变量无法持久化存储：你将存储历史数据的phArray定义为了Function节点的局部变量，Node-RED的Function节点每次被传感器数据触发时都会从头运行全部代码，phArray会被反复初始化为新的空数组，无法保留之前的历史读数。
• 空数组槽位导致计算偏差：new Array(10)会创建包含10个空槽位的数组，每次运行仅会存入1个有效pH值，剩余9个均为空值。reduce方法执行累加时会自动跳过空槽位，最终累加结果仅为1条有效读数，除以10后就得到了预期值十分之一左右的异常结果。

// 固定校准参数
const calSolution1 = 7.00;
const calSolution2 = 4.00;
const calReading1 = 9564;
const calReading2 = 10605;
const averageWindow = 10;

// 从节点上下文读取历史pH数组，首次运行无数据则初始化为空数组
let phArray = context.get('phArray') || [];

// 计算当前读数对应的pH值
const slope = (calSolution2 - calSolution1) / (calReading2 - calReading1);
const intercept = calSolution1 - slope * calReading1;
const currentPh = slope * msg.payload + intercept;

// 维护滑动窗口长度：超出窗口大小时移除最早的读数
phArray.push(currentPh);
if (phArray.length > averageWindow) {
    phArray.shift();
}

// 可根据需求选择计算逻辑：
// 方案1：始终返回平均，数据不足时按实际条数计算平均
const sum = phArray.reduce((acc, cur) => acc + cur, 0);
msg.payload = sum / phArray.length;

// 方案2：等窗口存满10条数据后再返回平均，未存满时返回当前读数
// if (phArray.length === averageWindow) {
//     const sum = phArray.reduce((acc, cur) => acc + cur, 0);
//     msg.payload = sum / averageWindow;
// } else {
//     msg.payload = currentPh;
//     // 若不需要未存满时的输出，可直接return null
// }

// 将更新后的历史数组存回节点上下文，供下次调用读取
context.set('phArray', phArray);

return msg;

• 采用Node-RED内置的context上下文存储历史读数，保证多次触发节点时数据不会丢失
• 动态维护有效数据数组，不会提前创建空槽位，避免空值干扰求和计算
• 提供两种平均计算方案，可根据实际业务需求选择启用

内容的提问来源于stack exchange，提问作者Matthew Wawrzyniec