Romain/rust_mosquitto
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update cargo

Browse Source
This commit is contained in:
Romulus21
2024-10-21 18:08:09 +02:00
parent 2b0fe78b38
commit f13e47f3c7
2 changed files with 1060 additions and 618 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1637
Cargo.lock generated
View File

File diff suppressed because it is too large Load Diff

41
src/reccord.rs
View File

@@ -33,25 +33,26 @@ pub fn message(message: paho_mqtt::Message) {
let split: Vec<&str> = message.topic().split("/").collect(); let split: Vec<&str> = message.topic().split("/").collect();
let data = message.payload_str(); let data = message.payload_str();
let message_received = [MosquittoMessage { if split.len() == 3 {
service: split[0].to_string(), let message_received = [MosquittoMessage {
capteur: split[1].to_string(), service: split[0].to_string(),
type_donnee: split[2].to_string(), capteur: split[1].to_string(),
donnee: data.to_string(), type_donnee: split[2].to_string(),
}]; donnee: data.to_string(),
}];
let _res = conn.exec_batch( let _res = conn.exec_batch(
r"INSERT INTO donnees (service, capteur, type, donnee, date_donnee) r"INSERT INTO donnees (service, capteur, type, donnee, date_donnee)
VALUES (:service, :capteur, :type, :donnee, NOW())", VALUES (:service, :capteur, :type, :donnee, NOW())",
message_received.iter().map(|p| { message_received.iter().map(|p| {
params! { params! {
"service" => &p.service, "service" => &p.service,
"capteur" => &p.capteur, "capteur" => &p.capteur,
"type" => &p.type_donnee, "type" => &p.type_donnee,
"donnee" => &p.donnee, "donnee" => &p.donnee,
} }
}), }),
); );
//println!("topic : {:?} data : {}", split, data.to_string());
//println!("topic : {:?} data : {}", split, data.to_string()); }
} }