eneuber/paramod-rust
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Daten für InfluxDB ohne type

Browse Source
This commit is contained in:
Eric Neuber 2026-03-18 17:28:21 +01:00
parent 3ed80f4b68
commit 68140a0c45
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/influx.rs
View File

@ -31,7 +31,7 @@ pub fn start_influx_thread(config: Arc<Mutex<AppConfig>>, values: Arc<Mutex<Modb
if should_write(&config, name, "input_register") { if should_write(&config, name, "input_register") {
let point = WriteQuery::new(Timestamp::from(Utc::now()), measurement.clone()) let point = WriteQuery::new(Timestamp::from(Utc::now()), measurement.clone())
.add_field(name, *v) .add_field(name, *v)
.add_tag("type", "input_register") // .add_tag("type", "input_register")
.add_tag("location", location.as_str()) .add_tag("location", location.as_str())
.to_owned(); .to_owned();
points.push(point); points.push(point);
@ -44,7 +44,7 @@ pub fn start_influx_thread(config: Arc<Mutex<AppConfig>>, values: Arc<Mutex<Modb
if should_write(&config, name, "holding_register") { if should_write(&config, name, "holding_register") {
let point = WriteQuery::new(Timestamp::from(Utc::now()), measurement.clone()) let point = WriteQuery::new(Timestamp::from(Utc::now()), measurement.clone())
.add_field(name, *v) .add_field(name, *v)
.add_tag("type", "holding_register") // .add_tag("type", "holding_register")
.add_tag("location", location.as_str()) .add_tag("location", location.as_str())
.to_owned(); .to_owned();
points.push(point); points.push(point);
@ -57,7 +57,7 @@ pub fn start_influx_thread(config: Arc<Mutex<AppConfig>>, values: Arc<Mutex<Modb
if should_write(&config, name, "coils") { if should_write(&config, name, "coils") {
let point = WriteQuery::new(Timestamp::from(Utc::now()), measurement.clone()) let point = WriteQuery::new(Timestamp::from(Utc::now()), measurement.clone())
.add_field(name, *v) .add_field(name, *v)
.add_tag("type", "coils") // .add_tag("type", "coils")
.add_tag("location", location.as_str()) .add_tag("location", location.as_str())
.to_owned(); .to_owned();
points.push(point); points.push(point);