为你自己的能源应用接入设备数据

# 申请凭据后，先用账号密码换 token
curl -X POST 'https://api.zenovaconnect.com/sol-emqx/login' \
  -d 'username=YOUR_USERNAME' \
  -d 'password=YOUR_PASSWORD'

# 响应：
# {
#   "success": true,
#   "code": 200,
#   "result": { "access_token": "eyJ..." }
# }

import requests

TOKEN = "eyJ..."
headers = {"Authorization": f"Bearer {TOKEN}"}

# 同步某个厂商账户下的电站和设备
resp = requests.get(
    "https://api.zenovaconnect.com/apiDevice/syncApiPlantAndDevice",
    headers=headers,
    params={"dataAccessUserId": "your-account-id"}
)

plants = resp.json()["result"]
print(f"同步了 {len(plants)} 个电站")

// 你的 Webhook endpoint，接收 ZenovaConnect 推送的设备数据
app.post('/webhooks/zenova', (req, res) => {
  const payload = req.body;

  // 验证签名 (HMAC-SHA256)
  const sig = req.headers['x-zenova-signature'];
  if (!verifyHmac(payload, sig, process.env.ZENOVA_SECRET)) {
    return res.status(401).end();
  }

  // payload 是统一 BaseData schema
  const { DataSources, InverterSN, EDay, PowerACOutputActive } = payload;
  console.log(`[${DataSources}] ${InverterSN} 当日 ${EDay} kWh`);

  res.status(200).end();
});