如何在Node-RED中单独提取树莓派输出的Radius与Theta值？

我的树莓派上运行的Python脚本每秒会输出一组数据，示例如下：

Highest Number: 31.9029
x: -15
y: 8
Radius: 17.0
Theta: -28.07

我想在Node-RED中单独提取Radius和Theta值，测试了以下流程：

timestamp -- 
exec（运行Python脚本，启用spawn模式）-- 
switch节点（匹配"Radius"）-- 
debug

但输出结果混乱，有时仅显示"Radius:"，有时显示y、x值，有时混合显示y、Radius和Theta值，请问有没有更可靠的实现方法？

解决方案 #

方法1：修改Python脚本输出JSON格式（最推荐） #

直接让Python输出结构化的JSON数据，从根源避免文本拆分混乱：

• 修改Python代码，将每次的计算结果包装成JSON字符串输出，同时强制刷新缓冲区防止数据滞留：

import json
import time
import sys

while True:
    # 替换成你的实际计算逻辑，得到对应数值
    x = -15
    y = 8
    highest_num = 31.9029
    radius = 17.0
    theta = -28.07

    # 输出结构化JSON
    output = json.dumps({
        "Highest Number": highest_num,
        "x": x,
        "y": y,
        "Radius": radius,
        "Theta": theta
    })
    print(output)
    sys.stdout.flush()  # 强制刷新输出，确保Node-RED能实时接收
    time.sleep(1)

• 在Node-RED中，exec节点后直接接json节点，解析后就能通过msg.payload.Radius和msg.payload.Theta直接获取目标值，后续用switch或function节点处理都不会出错。

方法2：Node-RED中通过缓冲区拼接完整数据（不修改Python脚本） #

如果无法修改Python脚本，就需要在Node-RED中把零散的输出行拼接成完整的一组数据后再解析：

1. 在exec节点后添加一个function节点，用上下文存储临时缓冲区，收集够5行数据再解析：

// 初始化缓冲区
if (!context.get('lineBuffer')) {
    context.set('lineBuffer', []);
}
let buffer = context.get('lineBuffer');

// 过滤空行，添加当前行到缓冲区
const line = msg.payload.trim();
if (line) {
    buffer.push(line);
}

// 凑齐5行完整数据时，解析并输出
if (buffer.length === 5) {
    const data = {};
    buffer.forEach(item => {
        const [key, val] = item.split(': ');
        data[key.trim()] = isNaN(val) ? val.trim() : parseFloat(val);
    });
    msg.payload = data;
    // 清空缓冲区，准备下一组数据
    context.set('lineBuffer', []);
    return msg;
} else {
    // 数据未凑齐，不输出
    return null;
}

2. 这个function节点输出后，就能拿到包含所有字段的结构化数据，再提取Radius和Theta就不会出现混乱。

方法3：用split节点按完整组拆分输出 #

如果你的Python脚本每次输出完一组数据后会有一个空行（作为组与组的分隔），可以用split节点自动拆分完整组：

• 在exec节点后接split节点，设置分隔符为\n\n（两个换行符对应空行），split会把每组5行的输出作为一个完整的payload发送。
• 再接一个function节点，解析这个完整的文本块：

const lines = msg.payload.trim().split('\n');
const data = {};
lines.forEach(line => {
    const [key, val] = line.split(': ');
    data[key.trim()] = isNaN(val) ? val.trim() : parseFloat(val);
});
msg.payload = data;
return msg;

之后就能正常提取Radius和Theta值。

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