Συνδρομή σε δεδομένα ενέργειας σε πραγματικό χρόνο μέσω MQTT Broker (Έκδοση 2025)

1. Εισαγωγή

IAMMETER-σύννεφοείναι μια επαγγελματική πλατφόρμα παρακολούθησης ενέργειας και διαχείρισης φωτοβολταϊκών. Εκτός από τις ισχυρές λειτουργίες οπτικοποίησης και αναφοράς, το IAMMETER-Cloud παρέχει επίσης ευέλικτες διεπαφές δεδομένων. Αυτό επιτρέπει σε χρήστες με προσαρμοσμένες απαιτήσεις να χρησιμοποιούν το IAMMETER-Cloud ωςενδιάμεσο λογισμικό δεδομένων, ανάκτηση δεδομένων μέσω προγραμματισμού μέσω κώδικα.

Υπάρχουν δύο βασικοί τρόποι για να λάβετε δεδομένα από το IAMMETER-Cloud χρησιμοποιώντας κώδικα:

• Εγγραφή στα δεδομένα μέσωΜεσίτης MQTT της IAMMETER(το επίκεντρο αυτού του άρθρου)
• Καλέστε τον εκπρόσωπο του IAMMETER-CloudAPI

Αυτός ο οδηγός εξηγεί πώς να εγγραφείτε στα θέματα του IAMMETER MQTT, πώς να ερμηνεύσετε δομές δεδομένων (τόσο για μονοφασικούς όσο και για τριφασικούς μετρητές) και πώς να εφαρμόσετε λειτουργικά παραδείγματα Python και Node.js.

2. Επισκόπηση του μεσίτη IAMMETER MQTT

Σημείωση:Ο μεσίτης IAMMETER MQTT σχεδιάστηκε αρχικά ωςυπηρεσία ανάπτυξης και δοκιμώνγια λόγους ευκολίας και δεν αποτελεί μέρος της τυπικής προσφοράς IAMMETER-Cloud (αν και είναι σταθερή και λειτουργεί για πάνω από 5 χρόνια). Για παραγωγή ή αναπτύξεις μεγάλης κλίμακας, συνιστούμε να ρυθμίσετε τοδικός σας μεσίτης MQTT.

Ρύθμιση παραμέτρων μεσολαβητή IAMMETER MQTT

παράμετρος	Περιγραφή
Διεύθυνση μεσίτη	mqtt.iammeter.com
Λιμάνι	1883(χωρίς SSL)
Όνομα χρήστη / Κωδικός πρόσβασης	Πρέπει να δημιουργηθεί σεIAMMETER Cloud → Ρυθμίσεις → Ρυθμίσεις MQTT
Μορφή θέματος	συσκευή/{SN}/πραγματικός χρόνος
Μορφή ωφέλιμου φορτίου	JSON

⚠️ Σπουδαίος:Κάνωδενχρησιμοποιήστε τα διαπιστευτήρια σύνδεσης στο IAMMETER Cloud εδώ. Πρέπει ναδημιουργήστε ένα αποκλειστικό όνομα χρήστη και κωδικό πρόσβασης MQTTστον πίνακα ελέγχου του IAMMETER Cloud.

Ρύθμιση παραμέτρων μετρητή IAMMETER για χρήση της λειτουργίας MQTT

Ρυθμίστε το μετρητή IAMMETER σεΛειτουργία μεταφόρτωσης MQTT(βλέπωοδηγός διαμόρφωσης υλικολογισμικού) και εισαγάγετε τις παραμέτρους του IAMMETER MQTT Broker.

3. Μορφή θέματος MQTT

Κάθε συσκευή IAMMETER δημοσιεύει τα δεδομένα σε πραγματικό χρόνο της με βάση το ακόλουθο θέμα:

συσκευή/{SN}/πραγματικός χρόνος

Οπου{Αριθμός Μητρώου}είναι ο σειριακός αριθμός του μετρητή σας. Για παράδειγμα, εάν ο αριθμός SN της συσκευής σας είναιDA2BD94, το θέμα θα είναι:

