Οι αισθητήρες ήδη στέλνουν δεδομένα μέσω MQTT, αλλά δεν αποθηκεύοντ…
任务
Οι αισθητήρες ήδη στέλνουν δεδομένα μέσω MQTT, αλλά δεν αποθηκεύονται πουθενά — έρχονται και χάνονται. Θέλω όλα αυτά να συσσωρεύονται σε μια βάση με βάση τον χρόνο, ώστε να μπορώ μετά να δω τους μέσους όρους κάθε λεπτού.
解决方案规划
Τι θα κατασκευάσουμε
- Broker MQTT με persistent subscription που συλλαμβάνει όλα τα εισερχόμενα μηνύματα χωρίς απώλειες.
- Time-series βάση δεδομένων (π.χ. TimescaleDB ή InfluxDB) όπου κάθε μήνυμα αποθηκεύεται με ακριβή timestamp.
- Αυτοματοποιημένα aggregations (1-λεπτιαίοι μέσοι όροι) μέσω scheduled queries ή continuous aggregates.
Πώς λειτουργεί
- Τα υπάρχοντα sensors συνεχίζουν να δημοσιεύουν μέσω MQTT — χωρίς αλλαγή στο firmware τους.
- Ένα lightweight service (Node-RED ή custom consumer) εγγράφεται στα topics, αναλύει τα payloads και τα γράφει στη βάση.
- Η επεξεργασία γίνεται on-premise ή σε cloud, ανάλογα με τις απαιτήσεις συνδεσιμότητας του πλοίου (edge board / VSAT).
Επόμενο βήμα
Στείλτε μας ένα δείγμα payload MQTT (topic + JSON structure) και τον κατάλογο των αισθητήρων σας — ώστε να εκτιμήσουμε το schema της βάσης και να ξεκινήσουμε την υλοποίηση χωρίς καθυστέρηση.