Azure IoT SDK for Rust

Self developed library to interact with Azure IoT Hub using MQTT protocol

Running examples

Copy the sample config file bash cp examples/config.sample.toml examples/config.toml

Edit values in examples/config.toml with your iot hub host, device and primary key

Usage

```rust

[macro_use]

extern crate log;

use azureiotsdk::{client::IoTHubClient, message::Message};

use serde::Deserialize;

[derive(Debug, Deserialize)]

struct DeviceConfig { hostname: String, deviceid: String, sharedaccess_key: String, }

impl DeviceConfig { fn fromenv() -> Result { let mut cfg = config::Config::default(); cfg.merge(config::File::withname("examples/config"))?; cfg.try_into() } }

[tokio::main]

async fn main() { envlogger::fromenv(envlogger::Env::default().defaultfilter_or("info")).init();

let DeviceConfig {
    hostname,
    device_id,
    shared_access_key,
} = DeviceConfig::from_env().unwrap();

let token_source = DeviceKeyTokenSource::new(
    &hostname,
    &device_id,
    &shared_access_key,
)
.unwrap();

let mut client = IoTHubClient::new(&hostname, device_id, token_source).await?;

info!("Initialized client");

let mut recv = client.get_receiver().await;
let receive_loop = async {
    while let Some(msg) = recv.recv().await {
        match msg {
            MessageType::C2DMessage(msg) => info!("Received message {:?}", msg),
            _ => {}
        }
    }
};

let msg = Message::new(b"Hello, world!".to_vec());
let sender = client.send_message(msg);

tokio::join!(receive_loop, sender);

} ```