συσκευή/DA2BED94/πραγματικός χρόνος

Μπορείτε να εγγραφείτε σε αυτό το θέμα για να λαμβάνετε συνεχώς δεδομένα μετρήσεων σε πραγματικό χρόνο.

4. Μορφή δεδομένων

4.1 Μορφή δεδομένων μονοφασικού μετρητή

Ένας μονοφασικός μετρητής IAMMETER δημοσιεύει δεδομένα πραγματικού χρόνου σε μορφή JSON ως εξής:

{
"μέθοδος": "1-272",
"mac": "B0F8932A295C",
"έκδοση": "i.91.062T6",
"διακομιστής": "em",
"SN": "DA2BED94",
"Δεδομένα": [227.02, 1.81, 296.0, 21699.98, 0.00, 50.01, 0.72]
}

🟢 Σημειώσεις:

• Θετική ισχύς → κατανάλωση ενέργειας
• Αρνητική ισχύς → εξαγωγή ενέργειας (π.χ., ηλιακή τροφοδοσία)

4.2 Μορφή δεδομένων τριφασικού μετρητή (WEM3080T / WEM3046T / WEM3050T)

Οι τριφασικοί μετρητές IAMMETER δημοσιεύουν δεδομένα σε παρόμοια μορφή JSON, με τρεις πίνακες που αντιστοιχούν σε κάθε φάση.

{
"μέθοδος": "4-9",
"mac": "849DC2CEC625",
"έκδοση": "i.91.062T6",
"διακομιστής": "em",
"SN": "CB0A0CFB",
"EA": {
"Αντιδραστικό": [
[-111.0, 0.000, 176.750],
[-113.0, 0.000, 179.110],
[-114.0, 36.120, 144.410]
]
},
"Δεδομένα": [
[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]
]
}

Δεδομέναείναι μια λίστα που περιέχειτρεις πίνακες, το καθένα αντιστοιχεί σεφάση Α, Β και Γ. Κάθε εσωτερική συστοιχία έχει την ίδια δομή με την μονοφασικήΔεδομέναπαράταξη.

Εκτός από τα πραγματικά δεδομένα ισχύος, ότανΜέτρηση άεργου ισχύοςείναι ενεργοποιημένο, θα δείτε επίσης τοEAενότητα ως εξής:

"EA": {
"Αντιδραστικό": [
[-111,0, 0,000, 176,750],
[-113,0, 0,000, 179,110],
[-114,0, 36,120, 144,410]
]
}

Αυτή η ενότητα δείχνειδεδομένα αντιδραστικής μέτρησης, η οποία εμφανίζεται μόνο όταν τοαντιδραστική λειτουργία δοκιμήςείναι ενεργοποιημένο (δείτε το στιγμιότυπο οθόνης παρακάτω).

Κάθε πίνακας αντιπροσωπεύει τις τρεις φάσεις (A, B, C), δείχνονταςάεργος ισχύς (Q σε kVar)καιΕνεργός Ενέργεια (kVARh).

Q (kVar):Άεργος ισχύς — θετική = επαγωγική, αρνητική = χωρητικήkVARh:Άεργος ενέργεια — κάθε φάση περιλαμβάνει δύο τιμές kVARh: μία γιαεπαγωγικό φορτίοκαι ένα γιαχωρητικό φορτίο.

5. Παράδειγμα Python: Εγγραφή σε δεδομένα πραγματικού χρόνου

Παρακάτω είναι ένα λειτουργικό σενάριο Python που χρησιμοποιεί τοpaho-mqttβιβλιοθήκη.

εισαγωγή paho.mqtt.client ως mqtt
εισαγωγή json

# Ρύθμιση παραμέτρων MQTT Broker
MQTT_BROKER = "mqtt.iammeter.com"
MQTT_PORT = 1883
MQTT_USER = "your_mqtt_username" # Ορισμός στο IAMMETER Cloud → Ρυθμίσεις MQTT
MQTT_PASS = "your_mqtt_password"
TOPIC = "device/DA2BED94/realtime" # Αντικατάσταση με τον δικό σας SN συσκευής

