创建产品

package com.huaweicloud.sdk.test;

import com.huaweicloud.sdk.core.auth.ICredential;
import com.huaweicloud.sdk.core.auth.AbstractCredentials;
import com.huaweicloud.sdk.core.auth.BasicCredentials;
import com.huaweicloud.sdk.core.exception.ConnectionException;
import com.huaweicloud.sdk.core.exception.RequestTimeoutException;
import com.huaweicloud.sdk.core.exception.ServiceResponseException;
import com.huaweicloud.sdk.core.region.Region;
import com.huaweicloud.sdk.iotda.v5.*;
import com.huaweicloud.sdk.iotda.v5.model.*;

import java.util.List;
import java.util.ArrayList;

public class CreateProductSolution {

    public static void main(String[] args) {
        // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
        // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
        String ak = System.getenv("CLOUD_SDK_AK");
        String sk = System.getenv("CLOUD_SDK_SK");
        // ENDPOINT：请在控制台的"总览"界面的"平台接入地址"中查看“应用侧”的https接入地址。
        String iotdaEndpoint = "<YOUR ENDPOINT>";
        String projectId = "{project_id}";

        ICredential auth = new BasicCredentials()
                .withProjectId(projectId)
                // 标准版/企业版需要使用衍生算法，基础版请删除配置"withDerivedPredicate";
                .withDerivedPredicate(AbstractCredentials.DEFAULT_DERIVED_PREDICATE) // Used in derivative ak/sk authentication scenarios
                .withAk(ak)
                .withSk(sk);

        IoTDAClient client = IoTDAClient.newBuilder()
                .withCredential(auth)
                // 标准版/企业版：需自行创建Region对象，基础版：请使用IoTDARegion的region对象，如"withRegion(IoTDARegion.CN_NORTH_4)"
                .withRegion(new Region("cn-north-4", iotdaEndpoint))
                .build();
        CreateProductRequest request = new CreateProductRequest();
        AddProduct body = new AddProduct();
        List<ServiceCommandPara> listResponsesParas = new ArrayList<>();
        listResponsesParas.add(
            new ServiceCommandPara()
                .withParaName("force")
                .withDataType("string")
                .withRequired(false)
                .withMin("1")
                .withMax("100")
                .withMaxLength(100)
                .withStep((double)0.1)
                .withUnit("km/h")
                .withDescription("force")
        );
        List<ServiceCommandResponse> listCommandsResponses = new ArrayList<>();
        listCommandsResponses.add(
            new ServiceCommandResponse()
                .withResponseName("ACK")
                .withParas(listResponsesParas)
        );
        List<ServiceCommandPara> listCommandsParas = new ArrayList<>();
        listCommandsParas.add(
            new ServiceCommandPara()
                .withParaName("force")
                .withDataType("string")
                .withRequired(false)
                .withMin("1")
                .withMax("100")
                .withMaxLength(100)
                .withStep((double)0.1)
                .withUnit("km/h")
                .withDescription("force")
        );
        List<ServiceCommand> listServiceCapabilitiesCommands = new ArrayList<>();
        listServiceCapabilitiesCommands.add(
            new ServiceCommand()
                .withCommandName("reboot")
                .withParas(listCommandsParas)
                .withResponses(listCommandsResponses)
        );
        List<ServiceProperty> listServiceCapabilitiesProperties = new ArrayList<>();
        listServiceCapabilitiesProperties.add(
            new ServiceProperty()
                .withPropertyName("temperature")
                .withDataType("decimal")
                .withRequired(true)
                .withMin("1")
                .withMax("100")
                .withMaxLength(100)
                .withStep((double)0.1)
                .withUnit("centigrade")
                .withMethod("RW")
                .withDescription("force")
                .withDefaultValue("{\"color\":\"red\",\"size\":1}")
        );
        List<ServiceCapability> listbodyServiceCapabilities = new ArrayList<>();
        listbodyServiceCapabilities.add(
            new ServiceCapability()
                .withServiceId("temperature,")
                .withServiceType("temperature")
                .withProperties(listServiceCapabilitiesProperties)
                .withCommands(listServiceCapabilitiesCommands)
                .withDescription("temperature")
                .withOption("Mandatory")
        );
        body.withAppId("jeQDJQZltU8iKgFFoW060F5SGZka");
        body.withDescription("this is a thermometer produced by Huawei");
        body.withIndustry("smartCity");
        body.withManufacturerName("ABC");
        body.withServiceCapabilities(listbodyServiceCapabilities);
        body.withDataFormat("json");
        body.withProtocolType("MQTT");
        body.withDeviceType("Thermometer,");
        body.withName("Thermometer,");
        body.withProductId("5ba24f5ebbe8f56f5a14f605");
        request.withBody(body);
        try {
            CreateProductResponse response = client.createProduct(request);
            System.out.println(response.toString());
        } catch (ConnectionException e) {
            e.printStackTrace();
        } catch (RequestTimeoutException e) {
            e.printStackTrace();
        } catch (ServiceResponseException e) {
            e.printStackTrace();
            System.out.println(e.getHttpStatusCode());
            System.out.println(e.getRequestId());
            System.out.println(e.getErrorCode());
            System.out.println(e.getErrorMsg());
        }
    }
}

