aiot 0.10.0

Rust Link SDK (Aliyun IoT) based on Alink Protocol.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55

use aiot::tag;
use aiot::tag::base::DeviceInfoKeyValue;
use aiot::{MqttClient, ThreeTuple};
use anyhow::Result;
use log::*;
use tag::recv::TagRecv;

#[tokio::main]
async fn main() -> Result<()> {
    env_logger::init();

    let host = "iot-as-mqtt.cn-shanghai.aliyuncs.com";
    let three = ThreeTuple::from_env();
    let mut conn = MqttClient::new_public_tls(host, &three)?.connect();
    let mut tag = conn.tag()?;
    tag.update(
        vec![
            DeviceInfoKeyValue {
                attr_key: String::from("key1"),
                attr_value: String::from("key1_v"),
            },
            DeviceInfoKeyValue {
                attr_key: String::from("key2"),
                attr_value: String::from("key2_v"),
            },
        ],
        true,
    )
    .await?;
    // let deleted_keys = vec![
    //    "key1",
    //    "key2"
    // ];
    // tag.delete(&deleted_keys, true).await?;

    loop {
        tokio::select! {
            Ok(notification) = conn.poll() => {
                // 主循环的 poll 是必须的
                info!("Received = {:?}", notification);
            }
            Ok(recv) = tag.poll() => {
                   match recv {
                 TagRecv::DeviceInfoUpdateResponse(_response) => {
                    info!("DeviceInfoUpdateResponse");

                 },
                 TagRecv::DeviceInfoDeleteResponse(_response) => {
                    info!("DeviceInfoDeleteResponse");
                 },
              }
            }
        }
    }
}