# Επανάκληση όταν συνδεθεί με τον broker
def on_connect(client, userdata, flags, rc):
if rc == 0:

print("✅ Συνδέθηκε με επιτυχία στον broker IAMMETER MQTT")
client.subscribe(TOPIC)

print(f"📡 Εγγράφηκε στο θέμα: {TOPIC}")
else:

print(f"❌ Η σύνδεση απέτυχε με τον κωδικό {rc}")

# Επανάκληση όταν ληφθεί μήνυμα
def on_message(client, userdata, msg):
payload = json.loads(msg.payload.decode())

print("📊 Λήψη δεδομένων πραγματικού χρόνου:")

print(json.dumps(payload, indent=2, ensure_ascii=False))

# Αρχικοποίηση προγράμματος-πελάτη MQTT
client = mqtt.Client()
client.username_pw_set(MQTT_USER, MQTT_PASS)
client.on_connect = on_connect
client.on_message = on_message

# Σύνδεση με τον μεσίτη και έναρξη του βρόχου
client.connect(MQTT_BROKER, MQTT_PORT, 60)
client.loop_forever()

6. Παράδειγμα Node.js

Σας προτείνουμε να δοκιμάσετε αυτό το ενδιαφέρον έργο ανοιχτού κώδικα: ΧρησιμοποιείNode.jsγια να εγγραφείτε σε δεδομένα πραγματικού χρόνου από τον μεσίτη IAMMETER MQTT και να τα απεικονίσετε σε έναδιεπαφή χρήστη ιστού, δημιουργώντας έναν ωραίο πίνακα ελέγχου σε πραγματικό χρόνο.

🔗 https://github.com/lewei50/iammeterJS

7. Πρακτικές περιπτώσεις χρήσης

1. Έξυπνος οικιακός αυτοματισμόςΕνσωματώστε δεδομένα ισχύος σε πραγματικό χρόνο σεΒοηθός στο σπίτιήΚόμβος-ΚΟΚΚΙΝΟγια την ενεργοποίηση ενεργειών αυτοματισμού (π.χ., εκκίνηση ενός θερμαντήρα όταν η παραγωγή ηλιακής ενέργειας είναι υψηλή).
2. Οπτικοποίηση τοπικών δεδομένωνΑποθήκευση εισερχόμενων δεδομένων MQTT σεInfluxDBκαι οπτικοποιήστε το μεΠίνακες ελέγχου Grafana.
3. Ιδιωτικό cloud ή Edge ComputingΑνακτήστε δεδομένα ισχύος σε πραγματικό χρόνο απευθείας μέσω του MQTT για προσαρμοσμένες αναλύσεις ή λογική ελέγχου χωρίς να βασίζεστε στο IAMMETER Cloud.

8. Αντιμετώπιση προβλημάτων

9. Συμπέρασμα

ΧρησιμοποιώνταςΜεσίτης IAMMETER MQTT, μπορείτε εύκολα να έχετε πρόσβασηροές δεδομένων ενέργειας σε πραγματικό χρόνοαπό τις συσκευές IAMMETER σας. Είναι μια ισχυρή και ευέλικτη μέθοδος για τη δημιουργίατοπικούς πίνακες ελέγχου, έξυπνους αυτοματισμούς ή συστήματα βελτιστοποίησης ενέργειας που βασίζονται σε τεχνητή νοημοσύνη.

📘 βιβλιογραφικές αναφορές

• IAMMETER Firmware & Χαρακτηριστικά επικοινωνίας
• Τεκμηρίωση IAMMETER Cloud και MQTT API
• Αναπτύξτε τον δικό σας Πίνακα Ελέγχου Παρακολούθησης Ενέργειας χρησιμοποιώντας το NodeJS

Θα θέλατε να φτιάξω έναΈκδοση ανάρτησης ιστολογίου με μορφοποίηση Markdown(έτοιμο για δημοσίευση στο επίσημο ιστολόγιο του IAMMETER, με την επισήμανση σύνταξης και τους ενσωματωμένους συνδέσμους εικόνας ανέπαφα);