# coding: utf-8

import os
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdkcore.auth.credentials import DerivedCredentials
from huaweicloudsdkcore.region.region import Region as coreRegion
from huaweicloudsdkcore.exceptions import exceptions
from huaweicloudsdkiotda.v5 import *

if __name__ == "__main__":
    # The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
    # In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
    ak = os.environ["CLOUD_SDK_AK"]
    sk = os.environ["CLOUD_SDK_SK"]
    // ENDPOINT：请在控制台的"总览"界面的"平台接入地址"中查看“应用侧”的https接入地址。
    iotdaEndpoint = "<YOUR ENDPOINT>";
    projectId = "{project_id}"

    credentials = BasicCredentials(ak, sk, projectId).with_derived_predicate(DerivedCredentials.get_default_derived_predicate())

    client = IoTDAClient.new_builder() \
        .with_credentials(credentials) \
        # 标准版/企业版：需要使用自行创建的Region对象，基础版：请选择IoTDAClient中的Region对象 如： .with_region(IoTDARegion.CN_NORTH_4)
        .with_region(coreRegion(id="cn-north-4", endpoint=endpoint)) \
        .build()

    try:
        request = CreateProductRequest()
        listParasResponses = [
            ServiceCommandPara(
                para_name="force",
                data_type="string",
                required=False,
                min="1",
                max="100",
                max_length=100,
                step=0.1,
                unit="km/h",
                description="force"
            )
        ]
        listResponsesCommands = [
            ServiceCommandResponse(
                response_name="ACK",
                paras=listParasResponses
            )
        ]
        listParasCommands = [
            ServiceCommandPara(
                para_name="force",
                data_type="string",
                required=False,
                min="1",
                max="100",
                max_length=100,
                step=0.1,
                unit="km/h",
                description="force"
            )
        ]
        listCommandsServiceCapabilities = [
            ServiceCommand(
                command_name="reboot",
                paras=listParasCommands,
                responses=listResponsesCommands
            )
        ]
        listPropertiesServiceCapabilities = [
            ServiceProperty(
                property_name="temperature",
                data_type="decimal",
                required=True,
                min="1",
                max="100",
                max_length=100,
                step=0.1,
                unit="centigrade",
                method="RW",
                description="force",
                default_value="{\"color\":\"red\",\"size\":1}"
            )
        ]
        listServiceCapabilitiesbody = [
            ServiceCapability(
                service_id="temperature,",
                service_type="temperature",
                properties=listPropertiesServiceCapabilities,
                commands=listCommandsServiceCapabilities,
                description="temperature",
                option="Mandatory"
            )
        ]
        request.body = AddProduct(
            app_id="jeQDJQZltU8iKgFFoW060F5SGZka",
            description="this is a thermometer produced by Huawei",
            industry="smartCity",
            manufacturer_name="ABC",
            service_capabilities=listServiceCapabilitiesbody,
            data_format="json",
            protocol_type="MQTT",
            device_type="Thermometer,",
            name="Thermometer,",
            product_id="5ba24f5ebbe8f56f5a14f605"
        )
        response = client.create_product(request)
        print(response)
    except exceptions.ClientRequestException as e:
        print(e.status_code)
        print(e.request_id)
        print(e.error_code)
        print(e.error_msg)

package main

import (
	"fmt"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic"
    iotda "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/iotda/v5"
	"github.com/huaweicloud/huaweicloud-sdk-go-v3/services/iotda/v5/model"
    region "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/region"
    core_auth "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth"
)

