調用步驟

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));