创建规则

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 CreateRuleSolution {

    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();
        CreateRuleRequest request = new CreateRuleRequest();
        Rule body = new Rule();
        ActionDeviceAlarm deviceAlarmActions = new ActionDeviceAlarm();
        deviceAlarmActions.withName("设备下线")
            .withAlarmStatus("fault")
            .withSeverity("warning")
            .withDescription("设备下线");
        List<RuleAction> listbodyActions = new ArrayList<>();
        listbodyActions.add(
            new RuleAction()
                .withType("DEVICE_ALARM")
                .withDeviceAlarm(deviceAlarmActions)
        );
        TimeRange timeRangeConditionGroup = new TimeRange();
        timeRangeConditionGroup.withStartTime("18:00")
            .withEndTime("23:00")
            .withDaysOfWeek("2,3,4,5,6");
        List<String> listDeviceLinkageStatusConditionStatusList = new ArrayList<>();
        listDeviceLinkageStatusConditionStatusList.add("OFFLINE");
        DeviceLinkageStatusCondition deviceLinkageStatusConditionConditions = new DeviceLinkageStatusCondition();
        deviceLinkageStatusConditionConditions.withDeviceId("07b69d78-c716-4be6-9545-869920738397")
            .withStatusList(listDeviceLinkageStatusConditionStatusList)
            .withDuration(0);
        List<RuleCondition> listConditionGroupConditions = new ArrayList<>();
        listConditionGroupConditions.add(
            new RuleCondition()
                .withType("DEVICE_LINKAGE_STATUS")
                .withDeviceLinkageStatusCondition(deviceLinkageStatusConditionConditions)
        );
        ConditionGroup conditionGroupbody = new ConditionGroup();
        conditionGroupbody.withConditions(listConditionGroupConditions)
            .withLogic("or")
            .withTimeRange(timeRangeConditionGroup);
        body.withAppId("string");
        body.withStatus("active");
        body.withRuleType("DEVICE_LINKAGE");
        body.withActions(listbodyActions);
        body.withConditionGroup(conditionGroupbody);
        body.withDescription("string");
        body.withName("openLight");
        request.withBody(body);
        try {
            CreateRuleResponse response = client.createRule(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());
        }
    }
}

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 CreateRuleSolution {

    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();
        CreateRuleRequest request = new CreateRuleRequest();
        Rule body = new Rule();
        Cmd cmdDeviceCommand = new Cmd();
        cmdDeviceCommand.withCommandName("SET_LIGHT_SWITCH")
            .withCommandBody("{\"value\":0}")
            .withServiceId("Switch")
            .withBufferTimeout(0)
            .withMode("ACTIVE");
        ActionDeviceCommand deviceCommandActions = new ActionDeviceCommand();
        deviceCommandActions.withDeviceId("3a9e52d9-3ebf-4985-89e9-6d2396748a2f")
            .withCmd(cmdDeviceCommand);
        List<RuleAction> listbodyActions = new ArrayList<>();
        listbodyActions.add(
            new RuleAction()
                .withType("DEVICE_CMD")
                .withDeviceCommand(deviceCommandActions)
        );
        TimeRange timeRangeConditionGroup = new TimeRange();
        timeRangeConditionGroup.withStartTime("18:00")
            .withEndTime("23:00")
            .withDaysOfWeek("2,3,4,5,6");
        Strategy strategyFilters = new Strategy();
        strategyFilters.withTrigger("reverse")
            .withEventValidTime(300);
        List<PropertyFilter> listDevicePropertyConditionFilters = new ArrayList<>();
        listDevicePropertyConditionFilters.add(
            new PropertyFilter()
                .withPath("StreetLight/visibility")
                .withOperator("<")
                .withValue("30")
                .withStrategy(strategyFilters)
        );
        DeviceDataCondition devicePropertyConditionConditions = new DeviceDataCondition();
        devicePropertyConditionConditions.withDeviceId("07b69d78-c716-4be6-9545-869920738397")
            .withFilters(listDevicePropertyConditionFilters);
        List<RuleCondition> listConditionGroupConditions = new ArrayList<>();
        listConditionGroupConditions.add(
            new RuleCondition()
                .withType("DEVICE_DATA")
                .withDevicePropertyCondition(devicePropertyConditionConditions)
        );
        ConditionGroup conditionGroupbody = new ConditionGroup();
        conditionGroupbody.withConditions(listConditionGroupConditions)
            .withLogic("or")
            .withTimeRange(timeRangeConditionGroup);
        body.withAppId("string");
        body.withStatus("active");
        body.withRuleType("DEVICE_LINKAGE");
        body.withActions(listbodyActions);
        body.withConditionGroup(conditionGroupbody);
        body.withDescription("string");
        body.withName("openLight");
        request.withBody(body);
        try {
            CreateRuleResponse response = client.createRule(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());
        }
    }
}

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 CreateRuleSolution {

    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();
        CreateRuleRequest request = new CreateRuleRequest();
        Rule body = new Rule();
        List<String> listDeviceSideDeviceIds = new ArrayList<>();
        listDeviceSideDeviceIds.add("3a9e52d9-3ebf-4985-89e9-6d2396748a2f");
        DeviceSide deviceSidebody = new DeviceSide();
        deviceSidebody.withDeviceIds(listDeviceSideDeviceIds);
        Cmd cmdDeviceCommand = new Cmd();
        cmdDeviceCommand.withCommandName("SET_LIGHT_SWITCH")
            .withCommandBody("{\"value\":0}")
            .withServiceId("Switch")
            .withBufferTimeout(0)
            .withMode("ACTIVE");
        ActionDeviceCommand deviceCommandActions = new ActionDeviceCommand();
        deviceCommandActions.withDeviceId("3a9e52d9-3ebf-4985-89e9-6d2396748a2f")
            .withCmd(cmdDeviceCommand);
        List<RuleAction> listbodyActions = new ArrayList<>();
        listbodyActions.add(
            new RuleAction()
                .withType("DEVICE_CMD")
                .withDeviceCommand(deviceCommandActions)
        );
        TimeRange timeRangeConditionGroup = new TimeRange();
        timeRangeConditionGroup.withStartTime("18:00")
            .withEndTime("23:00")
            .withDaysOfWeek("2,3,4,5,6");
        Strategy strategyFilters = new Strategy();
        strategyFilters.withTrigger("reverse")
            .withEventValidTime(300);
        List<PropertyFilter> listDevicePropertyConditionFilters = new ArrayList<>();
        listDevicePropertyConditionFilters.add(
            new PropertyFilter()
                .withPath("StreetLight/visibility")
                .withOperator("<")
                .withValue("30")
                .withStrategy(strategyFilters)
        );
        DeviceDataCondition devicePropertyConditionConditions = new DeviceDataCondition();
        devicePropertyConditionConditions.withDeviceId("3a9e52d9-3ebf-4985-89e9-6d2396748a2f")
            .withFilters(listDevicePropertyConditionFilters);
        List<RuleCondition> listConditionGroupConditions = new ArrayList<>();
        listConditionGroupConditions.add(
            new RuleCondition()
                .withType("DEVICE_DATA")
                .withDevicePropertyCondition(devicePropertyConditionConditions)
        );
        ConditionGroup conditionGroupbody = new ConditionGroup();
        conditionGroupbody.withConditions(listConditionGroupConditions)
            .withLogic("or")
            .withTimeRange(timeRangeConditionGroup);
        body.withDeviceSide(deviceSidebody);
        body.withAppId("string");
        body.withStatus("active");
        body.withRuleType("DEVICE_SIDE");
        body.withActions(listbodyActions);
        body.withConditionGroup(conditionGroupbody);
        body.withDescription("string");
        body.withName("openLight");
        request.withBody(body);
        try {
            CreateRuleResponse response = client.createRule(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 = CreateRuleRequest()
        deviceAlarmActions = ActionDeviceAlarm(
            name="设备下线",
            alarm_status="fault",
            severity="warning",
            description="设备下线"
        )
        listActionsbody = [
            RuleAction(
                type="DEVICE_ALARM",
                device_alarm=deviceAlarmActions
            )
        ]
        timeRangeConditionGroup = TimeRange(
            start_time="18:00",
            end_time="23:00",
            days_of_week="2,3,4,5,6"
        )
        listStatusListDeviceLinkageStatusCondition = [
            "OFFLINE"
        ]
        deviceLinkageStatusConditionConditions = DeviceLinkageStatusCondition(
            device_id="07b69d78-c716-4be6-9545-869920738397",
            status_list=listStatusListDeviceLinkageStatusCondition,
            duration=0
        )
        listConditionsConditionGroup = [
            RuleCondition(
                type="DEVICE_LINKAGE_STATUS",
                device_linkage_status_condition=deviceLinkageStatusConditionConditions
            )
        ]
        conditionGroupbody = ConditionGroup(
            conditions=listConditionsConditionGroup,
            logic="or",
            time_range=timeRangeConditionGroup
        )
        request.body = Rule(
            app_id="string",
            status="active",
            rule_type="DEVICE_LINKAGE",
            actions=listActionsbody,
            condition_group=conditionGroupbody,
            description="string",
            name="openLight"
        )
        response = client.create_rule(request)
        print(response)
    except exceptions.ClientRequestException as e:
        print(e.status_code)
        print(e.request_id)
        print(e.error_code)
        print(e.error_msg)

# 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 = CreateRuleRequest()
        cmdDeviceCommand = Cmd(
            command_name="SET_LIGHT_SWITCH",
            command_body="{\"value\":0}",
            service_id="Switch",
            buffer_timeout=0,
            mode="ACTIVE"
        )
        deviceCommandActions = ActionDeviceCommand(
            device_id="3a9e52d9-3ebf-4985-89e9-6d2396748a2f",
            cmd=cmdDeviceCommand
        )
        listActionsbody = [
            RuleAction(
                type="DEVICE_CMD",
                device_command=deviceCommandActions
            )
        ]
        timeRangeConditionGroup = TimeRange(
            start_time="18:00",
            end_time="23:00",
            days_of_week="2,3,4,5,6"
        )
        strategyFilters = Strategy(
            trigger="reverse",
            event_valid_time=300
        )
        listFiltersDevicePropertyCondition = [
            PropertyFilter(
                path="StreetLight/visibility",
                operator="<",
                value="30",
                strategy=strategyFilters
            )
        ]
        devicePropertyConditionConditions = DeviceDataCondition(
            device_id="07b69d78-c716-4be6-9545-869920738397",
            filters=listFiltersDevicePropertyCondition
        )
        listConditionsConditionGroup = [
            RuleCondition(
                type="DEVICE_DATA",
                device_property_condition=devicePropertyConditionConditions
            )
        ]
        conditionGroupbody = ConditionGroup(
            conditions=listConditionsConditionGroup,
            logic="or",
            time_range=timeRangeConditionGroup
        )
        request.body = Rule(
            app_id="string",
            status="active",
            rule_type="DEVICE_LINKAGE",
            actions=listActionsbody,
            condition_group=conditionGroupbody,
            description="string",
            name="openLight"
        )
        response = client.create_rule(request)
        print(response)
    except exceptions.ClientRequestException as e:
        print(e.status_code)
        print(e.request_id)
        print(e.error_code)
        print(e.error_msg)

# 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 = CreateRuleRequest()
        listDeviceIdsDeviceSide = [
            "3a9e52d9-3ebf-4985-89e9-6d2396748a2f"
        ]
        deviceSidebody = DeviceSide(
            device_ids=listDeviceIdsDeviceSide
        )
        cmdDeviceCommand = Cmd(
            command_name="SET_LIGHT_SWITCH",
            command_body="{\"value\":0}",
            service_id="Switch",
            buffer_timeout=0,
            mode="ACTIVE"
        )
        deviceCommandActions = ActionDeviceCommand(
            device_id="3a9e52d9-3ebf-4985-89e9-6d2396748a2f",
            cmd=cmdDeviceCommand
        )
        listActionsbody = [
            RuleAction(
                type="DEVICE_CMD",
                device_command=deviceCommandActions
            )
        ]
        timeRangeConditionGroup = TimeRange(
            start_time="18:00",
            end_time="23:00",
            days_of_week="2,3,4,5,6"
        )
        strategyFilters = Strategy(
            trigger="reverse",
            event_valid_time=300
        )
        listFiltersDevicePropertyCondition = [
            PropertyFilter(
                path="StreetLight/visibility",
                operator="<",
                value="30",
                strategy=strategyFilters
            )
        ]
        devicePropertyConditionConditions = DeviceDataCondition(
            device_id="3a9e52d9-3ebf-4985-89e9-6d2396748a2f",
            filters=listFiltersDevicePropertyCondition
        )
        listConditionsConditionGroup = [
            RuleCondition(
                type="DEVICE_DATA",
                device_property_condition=devicePropertyConditionConditions
            )
        ]
        conditionGroupbody = ConditionGroup(
            conditions=listConditionsConditionGroup,
            logic="or",
            time_range=timeRangeConditionGroup
        )
        request.body = Rule(
            device_side=deviceSidebody,
            app_id="string",
            status="active",
            rule_type="DEVICE_SIDE",
            actions=listActionsbody,
            condition_group=conditionGroupbody,
            description="string",
            name="openLight"
        )
        response = client.create_rule(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.CreateRuleRequest{}
	descriptionDeviceAlarm:= "设备下线"
	deviceAlarmActions := &model.ActionDeviceAlarm{
		Name: "设备下线",
		AlarmStatus: "fault",
		Severity: "warning",
		Description: &descriptionDeviceAlarm,
	}
	var listActionsbody = []model.RuleAction{
        {
            Type: "DEVICE_ALARM",
            DeviceAlarm: deviceAlarmActions,
        },
    }
	daysOfWeekTimeRange:= "2,3,4,5,6"
	timeRangeConditionGroup := &model.TimeRange{
		StartTime: "18:00",
		EndTime: "23:00",
		DaysOfWeek: &daysOfWeekTimeRange,
	}
	var listStatusListDeviceLinkageStatusCondition = []string{
        "OFFLINE",
    }
	deviceIdDeviceLinkageStatusCondition:= "07b69d78-c716-4be6-9545-869920738397"
	durationDeviceLinkageStatusCondition:= int32(0)
	deviceLinkageStatusConditionConditions := &model.DeviceLinkageStatusCondition{
		DeviceId: &deviceIdDeviceLinkageStatusCondition,
		StatusList: &listStatusListDeviceLinkageStatusCondition,
		Duration: &durationDeviceLinkageStatusCondition,
	}
	var listConditionsConditionGroup = []model.RuleCondition{
        {
            Type: "DEVICE_LINKAGE_STATUS",
            DeviceLinkageStatusCondition: deviceLinkageStatusConditionConditions,
        },
    }
	logicConditionGroup:= "or"
	conditionGroupbody := &model.ConditionGroup{
		Conditions: &listConditionsConditionGroup,
		Logic: &logicConditionGroup,
		TimeRange: timeRangeConditionGroup,
	}
	appIdRule:= "string"
	statusRule:= "active"
	descriptionRule:= "string"
	request.Body = &model.Rule{
		AppId: &appIdRule,
		Status: &statusRule,
		RuleType: "DEVICE_LINKAGE",
		Actions: listActionsbody,
		ConditionGroup: conditionGroupbody,
		Description: &descriptionRule,
		Name: "openLight",
	}
	response, err := client.CreateRule(request)
	if err == nil {
        fmt.Printf("%+v\n", response)
    } else {
        fmt.Println(err)
    }
}

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.CreateRuleRequest{}
	var commandBodyCmd interface{} = "{\"value\":0}"
	bufferTimeoutCmd:= int32(0)
	modeCmd:= "ACTIVE"
	cmdDeviceCommand := &model.Cmd{
		CommandName: "SET_LIGHT_SWITCH",
		CommandBody: &commandBodyCmd,
		ServiceId: "Switch",
		BufferTimeout: &bufferTimeoutCmd,
		Mode: &modeCmd,
	}
	deviceIdDeviceCommand:= "3a9e52d9-3ebf-4985-89e9-6d2396748a2f"
	deviceCommandActions := &model.ActionDeviceCommand{
		DeviceId: &deviceIdDeviceCommand,
		Cmd: cmdDeviceCommand,
	}
	var listActionsbody = []model.RuleAction{
        {
            Type: "DEVICE_CMD",
            DeviceCommand: deviceCommandActions,
        },
    }
	daysOfWeekTimeRange:= "2,3,4,5,6"
	timeRangeConditionGroup := &model.TimeRange{
		StartTime: "18:00",
		EndTime: "23:00",
		DaysOfWeek: &daysOfWeekTimeRange,
	}
	triggerStrategy:= "reverse"
	eventValidTimeStrategy:= int32(300)
	strategyFilters := &model.Strategy{
		Trigger: &triggerStrategy,
		EventValidTime: &eventValidTimeStrategy,
	}
	valueFilters:= "30"
	var listFiltersDevicePropertyCondition = []model.PropertyFilter{
        {
            Path: "StreetLight/visibility",
            Operator: "<",
            Value: &valueFilters,
            Strategy: strategyFilters,
        },
    }
	deviceIdDevicePropertyCondition:= "07b69d78-c716-4be6-9545-869920738397"
	devicePropertyConditionConditions := &model.DeviceDataCondition{
		DeviceId: &deviceIdDevicePropertyCondition,
		Filters: &listFiltersDevicePropertyCondition,
	}
	var listConditionsConditionGroup = []model.RuleCondition{
        {
            Type: "DEVICE_DATA",
            DevicePropertyCondition: devicePropertyConditionConditions,
        },
    }
	logicConditionGroup:= "or"
	conditionGroupbody := &model.ConditionGroup{
		Conditions: &listConditionsConditionGroup,
		Logic: &logicConditionGroup,
		TimeRange: timeRangeConditionGroup,
	}
	appIdRule:= "string"
	statusRule:= "active"
	descriptionRule:= "string"
	request.Body = &model.Rule{
		AppId: &appIdRule,
		Status: &statusRule,
		RuleType: "DEVICE_LINKAGE",
		Actions: listActionsbody,
		ConditionGroup: conditionGroupbody,
		Description: &descriptionRule,
		Name: "openLight",
	}
	response, err := client.CreateRule(request)
	if err == nil {
        fmt.Printf("%+v\n", response)
    } else {
        fmt.Println(err)
    }
}

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.CreateRuleRequest{}
	var listDeviceIdsDeviceSide = []string{
        "3a9e52d9-3ebf-4985-89e9-6d2396748a2f",
    }
	deviceSidebody := &model.DeviceSide{
		DeviceIds: &listDeviceIdsDeviceSide,
	}
	var commandBodyCmd interface{} = "{\"value\":0}"
	bufferTimeoutCmd:= int32(0)
	modeCmd:= "ACTIVE"
	cmdDeviceCommand := &model.Cmd{
		CommandName: "SET_LIGHT_SWITCH",
		CommandBody: &commandBodyCmd,
		ServiceId: "Switch",
		BufferTimeout: &bufferTimeoutCmd,
		Mode: &modeCmd,
	}
	deviceIdDeviceCommand:= "3a9e52d9-3ebf-4985-89e9-6d2396748a2f"
	deviceCommandActions := &model.ActionDeviceCommand{
		DeviceId: &deviceIdDeviceCommand,
		Cmd: cmdDeviceCommand,
	}
	var listActionsbody = []model.RuleAction{
        {
            Type: "DEVICE_CMD",
            DeviceCommand: deviceCommandActions,
        },
    }
	daysOfWeekTimeRange:= "2,3,4,5,6"
	timeRangeConditionGroup := &model.TimeRange{
		StartTime: "18:00",
		EndTime: "23:00",
		DaysOfWeek: &daysOfWeekTimeRange,
	}
	triggerStrategy:= "reverse"
	eventValidTimeStrategy:= int32(300)
	strategyFilters := &model.Strategy{
		Trigger: &triggerStrategy,
		EventValidTime: &eventValidTimeStrategy,
	}
	valueFilters:= "30"
	var listFiltersDevicePropertyCondition = []model.PropertyFilter{
        {
            Path: "StreetLight/visibility",
            Operator: "<",
            Value: &valueFilters,
            Strategy: strategyFilters,
        },
    }
	deviceIdDevicePropertyCondition:= "3a9e52d9-3ebf-4985-89e9-6d2396748a2f"
	devicePropertyConditionConditions := &model.DeviceDataCondition{
		DeviceId: &deviceIdDevicePropertyCondition,
		Filters: &listFiltersDevicePropertyCondition,
	}
	var listConditionsConditionGroup = []model.RuleCondition{
        {
            Type: "DEVICE_DATA",
            DevicePropertyCondition: devicePropertyConditionConditions,
        },
    }
	logicConditionGroup:= "or"
	conditionGroupbody := &model.ConditionGroup{
		Conditions: &listConditionsConditionGroup,
		Logic: &logicConditionGroup,
		TimeRange: timeRangeConditionGroup,
	}
	appIdRule:= "string"
	statusRule:= "active"
	descriptionRule:= "string"
	request.Body = &model.Rule{
		DeviceSide: deviceSidebody,
		AppId: &appIdRule,
		Status: &statusRule,
		RuleType: "DEVICE_SIDE",
		Actions: listActionsbody,
		ConditionGroup: conditionGroupbody,
		Description: &descriptionRule,
		Name: "openLight",
	}
	response, err := client.CreateRule(request)
	if err == nil {
        fmt.Printf("%+v\n", response)
    } else {
        fmt.Println(err)
    }
}