func main() {
    // The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security.
    // In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment
    ak := os.Getenv("CLOUD_SDK_AK")
    sk := os.Getenv("CLOUD_SDK_SK")
    // endpoint：请在控制台的"总览"界面的"平台接入地址"中查看"应用侧"的https接入地址
    endpoint := "<YOUR ENDPOINT>"
    projectId := "{project_id}"

    auth := basic.NewCredentialsBuilder().
        WithAk(ak).
        WithSk(sk).
        WithProjectId(projectId).
        // 企业版/标准版需要使用衍生算法，基础版请删除该配置"WithDerivedPredicate"
        WithDerivedPredicate(core_auth.GetDefaultDerivedPredicate()). // Used in derivative ak/sk authentication scenarios
        Build()

    client := iotda.NewIoTDAClient(
        iotda.IoTDAClientBuilder().
            // 标准版/企业版需要自行创建region，基础版使用IoTDARegion中的region对象
            WithRegion(region.NewRegion("cn-north-4", endpoint)).
            WithCredential(auth).
            Build())

    request := &model.CreateProductRequest{}
	requiredParas:= false
	minParas:= "1"
	maxParas:= "100"
	maxLengthParas:= int32(100)
	stepParas:= float64(0.1)
	unitParas:= "km/h"
	descriptionParas:= "force"
	var listParasResponses = []model.ServiceCommandPara{
        {
            ParaName: "force",
            DataType: "string",
            Required: &requiredParas,
            Min: &minParas,
            Max: &maxParas,
            MaxLength: &maxLengthParas,
            Step: &stepParas,
            Unit: &unitParas,
            Description: &descriptionParas,
        },
    }
	var listResponsesCommands = []model.ServiceCommandResponse{
        {
            ResponseName: "ACK",
            Paras: &listParasResponses,
        },
    }
	requiredParas1:= false
	minParas1:= "1"
	maxParas1:= "100"
	maxLengthParas1:= int32(100)
	stepParas1:= float64(0.1)
	unitParas1:= "km/h"
	descriptionParas1:= "force"
	var listParasCommands = []model.ServiceCommandPara{
        {
            ParaName: "force",
            DataType: "string",
            Required: &requiredParas1,
            Min: &minParas1,
            Max: &maxParas1,
            MaxLength: &maxLengthParas1,
            Step: &stepParas1,
            Unit: &unitParas1,
            Description: &descriptionParas1,
        },
    }
	var listCommandsServiceCapabilities = []model.ServiceCommand{
        {
            CommandName: "reboot",
            Paras: &listParasCommands,
            Responses: &listResponsesCommands,
        },
    }
	requiredProperties:= true
	minProperties:= "1"
	maxProperties:= "100"
	maxLengthProperties:= int32(100)
	stepProperties:= float64(0.1)
	unitProperties:= "centigrade"
	descriptionProperties:= "force"
	defaultValueProperties:= "{\"color\":\"red\",\"size\":1}"
	var defaultValuePropertiesInterface interface{} = defaultValueProperties
	var listPropertiesServiceCapabilities = []model.ServiceProperty{
        {
            PropertyName: "temperature",
            DataType: "decimal",
            Required: &requiredProperties,
            Min: &minProperties,
            Max: &maxProperties,
            MaxLength: &maxLengthProperties,
            Step: &stepProperties,
            Unit: &unitProperties,
            Method: "RW",
            Description: &descriptionProperties,
            DefaultValue: &defaultValuePropertiesInterface,
        },
    }
	descriptionServiceCapabilities:= "temperature"
	optionServiceCapabilities:= "Mandatory"
	var listServiceCapabilitiesbody = []model.ServiceCapability{
        {
            ServiceId: "temperature,",
            ServiceType: "temperature",
            Properties: &listPropertiesServiceCapabilities,
            Commands: &listCommandsServiceCapabilities,
            Description: &descriptionServiceCapabilities,
            Option: &optionServiceCapabilities,
        },
    }
	appIdAddProduct:= "jeQDJQZltU8iKgFFoW060F5SGZka"
	descriptionAddProduct:= "this is a thermometer produced by Huawei"
	industryAddProduct:= "smartCity"
	manufacturerNameAddProduct:= "ABC"
	productIdAddProduct:= "5ba24f5ebbe8f56f5a14f605"
	request.Body = &model.AddProduct{
		AppId: &appIdAddProduct,
		Description: &descriptionAddProduct,
		Industry: &industryAddProduct,
		ManufacturerName: &manufacturerNameAddProduct,
		ServiceCapabilities: listServiceCapabilitiesbody,
		DataFormat: "json",
		ProtocolType: "MQTT",
		DeviceType: "Thermometer,",
		Name: "Thermometer,",
		ProductId: &productIdAddProduct,
	}
	response, err := client.CreateProduct(request)
	if err == nil {
        fmt.Printf("%+v\n", response)
    } else {
        fmt.Println(err)
    }
}