IoT Platform:Node.js 用 IoT Platform SDK の使用

手順

1. SDK を初期化します。詳細については、このトピックの「SDK の初期化」セクションをご参照ください。

2. リクエスト インスタンスを生成することで、${API 操作名}+"Request" クラスの API リクエストを作成します。

3. リクエスト インスタンスを使用して、リクエストパラメータを指定します。

4. 応答${API操作名}+"Response" クラスの ${API 操作名}(リクエスト)クライアント本文ヘッダー インスタンスを作成して、レスポンスを取得します。 インスタンスの メソッドを呼び出して、API リクエストに対するレスポンスを取得します。レスポンスには、サーバーから返された と が含まれます。

5. メソッドを呼び出して、レスポンスパラメーターの値を取得します。

   たとえば、response.body.success メソッドを呼び出して、成功 パラメーターを取得できます。このパラメーターは、リクエストが成功したかどうかを示す一般的なレスポンスパラメーターです。一般的なレスポンスパラメーターには、リクエスト ID、エラーメッセージ、コード も含まれます。

6. catch() メソッドを呼び出して、例外を処理します。

IoT Platform の API 操作の詳細については、「関数別の操作リスト」をご参照ください。各 API 操作のリクエストパラメーターとレスポンスパラメーターの詳細については、API リファレンスをご参照ください。

次の例は、Pub 操作を呼び出して Topic にメッセージをパブリッシュする方法を示しています。リクエストパラメーターの詳細については、「Pub」をご参照ください。

try {
    let client = Client.createClient("${accessKey}", "${accessKeySecret}");
    let request = new $Iot.PubRequest({
        // IoT Platform インスタンスの ID。
        iotInstanceId: "${iotInstanceId}",
        // プロダクトの ProductKey。
        productKey: "${productKey}",
        // 送信されるメッセージ本文。 Base64 でエンコードする必要があります。
        messageContent: "eyJ0ZXN0IjoidGFzayBwdWIgYnJvYWRjYXN0In0=",
        // メッセージをパブリッシュするために使用されるカスタム Topic。
        topicFullName: "/${productKey}/${deviceName}/user/get",
        // メッセージ送信モード。 IoT Platform SDK は QoS 0 と QoS 1 をサポートしています。
        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 {
  /**
   * アクセスキー ID とアクセスキーシークレットを使用して、クライアントを初期化します。
   * @param accessKeyId
   * @param accessKeySecret
   * @param regionId
   * @return Client
   * @throws Exception
   */
  static createClient(): Iot {
    let config = new $OpenApi.Config({ });
    // アクセスキー ID。
    config.accessKeyId = process.env.ACCESS_KEY_ID;
    // アクセスキーシークレット。
    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({
        // IoT Platform インスタンスの ID。
        iotInstanceId: "${iotInstanceId}",
        // プロダクトの ProductKey。
        productKey: "${productKey}",
        // 送信するメッセージ本文。 "hello world" を Base64 で文字列としてエンコードします。
        messageContent: "eyJ0ZXN0IjoidGFzayBwdWIgYnJvYWRjYXN0In0=",
        // メッセージをパブリッシュするために使用されるカスタム Topic。
        topicFullName: "/${productKey}/${deviceName}/user/get",
        // メッセージ送信モード。 IoT Platform SDK は QoS 0 と QoS 1 をサポートしています。
        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));