Reaaliaikainen energiatietojen tilaus MQTT Brokerin kautta (2025-versio)
1. Esittely
IAMMETER-pilvion ammattimainen energiankulutuksen seuranta- ja aurinkosähkön hallinta-alusta. Tehokkaiden visualisointi- ja raportointitoimintojensa lisäksi IAMMETER-Cloud tarjoaa myös joustavia dataliittymiä. Tämä mahdollistaa räätälöityjen vaatimusten omaaville käyttäjille IAMMETER-Cloudin käytön…datan väliohjelmisto, hakemalla tietoja ohjelmallisesti koodin avulla.
IAMMETER-Cloudista voi saada tietoja koodin avulla kahdella päätavalla:
- Tilaa tiedot kauttaIAMMETERin MQTT-välittäjä(tämän artikkelin painopiste)
- Soita IAMMETER-Cloudin edustajalleAPI-rajapinnat
Tässä oppaassa selitetään, miten IAMMETER MQTT -aiheita tilataan, miten tulkitaan tietorakenteita (sekä yksi- että kolmivaiheisille mittareille) ja miten toteutetaan toimivia Python- ja Node.js-esimerkkejä.
2. IAMMETER MQTT -välittäjän yleiskatsaus
merkintä:IAMMETER MQTT Broker suunniteltiin alun perinkehitys- ja testauspalvelumukavuussyistä eikä se ole osa IAMMETER-Cloudin vakiotarjontaa (vaikka se onkin toiminut vakaasti ja yli 5 vuotta). Tuotantoympäristöissä tai laajamittaisissa käyttöönotoissa suosittelemme, että määritätoma MQTT-välittäjä.
IAMMETER MQTT -välittäjän konfigurointi
| parametri | Kuvaus |
|---|---|
| Välittäjän osoite | mqtt.iammeter.com |
| Portti | 1883(ei-SSL) |
| Käyttäjätunnus / Salasana | On luotava vuonnaIAMMETER Cloud → Asetukset → MQTT-asetukset![]() |
| Aihemuoto | laite/{SN}/reaaliaikainen |
| Hyötykuorman muoto | JSON |
⚠️ Tärkeää:TehdäeiKäytä tässä IAMMETER Cloud -kirjautumistietojasi. Sinun täytyyluo oma MQTT-käyttäjätunnus ja -salasanaIAMMETER Cloud -hallintapaneelissa.
IAMMETER-mittarin määrittäminen käyttämään MQTT-tilaa
Aseta IAMPERMETER-mittarisi asentoonMQTT-lataustila(katsolaiteohjelmiston konfigurointiopas) ja syötä IAMMETER MQTT Broker -parametrit.

