Go SDK使用说明

调用步骤

1. 已完成SDK客户端初始化。具体内容，请参见初始化SDK。

2. 创建对应API的调用请求，生成${API名称}+"Request"类对象实例request。

3. 通过对象实例request，使用request.${请求参数的名称}方法，设置API所需的请求参数值。

4. 创建${API名称}+"Response"类的对象实例response承载响应结果：使用Client对象实例client的${API名称}(request)方法，获取API对应request的响应结果，包含服务端响应的body和headers。

物联网平台云端API，请参见API列表。有关request中请求参数说明，及response中返回参数说明，请参见对应API文档。

本文以调用Pub接口发布消息到Topic为例。请求参数信息，请参见Pub。

request := &iot.PubRequest{
    // 物联网平台实例ID。
    IotInstanceId: tea.String("${iotInstanceId}"),
    // 产品ProductKey。
    ProductKey: tea.String("${productKey}"),
    // 要发送的消息主体，hello world Base64 String。
    MessageContent: tea.String(base64.StdEncoding.EncodeToString([]byte("hello world"))),
    // 要接收消息的设备的自定义Topic。
    TopicFullName: tea.String("/${productKey}/${deviceName}/user/get"),
    // 指定消息的发送方式，支持QoS0和QoS1。
      Qos: tea.Int32(0),
}
response, _err := client.Pub(request)
if _err != nil {
  fmt.Print(_err.Error())
}
fmt.Printf("response is %#v\n", response)

完整代码示例

package main

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


/**
 * 使用AK&SK初始化账号Client
 * @param accessKeyId
 * @param accessKeySecret
 * @param regionId
 * @return Client
 * @throws Exception
 */
func CreateClient (accessKeyId *string, accessKeySecret *string) (_result *iot.Client, _err error) {
  config := &openapi.Config{}
  // 您的AccessKey ID。
  config.AccessKeyId = accessKeyId
  // 您的AccessKey Secret。
  config.AccessKeySecret = accessKeySecret
  // 您的可用区ID。
  config.RegionId = tea.String("cn-shanghai")
  _result = &iot.Client{}
  _result, _err = iot.NewClient(config)
  return _result, _err
}

func _main (args []*string) (_err error) {
  tryErr := func()(_e error) {
    defer func() {
      if r := tea.Recover(recover()); r != nil {
        _e = r
      }
    }()
    client, _err := CreateClient(tea.String("${accessKey}"), tea.String("${accessKeySecret}"))
    if _err != nil {
      return _err
    }

    request := &iot.PubRequest{
        // 物联网平台实例ID。
        IotInstanceId: tea.String("${iotInstanceId}"),
        // 产品ProductKey。
        ProductKey: tea.String("${productKey}"),
        // 要发送的消息主体，hello world Base64 String。
        MessageContent: tea.String(base64.StdEncoding.EncodeToString([]byte("hello world"))),
        // 要接收消息的设备的自定义Topic。
        TopicFullName: tea.String("/${productKey}/${deviceName}/user/get"),
        // 指定消息的发送方式，支持QoS0和QoS1。
          Qos: tea.Int32(0),
    }
    response, _err := client.Pub(request)
    if _err != nil {
      fmt.Print(_err.Error())
    }
    console.Log(util.ToJSONString(tea.ToMap(response)))
    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())
    }
    console.Log(error.Message)
  }
  return _err
}


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