IoT Platform：Node.js SDK使用說明

調用步驟

1. 已完成SDK用戶端初始化。具體內容，請參見初始化SDK。

2. 建立對應API的調用請求，產生${API名稱}+"Request"類對象執行個體request。

3. 通過對象執行個體request，設定API所需的請求參數值。

4. 建立${API名稱}+"Response"類的對象執行個體response承載響應結果：使用Client對象執行個體client的${API名稱}(request)方法，擷取API對應request的響應結果，包含服務端響應的body和headers。

5. 通過對象執行個體response的body成員對象，使用response.body.${返回參數的名稱}方法，可擷取對應返回參數的值。

   例如：response.body.success用於擷取是否調用成功的標識，其中Success為API的通用返回參數。通用返回參數還包含RequestId、ErrorMessage和Code。

6. 使用catch()方法處理異常報錯。

物聯網平台雲端API，請參見API列表。有關request中請求參數說明，及response中返回參數說明，請參見對應API文檔。

本文以調用Pub介面發布訊息到Topic為例。請求參數資訊，請參見Pub。

try {
    let client = Client.createClient("${accessKey}", "${accessKeySecret}");
    let request = new $Iot.PubRequest({
        // 物聯網平台執行個體ID。
        iotInstanceId: "${iotInstanceId}",
        // 產品ProductKey。
        productKey: "${productKey}",
        // 要發送的訊息主體，需通過Base64編碼。
        messageContent: "eyJ0ZXN0IjoidGFzayBwdWIgYnJvYWRjYXN0In0=",
        // 要接收訊息的裝置的自訂Topic。
        topicFullName: "/${productKey}/${deviceName}/user/get",
        // 指定訊息的發送方式，支援QoS0和QoS1。
        qos: 0,
    });
    let response = await client.pub(request);
    Console.log(Util.toJSONString($tea.toMap(response)));
} catch (error) {
    Console.log(error.message);
}

完整程式碼範例

import Iot, * as $Iot from '@alicloud/iot20180120';
import Util from '@alicloud/tea-util';
import Env from '@alicloud/darabonba-env';
import OpenApi, * as $OpenApi from '@alicloud/openapi-client';
import Console from '@alicloud/tea-console';
import * as $tea from '@alicloud/tea-typescript';


export default class Client {
  /**
   * 使用AK&SK初始化帳號Client。
   * @param accessKeyId
   * @param accessKeySecret
   * @param regionId
   * @return Client
   * @throws Exception
   */
  static createClient(): Iot {
    let config = new $OpenApi.Config({ });
    // 您的AccessKey ID。
    config.accessKeyId = process.env.ACCESS_KEY_ID;
    // 您的AccessKey Secret
    config.accessKeySecret = process.env.ACCESS_KEY_SECRET;
    // 您的可用性區域ID。
    config.regionId = "cn-shanghai";
    return new Iot(config);
   }


  static async main(args: string[]): Promise<void> {
    try {
      let client = Client.createClient("${accessKey}", "${accessKeySecret}");
      let request = new $Iot.PubRequest({
        // 物聯網平台執行個體ID。
        iotInstanceId: "${iotInstanceId}",
        // 產品ProductKey。
        productKey: "${productKey}",
        // 要發送的訊息主體，hello world Base64 String。
        messageContent: "eyJ0ZXN0IjoidGFzayBwdWIgYnJvYWRjYXN0In0=",
        // 要接收訊息的裝置的自訂Topic。
        topicFullName: "/${productKey}/${deviceName}/user/get",
        // 指定訊息的發送方式，支援QoS0和QoS1。
        qos: 0,
      });
      let response = await client.pub(request);
      Console.log(response.body.success);
      Console.log(response.body.requestId);
    } catch (error) {
      Console.log(error.message);
    }    
  }
}

Client.main(process.argv.slice(2));