ดึงข้อมูล Solar ผ่าน Modbus-TCP
จาก Huawei SmartLogger

pip install pymodbus paho-mqtt

from pymodbus.client import ModbusTcpClient

# ===== ตั้งค่า =====
LOGGER_IP = "192.168.1.100"  # เปลี่ยนเป็น IP SmartLogger
PORT       = 502
UNIT_ID    = 1               # SmartLogger aggregate

# Register ที่จะอ่าน: (address, count, name, unit, scale, signed)
REGISTERS = [
    (32064, 2, "Active Power",      "kW",  0.001, True),
    (32078, 2, "Daily Energy",      "kWh", 0.01,  False),
    (32084, 2, "Total Energy",      "kWh", 0.01,  False),
    (32070, 1, "Grid Frequency",    "Hz",  0.01,  False),
    (32071, 1, "Voltage Phase A",   "V",   0.1,   False),
    (32089, 1, "Plant Status",      "",    1,     False),
]

def read_value(client, addr, count, signed):
    result = client.read_holding_registers(addr, count, slave=UNIT_ID)
    if result.isError():
        return None
    if count == 1:
        val = result.registers[0]
        return val - 65536 if signed and val > 32767 else val
    raw = (result.registers[0] << 16) | result.registers[1]
    return raw - 4294967296 if signed and raw > 2147483647 else raw

# ===== Main =====
client = ModbusTcpClient(LOGGER_IP, port=PORT, timeout=5)
if not client.connect():
    print("ERROR: ไม่สามารถเชื่อมต่อ SmartLogger ได้")
    exit(1)

print(f"เชื่อมต่อ {LOGGER_IP}:{PORT} สำเร็จ\n")
for addr, count, name, unit, scale, signed in REGISTERS:
    raw = read_value(client, addr, count, signed)
    if raw is not None:
        print(f"  {name:20s} = {raw * scale:>12.2f} {unit}")
    else:
        print(f"  {name:20s} = ERROR")

client.close()

solar/{building_id}/data

# ตัวอย่าง:
solar/building_1/data
solar/building_2/data

{
  "ts": "2026-06-15T10:30:00+07:00",
  "building": "building_1",
  "active_power_kw": 150.42,
  "daily_energy_kwh": 450.20,
  "total_energy_kwh": 125430.80,
  "grid_voltage_a": 230.5,
  "grid_voltage_b": 231.2,
  "grid_voltage_c": 229.8,
  "grid_frequency_hz": 50.01,
  "inverter_online": 5,
  "plant_status": 1
}

import json, time
from datetime import datetime, timezone, timedelta
from pymodbus.client import ModbusTcpClient
import paho.mqtt.client as mqtt

TZ = timezone(timedelta(hours=7))

# ===== Config =====
LOGGER_IP    = "192.168.1.100"
MQTT_BROKER  = "broker.vekin.tech"
BUILDING     = "building_1"
POLL_INTERVAL = 60  # วินาที

# ===== Connect =====
mb = ModbusTcpClient(LOGGER_IP, port=502, timeout=5)
mq = mqtt.Client(client_id=f"solar-{BUILDING}")
mq.connect(MQTT_BROKER, 1883)
mq.loop_start()
mb.connect()

while True:
    data = poll_all_registers(mb)  # ฟังก์ชันจากตัวอย่างด้านบน
    data["ts"] = datetime.now(TZ).isoformat()
    data["building"] = BUILDING

    mq.publish(f"solar/{BUILDING}/data", json.dumps(data), qos=1)
    print(f"[{data['ts']}] {data['active_power_kw']} kW")
    time.sleep(POLL_INTERVAL)