4. Modbus RTU 实战：Python 使用 pymodbus 库读取施肥机流量计数据

本章将进入 Modbus RTU 实战环节。我们将使用 Python 生态中最成熟的 pymodbus 库，通过 RS-485 串口读取变量施肥系统中流量计的瞬时流量与累计流量数据。通过本章学习，你将掌握从硬件接线、串口参数配置到数据解析的完整链路。

4.1 硬件连接与通信参数确认

在编写代码之前，必须确认物理层连接与设备通信参数。施肥机流量计通常采用两线制 RS-485 接口，通过 A/B 线与上位机（工控机或开发板）连接。

4.2 pymodbus 库安装与基础用法

pymodbus 是 Python 中功能最完善的 Modbus 协议实现库，支持 RTU、ASCII、TCP 三种模式。安装命令如下：

pip install pymodbus

使用 pymodbus 读取 Modbus RTU 设备的标准流程分为三步：

1. 创建串口客户端：指定串口号、波特率等参数。
2. 发起读取请求：使用 read_holding_registers 或 read_input_registers 方法。
3. 解析响应数据：将原始寄存器值转换为实际物理量。

4.3 完整代码实现：读取瞬时流量与累计流量

以下代码演示了如何连接施肥机流量计，读取瞬时流量（单位：m³/h）和累计流量（单位：m³）。假设流量计参数为：从站地址 1，瞬时流量寄存器地址 0x0000（32 位浮点），累计流量寄存器地址 0x0002（32 位浮点）。

from pymodbus.client import ModbusSerialClient
from pymodbus.constants import Endian
from pymodbus.payload import BinaryPayloadDecoder
import time

# 1. 创建 Modbus RTU 串口客户端
client = ModbusSerialClient(
    method='rtu',
    port='COM3',          # Windows 示例；Linux 下为 '/dev/ttyUSB0'
    baudrate=9600,
    bytesize=8,
    parity='N',
    stopbits=1,
    timeout=3             # 超时时间 3 秒
)

# 2. 连接串口
if not client.connect():
    print("❌ 无法连接串口，请检查硬件和端口号")
    exit(1)

print("✅ 串口连接成功，开始读取流量计数据...\n")

try:
    while True:
        # 3. 读取瞬时流量：从地址 0x0000 开始，读取 2 个寄存器（32 位浮点）
        result_instant = client.read_holding_registers(
            address=0x0000,
            count=2,
            slave=1
        )

        # 4. 读取累计流量：从地址 0x0002 开始，读取 2 个寄存器
        result_total = client.read_holding_registers(
            address=0x0002,
            count=2,
            slave=1
        )

        # 5. 检查读取是否成功
        if result_instant.isError() or result_total.isError():
            print("⚠️ 读取寄存器失败，请检查从站地址和寄存器地址")
            time.sleep(2)
            continue

        # 6. 使用 BinaryPayloadDecoder 解析 32 位浮点数
        decoder_instant = BinaryPayloadDecoder.fromRegisters(
            result_instant.registers,
            byteorder=Endian.BIG,
            wordorder=Endian.BIG
        )
        instant_flow = decoder_instant.decode_32bit_float()

        decoder_total = BinaryPayloadDecoder.fromRegisters(
            result_total.registers,
            byteorder=Endian.BIG,
            wordorder=Endian.BIG
        )
        total_flow = decoder_total.decode_32bit_float()

        # 7. 输出结果
        print(f"⏱  {time.strftime('%H:%M:%S')}  瞬时流量: {instant_flow:.2f} m³/h  |  累计流量: {total_flow:.2f} m³")

        time.sleep(2)  # 每 2 秒读取一次

except KeyboardInterrupt:
    print("\n🛑 用户中断读取，关闭连接...")

finally:
    client.close()
    print("🔌 串口连接已关闭")

4.4 数据解析原理：32 位浮点数的字节序

流量计返回的原始数据为两个 16 位寄存器，需要按照 IEEE 754 标准组合为 32 位浮点数。字节序（Byte Order）和字序（Word Order）决定了组合方式。

4.5 通信流程架构图

下图展示了从 Python 应用层到物理层的数据读取完整流程：

4.6 常见错误与排查清单

在实际对接过程中，以下三类错误最为常见：

4.7 代码优化：封装为可复用的读取函数

在实际项目中，建议将流量计读取逻辑封装为独立函数，便于集成到施肥控制主循环中：

def read_flow_meter(client, slave_id, addr_instant=0x0000, addr_total=0x0002):
    """
    读取施肥机流量计的瞬时流量和累计流量
    :param client: ModbusSerialClient 实例
    :param slave_id: 从站地址
    :param addr_instant: 瞬时流量寄存器起始地址
    :param addr_total: 累计流量寄存器起始地址
    :return: (instant_flow, total_flow) 或 (None, None)
    """
    try:
        # 读取瞬时流量
        resp_inst = client.read_holding_registers(addr_instant, 2, slave=slave_id)
        if resp_inst.isError():
            return None, None

        # 读取累计流量
        resp_total = client.read_holding_registers(addr_total, 2, slave=slave_id)
        if resp_total.isError():
            return None, None

        # 解析浮点数
        decoder_inst = BinaryPayloadDecoder.fromRegisters(
            resp_inst.registers, byteorder=Endian.BIG, wordorder=Endian.BIG
        )
        decoder_total = BinaryPayloadDecoder.fromRegisters(
            resp_total.registers, byteorder=Endian.BIG, wordorder=Endian.BIG
        )

        return decoder_inst.decode_32bit_float(), decoder_total.decode_32bit_float()

    except Exception as e:
        print(f"读取异常: {e}")
        return None, None

# 使用示例
instant, total = read_flow_meter(client, slave_id=1)
if instant is not None:
    print(f"瞬时流量: {instant:.2f} m³/h, 累计流量: {total:.2f} m³")

通过本章实战，你已经掌握了使用 pymodbus 库读取施肥机流量计数据的完整方法。这套代码可以直接复用到变量施肥系统的实时数据采集模块中，为后续的施肥量闭环控制提供准确的流量反馈。