Οι αισθητήρες ήδη στέλνουν δεδομένα μέσω 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 της βάσης και να ξεκινήσουμε την υλοποίηση χωρίς καθυστέρηση.