IoT Platform:Gunakan IoT Platform SDK untuk Go

Prosedur

1. Inisialisasi SDK. Untuk informasi lebih lanjut, lihat Inisialisasi SDK.

2. Buat permintaan API dengan menghasilkan instance request yang nama kelasnya dalam format ${Nama API}+"Request".

3. Panggil metode request.${Parameter Permintaan} dari instance request untuk menentukan parameter permintaan.

4. Buat instance response yang nama kelasnya dalam format ${Nama API}+"Response" untuk mendapatkan respons. Panggil metode ${Nama API}(request) dari instance client untuk mendapatkan respons terhadap permintaan API. Respons mencakup body dan headers yang dikembalikan oleh server.

Untuk informasi lebih lanjut tentang operasi API dari IoT Platform, lihat Daftar operasi berdasarkan fungsi. Untuk informasi lebih lanjut tentang parameter permintaan dan respons dari setiap operasi API, lihat referensi API.

Contoh berikut menunjukkan cara memanggil operasi Pub untuk menerbitkan pesan ke topik. Untuk informasi lebih lanjut tentang parameter permintaan, lihat 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
      }
    }()
    // Salin kode untuk dijalankan, harap cetak nilai pengembalian API sendiri.
    _, _err = client.PubWithOptions(pubRequest, runtime)
    if _err != nil {
      return _err
    }

    return nil
  }()

Kode sampel lengkap

// File ini dibuat secara otomatis, jangan edit. Terima kasih.
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"
)


/**
 * Inisialisasi Client dengan AccessKey dari akun
 * @param accessKeyId
 * @param accessKeySecret
 * @return Client
 * @throws Exception
 */
func CreateClient (accessKeyId *string, accessKeySecret *string) (_result *iot20180120.Client, _err error) {
  config := &openapi.Config{
    // Diperlukan, AccessKey ID Anda
    AccessKeyId: accessKeyId,
    // Diperlukan, AccessKey secret Anda
    AccessKeySecret: accessKeySecret,
  }
  // Lihat 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) {
  // Pastikan variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_ID dan ALIBABA_CLOUD_ACCESS_KEY_SECRET telah disetel.
  // Kebocoran kode proyek dapat mengakibatkan kebocoran AccessKey, yang mengancam keamanan semua sumber daya di bawah akun. Contoh kode berikut dipanggil menggunakan variabel lingkungan untuk mendapatkan AccessKey, hanya sebagai referensi. Disarankan untuk menggunakan kredensial STS yang lebih aman. Untuk kredensial lainnya, silakan merujuk ke: 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
      }
    }()
    // Salin kode untuk dijalankan, harap cetak nilai pengembalian API sendiri.
    _, _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())
    }
    // Hanya contoh pencetakan. Harap berhati-hati dalam penanganan pengecualian dan jangan abaikan pengecualian langsung dalam proyek teknik.
    // cetak pesan kesalahan
    fmt.Println(tea.StringValue(error.Message))
    // Silakan klik tautan di bawah ini untuk diagnosis.
    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)
  }
}