3. MQTT-aihemuoto
Jokainen IAMMETER-laite julkaisee reaaliaikaiset tietonsa seuraavan aiheen alla:
laite/{SN}/reaaliaikainen
Jossa{SN}on mittarisi sarjanumero.
Esimerkiksi, jos laitteesi sarjanumero onDA2BED94, aiheena on:
laite/DA2BED94/reaaliaikainen
Voit tilata tämän aiheen saadaksesi jatkuvaa reaaliaikaista mittausdataa.
4. Tietomuoto
4.1 Yksivaiheisen mittarin tietomuoto
Yksivaiheinen IAMMETER-mittari julkaisee reaaliaikaista dataa JSON-muodossa seuraavasti:
{
”Menetelmä”: ”1-272”,
”Mac”: ”B0F8932A295C”,
”Versio”: ”i.91.062T6”,
”Palvelin”: ”em”,
”Sarjanumero”: ”DA2BED94”,
”Data”: [227.02, 1.81, 296.0, 21699.98, 0.00, 50.01, 0.72]
}
| indeksi | Ala | Kuvaus | Yksikkö |
|---|---|---|---|
| 1 | Jännite | Nykyinen linjajännite | V |
| 2 | Nykyinen | Nykyinen linjavirta | A |
| 3 | Tehoa | Aktiivinen teho | W |
| 4 | Eteenpäin suuntautuva energia | Tuontienergia (kulutettu) | kWh |
| 5 | Käänteinen energia | Vientienergia (syöttöenergia, aurinkoenergia) | kWh |
| 6 | Taajuus | Ruudukon taajuus | Hz |
| 7 | tehokerroin | Nykyinen tehokerroin | PF |
🟢 Huomautuksia:
- Positiivinen teho → energiankulutus
- Negatiivinen teho → energian vienti (esim. aurinkoenergian syöttö)
4.2 Kolmivaiheisen mittarin tietomuoto (WEM3080T / WEM3046T / WEM3050T)
Kolmivaiheiset IAMMETER-mittarit julkaisevat tiedot samankaltaisessa JSON-muodossa, jossa kutakin vaihetta vastaa kolme taulukkoa.
{
”Menetelmä”: ”4-9”,
”Mac”: ”849DC2CEC625”,
”Versio”: ”i.91.062T6”,
”Palvelin”: ”em”,
”SN”: ”CB0A0CFB”,
”EA”: {
”Reaktiivinen”: [
[-111.0, 0.000, 176.750],
[-113.0, 0.000, 179.110],
[-114.0, 36.120, 144.410]
]
},
”Tiedot”: [
[225.9, 1.260, 194,0, 305,110, 0,000, 49,99, 0,87],
[225,8, 1,260, 193,0, 302,690, 0,000, 49,99, 0,86],
[225,9, 1,260, 192,0, 300,890, 0,000, 49,99, 0,86]
]
}
Datason lista, joka sisältääkolme taulukkoa, kukin vastaavaiheet A, B ja C.
Jokaisella sisäryhmällä on sama rakenne kuin yksivaiheisellaDatataulukko.
| indeksi | Ala | Kuvaus | Yksikkö |
|---|---|---|---|
| 1 | Jännite | vaihejännite | V |
| 2 | Nykyinen | vaihevirta | A |
| 3 | Tehoa | Aktiivinen teho | W |
| 4 | Eteenpäin suuntautuva energia | Tuontienergia | kWh |
| 5 | Käänteinen energia | Vietyä energiaa | kWh |
| 6 | Taajuus | Ruudukon taajuus | Hz |
| 7 | tehokerroin | Vaiheen tehokerroin | PF |
Todellisen tehon tietojen lisäksi, kunLoistehon mittauson käytössä, näet myösEAosio seuraavasti:
”EA”: {
”Reaktiivinen”: [
[-111,0, 0,000, 176,750],
[-113,0, 0,000, 179,110],
[-114,0, 36,120, 144,410]
]
}
Tässä osiossa näytetäänreaktiiviset mittaustiedot, joka näkyy vain silloin, kunreaktiivinen testitoimintoon käytössä (katso alla oleva kuvakaappaus).

