調(diào)用步驟

1. 已完成SDK客戶端初始化。具體內(nèi)容，請參見初始化SDK。

2. 創(chuàng)建對應(yīng)API的調(diào)用請求，生成${API名稱}+"Request"類對象實例request。

3. 通過對象實例request，使用request.${請求參數(shù)的名稱}方法，設(shè)置API所需的請求參數(shù)值。

4. 創(chuàng)建${API名稱}+"Response"類的對象實例response承載響應(yīng)結(jié)果：使用Client對象實例client的${API名稱}(request)方法，獲取API對應(yīng)request的響應(yīng)結(jié)果，包含服務(wù)端響應(yīng)的body和headers。

物聯(lián)網(wǎng)平臺云端API，請參見API列表。有關(guān)request中請求參數(shù)說明，及response中返回參數(shù)說明，請參見對應(yīng)API文檔。

本文以調(diào)用Pub接口發(fā)布消息到Topic為例。請求參數(shù)信息，請參見Pub。

	pubRequest := &iot20180120.PubRequest{
		ProductKey:     tea.String("${productKey}"),
		IotInstanceId:  tea.String("${iotInstanceId}"),
		DeviceName:     tea.String("${deviceName}"),
		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
			}
		}()
		resp, _err := client.PubWithOptions(pubRequest, runtime)
		if _err != nil {
			return _err
		}

		console.Log(util.ToJSONString(resp))

		return nil
	}()

完整代碼示例

// This file is auto-generated, don't edit it. Thanks.
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"
)


/**
 * 使用AK&SK初始化賬號Client
 * @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 Secret
    AccessKeySecret: accessKeySecret,
  }
  // Endpoint 請參考 https://api.aliyun.com/product/Iot
  config.Endpoint = tea.String("iot.cn-shanghai.aliyuncs.com")
  _result = &iot20180120.Client{}
  _result, _err = iot20180120.NewClient(config)
  return _result, _err
}

func _main (args []*string) (_err error) {
  // 請確保代碼運行環(huán)境設(shè)置了環(huán)境變量 ALIBABA_CLOUD_ACCESS_KEY_ID 和 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
  // 工程代碼泄露可能會導(dǎo)致 AccessKey 泄露，并威脅賬號下所有資源的安全性。以下代碼示例使用環(huán)境變量獲取 AccessKey 的方式進(jìn)行調(diào)用，僅供參考，建議使用更安全的 STS 方式
  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{
    // 產(chǎn)品ProductKey。
    ProductKey: tea.String("${productKey}"),
    // 物聯(lián)網(wǎng)平臺實例ID。
    IotInstanceId: tea.String("${iotInstanceId}"),
    DeviceName: tea.String("${deviceName}"),
    // 要接收消息的設(shè)備的自定義Topic。
    TopicFullName: tea.String("/${productKey}/${deviceName}/user/get"),
    // 要發(fā)送的消息主體：{"test":"task pub broadcast"}
    MessageContent: tea.String("eyJ0ZXN0IjoidGFzayBwdWIgYnJvYWRjYXN0In0="),
  }
  runtime := &util.RuntimeOptions{}
  tryErr := func()(_e error) {
    defer func() {
      if r := tea.Recover(recover()); r != nil {
        _e = r
      }
    }()
    // 復(fù)制代碼運行請自行打印 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())
    }
    // 此處僅做打印展示，請謹(jǐn)慎對待異常處理，在工程項目中切勿直接忽略異常。
    // 錯誤 message
    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)
  }
}