阿里云物联网平台：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。

	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) {
  // 请确保代码运行环境设置了环境变量 ALIBABA_CLOUD_ACCESS_KEY_ID 和 ALIBABA_CLOUD_ACCESS_KEY_SECRET。
  // 工程代码泄露可能会导致 AccessKey 泄露，并威胁账号下所有资源的安全性。以下代码示例使用环境变量获取 AccessKey 的方式进行调用，仅供参考，建议使用更安全的 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{
    // 产品ProductKey。
    ProductKey: tea.String("${productKey}"),
    // 物联网平台实例ID。
    IotInstanceId: tea.String("${iotInstanceId}"),
    DeviceName: tea.String("${deviceName}"),
    // 要接收消息的设备的自定义Topic。
    TopicFullName: tea.String("/${productKey}/${deviceName}/user/get"),
    // 要发送的消息主体：{"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
      }
    }()
    // 复制代码运行请自行打印 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())
    }
    // 此处仅做打印展示，请谨慎对待异常处理，在工程项目中切勿直接忽略异常。
    // 错误 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)
  }
}