阿里云物联网平台：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));