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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160

use aiot::{dm::recv::RecvEnum, DataModelMsg, DataModelOptions, MqttClient, ThreeTuple};
use anyhow::Result;
use log::*;
use serde_json::json;

#[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 options = DataModelOptions::new();
    let mut dm = conn.data_model(options)?;
    dm.init().await?;

    dm.send(DataModelMsg::property_post(json!({
        "LightSwitch": 0
    })))
    .await?;
    dm.send(DataModelMsg::event_post(
        "Error".to_string(),
        json!({
            "ErrorCode": 0
        }),
    ))
    .await?;

    let mut history = Vec::new();
    history.push(json!({
      "identity": {
        "productKey": "",
        "deviceName": ""
      },
      "properties": [
        {
          "Power": {
            "value": "on",
            "time": 1524448722000u64
          },
          "WF": {
            "value": "3",
            "time": 1524448722000u64
          }
        },
        {
          "Power": {
            "value": "on",
            "time": 1524448722000u64
          },
          "WF": {
            "value": "3",
            "time": 1524448722000u64
          }
        }
      ],
      "events": [
        {
          "alarmEvent": {
            "value": {
              "Power": "on",
              "WF": "2"
            },
            "time": 1524448722000u64
          },
          "alertEvent": {
            "value": {
              "Power": "off",
              "WF": "3"
            },
            "time": 1524448722000u64
          }
        }
      ]
    }));
    history.push(json!({
      "identity": {
        "productKey": "",
        "deviceName": ""
      },
      "properties": [
        {
          "Power": {
            "value": "on",
            "time": 1524448722000u64
          },
          "WF": {
            "value": "3",
            "time": 1524448722000u64
          }
        }
      ],
      "events": [
        {
          "alarmEvent": {
            "value": {
              "Power": "on",
              "WF": "2"
            },
            "time": 1524448722000u64
          },
          "alertEvent": {
            "value": {
              "Power": "off",
              "WF": "3"
            },
            "time": 1524448722000u64
          }
        }
      ]
    }));
    dm.send(DataModelMsg::history_post(history)).await?;

    loop {
        tokio::select! {
            Ok(notification) = conn.poll() => {
                // 主循环的 poll 是必须的
                info!("Received = {:?}", notification);
            },
            Ok(recv) = dm.poll() => {
                match recv {
                    RecvEnum::ServicePropertySet(data) => {
                        info!("属性设置 {:?}", data);
                        // 以下代码演示如何对来自云平台的属性设置指令进行应答
                        dm.send(DataModelMsg::property_set_reply(200, json!({}), data.msg_id)).await?;
                    },
                    RecvEnum::EventPostReply(data) => {
                        // 属性上报, 事件上报, 获取期望属性值或者删除期望属性值的应答
                        info!("服务端应答 {:?}", data);
                    },
                    RecvEnum::Service(data) => {
                        info!("异步服务调用 {:?}", data);
                        // 以下代码演示如何对来自云平台的异步服务调用进行应答
                        dm.send(DataModelMsg::async_service_reply(200, json!({"dataA": 20}), data.msg_id, data.service_id)).await?;
                    },
                    RecvEnum::RrpcService(data) => {
                        info!("同步服务调用 {:?}", data);
                        // 以下代码演示如何对来自云平台的同步服务调用进行应答
                        dm.send(DataModelMsg::sync_service_reply(200, json!({}), data.rrpc_id, data.msg_id, data.service_id)).await?;
                    },
                    RecvEnum::ModelDownRaw(data) => {
                        info!("下行二进制数据 {:?}", data);
                        // 以下代码演示如何发送二进制格式数据, 若使用需要有相应的数据透传脚本部署在云端
                        let raw = vec![0x01, 0x02];
                        dm.send(DataModelMsg::raw_data(raw)).await?;
                    },
                    RecvEnum::RrpcDownRaw(data) => {
                        info!("二进制格式的同步服务调用 {:?}", data);
                        let raw = vec![0x01, 0x02];
                        dm.send(DataModelMsg::raw_service_reply(raw, data.rrpc_id)).await?;
                    },
                    RecvEnum::ModelUpRawReply(data) => {
                        info!("上行二进制数据后, 云端的回复报文 {:?}", data);
                    },
                    _ => {}
                }
            }
        }
    }
}