IoT Platform:Go 向け IoT Platform SDK の使用

手順

1. SDK を初期化します。詳細については、「SDK の初期化」をご参照ください。

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

3. request.${Request parameter} メソッドを request インスタンスで呼び出して、リクエストパラメーターを指定します。

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

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

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

  pubRequest := &iot20180120.PubRequest{
    ProductKey: tea.String("${productKey}"),
    IotInstanceId: tea.String("${iotInstanceId}"),
    TopicFullName: tea.String("/${productKey}/${deviceName}/user/get"),
    MessageContent: tea.String("eyJ0ZXN0IjoidGFzayBwdWIgYnJvYWRjYXN0In0="),
  }
  runtime := &util.RuntimeOptions{}
  tryErr := func()(_e error) {
    defer func() {
      if r := tea.Recover(recover()); r != nil {
        _e = r
      }
    }()
    // 実行するコードをコピーします。API の戻り値は自分で出力してください。
    _, _err = client.PubWithOptions(pubRequest, runtime)
    if _err != nil {
      return _err
    }

    return nil
  }()

完全なサンプルコード

// このファイルは自動生成されています。編集しないでください。ありがとうございます。
package main

import (
  "encoding/json"
  "strings"
  "fmt"
  "os"
  iot20180120  "github.com/alibabacloud-go/iot-20180120/v6/client"
  openapi  "github.com/alibabacloud-go/darabonba-openapi/v2/client"
  util  "github.com/alibabacloud-go/tea-utils/v2/service"
  "github.com/alibabacloud-go/tea/tea"
)


// アカウントの AccessKey を使用してクライアントを初期化します
// @param accessKeyId
// @param accessKeySecret
// @return Client
// @throws Exception
func CreateClient (accessKeyId *string, accessKeySecret *string) (_result *iot20180120.Client, _err error) {
  config := &openapi.Config{
    // 必須。AccessKey ID。
    AccessKeyId: accessKeyId,
    // 必須。AccessKey シークレット。
    AccessKeySecret: accessKeySecret,
  }
  // https://api.alibabacloud.com/product/Iot を参照してください。
  config.Endpoint = tea.String("iot.cn-beijing.aliyuncs.com")
  _result = &iot20180120.Client{}
  _result, _err = iot20180120.NewClient(config)
  return _result, _err
}

func _main (args []*string) (_err error) {
  // 環境変数 ALIBABA_CLOUD_ACCESS_KEY_ID と ALIBABA_CLOUD_ACCESS_KEY_SECRET が設定されていることを確認してください。
  // プロジェクトコードの漏洩は、AccessKey の漏洩につながる可能性があり、アカウント下のすべてのリソースのセキュリティに脅威をもたらします。次のコード例は、環境変数を使用して AccessKey を取得することによって呼び出されます。これは参照用です。より安全な STS クレデンシャルを使用することをお勧めします。その他のクレデンシャルについては、https://www.alibabacloud.com/help/en/alibaba-cloud-sdk-262060/latest/configure-credentials-378661 を参照してください。
  client, _err := CreateClient(tea.String(os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_ID")), tea.String(os.Getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET")))
  if _err != nil {
    return _err
  }

  pubRequest := &iot20180120.PubRequest{
    ProductKey: tea.String("${productKey}"),
    IotInstanceId: tea.String("${iotInstanceId}"),
    TopicFullName: tea.String("/${productKey}/${deviceName}/user/get"),
    MessageContent: tea.String("eyJ0ZXN0IjoidGFzayBwdWIgYnJvYWRjYXN0In0="),
  }
  runtime := &util.RuntimeOptions{}
  tryErr := func()(_e error) {
    defer func() {
      if r := tea.Recover(recover()); r != nil {
        _e = r
      }
    }()
    // 実行するコードをコピーします。API の戻り値は自分で出力してください。
    _, _err = client.PubWithOptions(pubRequest, runtime)
    if _err != nil {
      return _err
    }

    return nil
  }()

  if tryErr != nil {
    var error = &tea.SDKError{}
    if _t, ok := tryErr.(*tea.SDKError); ok {
      error = _t
    } else {
      error.Message = tea.String(tryErr.Error())
    }
    // 出力例のみです。例外処理に注意し、エンジニアリングプロジェクトで例外を直接無視しないでください。
    // エラーメッセージを出力します
    fmt.Println(tea.StringValue(error.Message))
    // 診断については、以下のリンクをクリックしてください。
    var data interface{}
    d := json.NewDecoder(strings.NewReader(tea.StringValue(error.Data)))
    d.Decode(&data)
    if m, ok := data.(map[string]interface{}); ok {
      recommend, _ := m["Recommend"]
      fmt.Println(recommend)
    }
    _, _err = util.AssertAsString(error.Message)
    if _err != nil {
      return _err
    }
  }
  return _err
}


func main() {
  err := _main(tea.StringSlice(os.Args[1:]))
  if err != nil {
    panic(err)
  }
}