Go SDK instructions

Steps

1. Initialize the SDK client. For more information, see Initialize the SDK.

2. Create a request for the API call to generate a request object instance of the ${API_Name}+"Request" class.

3. Use the request object instance to call the request.${Request_Parameter_Name} method and set the required request parameters for the API.

4. Create a response object instance of the ${API_Name}+"Response" class to store the response. Use the client object instance to call the ${API_Name}(request) method and obtain the API response. The response includes the body and headers from the server.

For more information about IoT Platform cloud APIs, see API list. For descriptions of the request parameters in the request and the response parameters in the response, see the documentation for the specific API.

This topic uses the Pub API as an example to show how to publish a message to a topic. For information about request parameters, see 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
	}()

Complete code example

// 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"
)


/**
 * Use an AccessKey pair (AccessKey ID and AccessKey secret) to initialize a client.
 * @param accessKeyId
 * @param accessKeySecret
 * @return Client
 * @throws Exception
 */
func CreateClient (accessKeyId *string, accessKeySecret *string) (_result *iot20180120.Client, _err error) {
  config := &openapi.Config{
    // Required. Your AccessKey ID.
    AccessKeyId: accessKeyId,
    // Required. Your AccessKey secret.
    AccessKeySecret: accessKeySecret,
  }
  // For more information about the endpoint, see 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) {
  // Make sure that the ALIBABA_CLOUD_ACCESS_KEY_ID and ALIBABA_CLOUD_ACCESS_KEY_SECRET environment variables are set in your code execution environment.
  // Leaking the project code may cause the AccessKey pair to be leaked and threaten the security of all resources in your account. The following code provides an example of how to call the API using environment variables to obtain the AccessKey pair. This method is for reference only. We recommend that you use a more secure method, such as 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{
    // The ProductKey of the product.
    ProductKey: tea.String("${productKey}"),
    // The ID of the IoT Platform instance.
    IotInstanceId: tea.String("${iotInstanceId}"),
    DeviceName: tea.String("${deviceName}"),
    // The custom topic of the device that receives the message.
    TopicFullName: tea.String("/${productKey}/${deviceName}/user/get"),
    // The message body to send: {"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
      }
    }()
    // If you copy the code to run, print the return value of the API call.
    _, _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())
    }
    // The following code is for demonstration purposes only. Handle exceptions with caution. Do not ignore exceptions in your project.
    // Error message
    fmt.Println(tea.StringValue(error.Message))
    // Diagnosis address
    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)
  }
}