Jokainen matriisi edustaa kolmea vaihetta (A, B, C) ja näyttääloisteho (Q kVar-yksiköissä)jaLoisenergia (kVARh).
Q (kVar):Loisteho — positiivinen = induktiivinen, negatiivinen = kapasitiivinenkVARh:Loisenergia — jokainen vaihe sisältää kaksi kVARh-arvoa: yksiinduktiivinen kuormaja yksikapasitiivinen kuorma.
5. Python-esimerkki: Reaaliaikaisen datan tilaaminen
Alla on toimiva Python-skripti, joka käyttääpaho-mqttkirjasto.
import paho.mqtt.client as mqtt
import json
# MQTT Brokerin konfigurointi
MQTT_BROKER = "mqtt.iammeter.com"
MQTT_PORT = 1883
MQTT_USER = "oma_mqtt_käyttäjänimesi" # Asetettu IAMMETER Cloudissa → MQTT-asetukset
MQTT_PASS = "oma_mqtt_salasanasi"
TOPIC = "laite/DA2BED94/realtime" # Korvaa omalla laitteen sarjanumerolla
# Takaisinsoitto, kun yhteys välittäjään muodostettiin
def on_connect(client, userdata, flags, rc):
if rc == 0:
print("✅ Yhteys IAMMETER MQTT -välittäjään muodostettu onnistuneesti")
client.subscribe(TOPIC)
print(f"📡 Tilattu aihe: {TOPIC}")
else:
print(f"❌ Yhteys epäonnistui koodilla {rc}")
# Takaisinsoitto, kun viesti vastaanotetaan
def on_message(client, userdata, msg):
payload = json.loads(msg.payload.decode())
print("📊 Reaaliaikaista dataa vastaanotettu:")
print(json.dumps(payload, indent=2, ensure_ascii=False))
# MQTT-asiakkaan alustaminen
client = mqtt.Client()
client.username_pw_set(MQTT_USER, MQTT_PASS)
client.on_connect = on_connect
client.on_message = on_message
# Yhdistä välittäjään ja aloita silmukka
client.connect(MQTT_BROKER, MQTT_PORT, 60)
client.loop_forever()
6. Node.js-esimerkki
Suosittelemme kokeilemaan tätä mielenkiintoista avoimen lähdekoodin projektia: Se käyttääNode.jstilata reaaliaikaista dataa IAMMETER MQTT -välittäjältä ja visualisoida seweb-käyttöliittymä, luoden siistin reaaliaikaisen kojelaudan.
🔗 https://github.com/lewei50/iammeterJS
7. Käytännön käyttötapaukset
- Älykäs kodin automaatioIntegroi reaaliaikaiset tehotiedotKotiavustajataiSolmu-PUNAINENkäynnistääkseen automaatiotoimintoja (esim. käynnistääkseen lämmittimen, kun aurinkoenergian tuotanto on korkea).
- Paikallinen datan visualisointiTallenna saapuvat MQTT-tiedotInfluxDBja visualisoi seGrafana-kojelaudat.
- Yksityinen pilvi tai reunalaskentaHae reaaliaikaista tehodataa suoraan MQTT:n kautta mukautettua analytiikkaa tai ohjauslogiikkaa varten ilman IAMMETER Cloud -pilvipalvelua.
8. Vianmääritys
| Antaa | Mahdollinen syy / ratkaisu |
|---|---|
| Välittäjään ei voida muodostaa yhteyttä | Tarkista, onko MQTT-käyttäjätunnuksesi ja -salasanasi asetettu oikein IAMMETER Cloudissa. |
| Ei vastaanotettuja tietoja | Tarkista aiheesi muoto (laite/{SN}/reaaliaikainen) ja varmista, että mittari on verkossa. |
| Dataviive | Tarkista verkon vakaus tai Wi-Fi-signaalin voimakkuus. |
| Useita mittareita | Voit tilata useita aiheita samanaikaisesti (yhden per sarjanumero). |
9. Johtopäätös
KäyttämälläIAMMETER MQTT -välittäjä, pääset helposti käsiksireaaliaikaiset energiatietovirratIAMMETER-laitteistasi. Se on tehokas ja joustava menetelmä rakentaapaikalliset kojelaudat, älykkäät automaatiot tai tekoälypohjaiset energian optimointijärjestelmät.
📘 Viitteet
- IAMMETER-laiteohjelmisto ja tiedonsiirto-ominaisuudet
- IAMMETER Cloudin ja MQTT API:n dokumentaatio
- Kehitä oma energiankulutuksen seurantapaneelisi NodeJS:n avulla
Haluaisitko minun tekevänMarkdown-muotoiltu blogikirjoituksen versio(valmis julkaistavaksi IAMMETERin virallisella blogissa, syntaksin korostus ja upotetut kuvalinkit ehjinä)?
