dnutiu/bme680-rust
dnutiu/bme680-rust
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

remove influx client example

Browse source
This commit is contained in:
Denis-Cosmin Nutiu 2024-02-25 20:48:36 +02:00
parent 28eedb1266
commit 38cf1075c8
2 changed files with 2 additions and 97 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
Cargo.toml
View file

@ -15,13 +15,8 @@ maintenance = { status = "passively-maintained" }
bitflags = "1.2"
embedded-hal = "=1.0.0"
log = "0.4"
serde = { version = "1.0", optional = true, default-features = false }
serde = { version = "1.0", optional = true, default-features = false, features = ["derive"] }
linux-embedded-hal = "0.4.0"
[dev-dependencies]
env_logger = "0.9"
futures = { version = "0.3" }
i2cdev = "0.5"
influx_db_client = { version = "0.5", default-features= false, features = ["rustls-tls"] }
tokio = {version = "1.5", features = ["full"] }
url = "2.1"
env_logger = "0.9"

90
examples/influx_client.rs
View file

@ -1,90 +0,0 @@
///
/// This example demonstrates how to read values from the sensor and
/// continously send them to an influx database.
/// Make sure you adapt the influx constants and likely also the i2c device id and I2CAddress.
///
use bme680::{
Bme680, FieldDataCondition, I2CAddress, IIRFilterSize, OversamplingSetting, PowerMode,
SettingsBuilder,
};
use influx_db_client::{points, Client, Point, Points, Precision, Value};
use linux_embedded_hal::*;
use std::time::Duration;
use tokio::time::sleep;
use url::Url;
const INFLUX_ADDRESS: &str = "http://127.0.0.1:8086";
const INFLUX_USER: &str = "user";
const INFLUX_PASSWORD: &str = "pass";
const INFLUX_DATABASE: &str = "influxdb";
#[tokio::main]
async fn main() -> Result<(), ()> {
// Init device
let i2c = I2cdev::new("/dev/i2c-1").unwrap();
let mut delayer = Delay {};
let mut dev = Bme680::init(i2c, &mut delayer, I2CAddress::Primary)
.map_err(|e| eprintln!("Init failed: {:?}", e))?;
let settings = SettingsBuilder::new()
.with_humidity_oversampling(OversamplingSetting::OS2x)
.with_pressure_oversampling(OversamplingSetting::OS4x)
.with_temperature_oversampling(OversamplingSetting::OS8x)
.with_temperature_filter(IIRFilterSize::Size3)
.with_gas_measurement(Duration::from_millis(1500), 320, 25)
.with_run_gas(true)
.build();
dev.set_sensor_settings(&mut delayer, settings)
.map_err(|e| eprintln!("Setting sensor settings failed: {:?}", e))?;
let client = Client::new(Url::parse(INFLUX_ADDRESS).unwrap(), INFLUX_DATABASE)
.set_authentication(INFLUX_USER, INFLUX_PASSWORD);
loop {
dev.set_sensor_mode(&mut delayer, PowerMode::ForcedMode)
.map_err(|e| eprintln!("Setting sensor mode failed: {:?}", e))?;
let (data, state) = dev
.get_sensor_data(&mut delayer)
.map_err(|e| eprintln!("Retrieving sensor data failed: {:?}", e))?;
println!("State {:?}", state);
println!("Temperature {}°C", data.temperature_celsius());
println!("Pressure {}hPa", data.pressure_hpa());
println!("Humidity {}%", data.humidity_percent());
println!("Gas Resistence {}Ω", data.gas_resistance_ohm());
if state == FieldDataCondition::NewData {
let temperature_f = ipoint(
"temperature",
Value::Float(data.temperature_celsius() as f64),
);
let pressure_f = ipoint("pressure", Value::Float(data.pressure_hpa() as f64));
let humidity_f = ipoint("humidity", Value::Float(data.humidity_percent() as f64));
let gas_f = ipoint(
"gasresistence",
Value::Float(data.gas_resistance_ohm() as f64),
);
let points = points!(temperature_f, pressure_f, humidity_f, gas_f);
if let Err(e) = client
.write_points(points, Some(Precision::Seconds), None)
.await
{
eprintln!("Error: {:?}", e);
}
}
sleep(Duration::from_secs(10)).await;
}
}
/// Sends a measured value to the influx database
fn ipoint(type_name: &str, value: Value) -> Point {
let point = Point::new("sensor")
.add_field("value", value)
.add_tag("id", Value::String("VMAC".to_string()))
.add_tag("name", Value::String("bme680".to_string()))
.add_tag("type", Value::String(type_name.to_string()));
point
}