更新时间:2024-08-29 GMT+08:00

修改SQL告警规则

功能介绍

该接口用于修改SQL告警

调用方法

请参见如何调用API

URI

PUT /v2/{project_id}/lts/alarms/sql-alarm-rule

表1 路径参数

参数

是否必选

参数类型

描述

project_id

String

项目ID,获取方式请参见:获取项目ID,获取账号ID,日志组ID、日志流ID

请求参数

表2 请求Header参数

参数

是否必选

参数类型

描述

X-Auth-Token

String

从IAM服务获取的用户Token,获取方式请参见:获取用户Token

Content-Type

String

该字段填为:application/json;charset=UTF-8。

表3 请求Body参数

参数

是否必选

参数类型

描述

sql_alarm_rule_id

String

SQL告警id

sql_alarm_rule_name

String

规则原始名称(不支持修改首次创建的原始名称)

alarm_rule_alias

String

规则名称

is_css_sql

Boolean

是否管道符sql查询。

sql_alarm_rule_description

String

SQL告警信息描述

sql_requests

Array of SqlRequest objects

SQL详细信息

frequency

CreateSqlAlarmRuleFrequency object

告警统计周期

condition_expression

String

条件表达式

sql_alarm_level

String

告警级别

sql_alarm_send

Boolean

是否发送

sql_alarm_send_code

Integer

发送主题 0:不变 1:新增 2:修改 3:删除

domain_id

String

domainId

notification_save_rule

SqlNotificationSaveRule object

通知主题

trigger_condition_count

Integer

触发条件:触发次数;默认为1

trigger_condition_frequency

Integer

触发条件:触发周期;默认为1

whether_recovery_policy

Boolean

是否打开恢复通知;默认false

recovery_policy

Integer

恢复策略周期;默认为3

notification_frequency

Integer

通知频率,单位(分钟)

alarm_action_rule_name

String

告警行动规则名称

说明:

alarm_action_rule_name和notification_save_rule可以选填一个,如果都填,优先选择alarm_action_rule_name

表4 SqlRequest

参数

是否必选

参数类型

描述

is_time_range_relative

Boolean

是时间范围相对

log_stream_id

String

日志流id

log_stream_name

String

日志流名称

log_group_id

String

日志组id

log_group_name

String

日志组名称

sql

String

sql语句

sql_request_title

String

图表名称

search_time_range

Integer

查询执行任务时最近数据的时间范围(当search_time_range_unit为minute,则最大值为60;当search_time_range_unit为hour,则最大值为24)

search_time_range_unit

String

查询时间单位

表5 CreateSqlAlarmRuleFrequency

参数

是否必选

参数类型

描述

type

String

时间类型。

cron_expr

String

当字段type为"CRON"时取该字段。

hour_of_day

Integer

当字段type为"DAILY"或者"WEEKLY"时取该字段。

DAILY:最小值:0,最大值:23

WEEKLY:最小值:0,最大值:23

day_of_week

Integer

当字段type为"WEEKLY"时取该字段(周日~周六)。

fixed_rate

Integer

当字段type为"FIXED_RATE"时取该字段(当fixed_rate_unit单位为minute,最大值60;当fixed_rate_unit单位为hour,最大值24)。

fixed_rate_unit

String

时间单位。

表6 SqlNotificationSaveRule

参数

是否必选

参数类型

描述

language

String

首选项对应的语言

timezone

String

首选项对应的时区信息

user_name

String

用户名

topics

Array of Topics objects

主题信息

template_name

String

消息模板名称

表7 Topics

参数

是否必选

参数类型

描述

name

String

主题名称。

topic_urn

String

Topic的唯一的资源标识。

display_name

String

Topic的显示名,推送邮件消息时,作为邮件发件人显示。

push_policy

Integer

消息推送的策略。

响应参数

状态码: 200

表8 响应Body参数

参数

参数类型

描述

sql_alarm_rule_name

String

原始规则名称

alarm_rule_alias

String

规则名称

is_css_sql

Boolean

是否管道符sql查询。

indexId

String

索引id

projectId

String

项目id

sql_alarm_rule_id

String

SQL告警规则id

sql_alarm_rule_description

String

SQL告警信息描述

sql_requests

Array of SqlRequest objects

SQL详细信息

frequency

FrequencyRespBody object

告警统计周期

condition_expression

String

条件表达式

sql_alarm_level

String

告警级别

sql_alarm_send

Boolean

是否发送

domain_id

String

domainId

create_time

Long

创建时间(毫秒时间戳)

update_time

Long

更新时间(毫秒时间戳)

topics

Array of Topics objects

主题

language

String

邮件附加信息语言

id

String

规则ID。

notification_frequency

Integer

通知频率,单位(分钟)

alarm_action_rule_name

String

告警行动规则名称

说明:

alarm_action_rule_name和notification_save_rule可以选填一个,如果都填,优先选择alarm_action_rule_name

表9 SqlRequest

参数

参数类型

描述

is_time_range_relative

Boolean

是时间范围相对

log_stream_id

String

日志流id

log_stream_name

String

日志流名称

log_group_id

String

日志组id

log_group_name

String

日志组名称

sql

String

sql语句

sql_request_title

String

图表名称

search_time_range

Integer

查询执行任务时最近数据的时间范围(当search_time_range_unit为minute,则最大值为60;当search_time_range_unit为hour,则最大值为24)

search_time_range_unit

String

查询时间单位

表10 FrequencyRespBody

参数

参数类型

描述

type

String

时间类型。

cron_expr

String

当字段type为"CRON"时取该字段。

hour_of_day

Integer

当字段type为"DAILY"或者"WEEKLY"时取该字段。

day_of_week

Integer

当字段type为"WEEKLY"时取该字段(周日~周六)。

fixed_rate

Integer

当字段type为"FIXED_RATE"时取该字段(当fixed_rate_unit单位为minute,最大值60;当fixed_rate_unit单位为hour,最大值24)。

fixed_rate_unit

String

时间单位枚举值:

表11 Topics

参数

参数类型

描述

name

String

主题名称。

topic_urn

String

Topic的唯一的资源标识。

display_name

String

Topic的显示名,推送邮件消息时,作为邮件发件人显示。

push_policy

Integer

消息推送的策略。

状态码: 400

表12 响应Body参数

参数

参数类型

描述

error_code

String

错误码。

error_msg

String

调用失败响应信息描述。

状态码: 500

表13 响应Body参数

参数

参数类型

描述

error_code

String

错误码。

error_msg

String

调用失败响应信息描述。

请求示例

修改SQL告警规则

PUT https://{endpoint}/v2/{project_id}/lts/alarms/sql-alarm-rule 

{
  "sql_alarm_rule_id" : "",
  "sql_alarm_rule_name" : "huawei",
  "is_css_sql" : false,
  "alarm_rule_alias" : "zhangsan",
  "sql_alarm_rule_description" : "huawei",
  "sql_requests" : [ {
    "log_stream_id" : "1",
    "log_group_id" : "1",
    "sql" : "select count(*) as t",
    "sql_request_title" : "demo",
    "search_time_range" : 10,
    "search_time_range_unit" : "minute"
  } ],
  "frequency" : {
    "type" : "FIXED_RATE",
    "cron_expr" : "",
    "hour_of_day" : 0,
    "day_of_week" : 0,
    "fixed_rate" : 10,
    "fixed_rate_unit" : "minute"
  },
  "condition_expression" : "t>0",
  "sql_alarm_level" : "Critical",
  "sql_alarm_send" : true,
  "sql_alarm_send_code" : 0,
  "domain_id" : "",
  "notification_frequency" : 5,
  "alarm_action_rule_name" : "",
  "notification_save_rule" : {
    "language" : "zh-cn",
    "timezone" : "Asia/Shanghai",
    "user_name" : "huawei",
    "template_name" : "消息模板名称",
    "topics" : [ {
      "name" : "huawei",
      "topic_urn" : "urn:smn:cn-north-7:1b06fc5dc0814a4da1594a9ade9cb93c:huawei",
      "display_name" : "",
      "push_policy" : 0
    } ]
  }
}

响应示例

状态码: 200

请求响应成功。

{
  "sql_alarm_rule_id" : "",
  "sql_alarm_rule_name" : "huawei",
  "alarm_rule_alias" : "zhangsan",
  "is_css_sql" : false,
  "sql_alarm_rule_description" : "huawei",
  "sql_requests" : [ {
    "log_stream_id" : "1",
    "log_stream_name" : "huawei",
    "log_group_name" : "huawei",
    "log_group_id" : "1",
    "sql" : "select count(*) as t",
    "sql_request_title" : "demo",
    "search_time_range" : 10,
    "search_time_range_unit" : "minute"
  } ],
  "frequency" : {
    "type" : "FIXED_RATE",
    "cron_expr" : "",
    "hour_of_day" : 0,
    "day_of_week" : 0,
    "fixed_rate" : 10,
    "fixed_rate_unit" : "minute"
  },
  "condition_expression" : "t>0",
  "sql_alarm_level" : "Critical",
  "sql_alarm_send" : true,
  "domain_id" : "",
  "notification_frequency" : 5,
  "alarm_action_rule_name" : "",
  "topics" : [ {
    "name" : "huawei",
    "topic_urn" : "urn:smn:cn-north-7:1b06fc5dc0814a4da1594a9ade9cb93c:huawei",
    "display_name" : "",
    "push_policy" : 0
  } ]
}

状态码: 400

BadRequest 非法请求 建议根据error_msg直接修改该请求。

{
  "error_code" : "LTS.2005",
  "error_msg" : "Alarm rule params validator error."
}

状态码: 500

表明服务端能被请求访问到,但是服务内部出错。

{
  "error_code" : "LTS.2003",
  "error_msg" : "Failed to update alarm rule."
}

SDK代码示例

SDK代码示例如下。

修改SQL告警规则

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
package com.huaweicloud.sdk.test;

import com.huaweicloud.sdk.core.auth.ICredential;
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.lts.v2.region.LtsRegion;
import com.huaweicloud.sdk.lts.v2.*;
import com.huaweicloud.sdk.lts.v2.model.*;

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

public class UpdateSqlAlarmRuleSolution {

    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");
        String projectId = "{project_id}";

        ICredential auth = new BasicCredentials()
                .withProjectId(projectId)
                .withAk(ak)
                .withSk(sk);

        LtsClient client = LtsClient.newBuilder()
                .withCredential(auth)
                .withRegion(LtsRegion.valueOf("<YOUR REGION>"))
                .build();
        UpdateSqlAlarmRuleRequest request = new UpdateSqlAlarmRuleRequest();
        UpdateSqlAlarmRuleRequestBody body = new UpdateSqlAlarmRuleRequestBody();
        List<Topics> listNotificationSaveRuleTopics = new ArrayList<>();
        listNotificationSaveRuleTopics.add(
            new Topics()
                .withName("huawei")
                .withTopicUrn("urn:smn:cn-north-7:1b06fc5dc0814a4da1594a9ade9cb93c:huawei")
                .withDisplayName("")
                .withPushPolicy(0)
        );
        SqlNotificationSaveRule notificationSaveRulebody = new SqlNotificationSaveRule();
        notificationSaveRulebody.withLanguage(SqlNotificationSaveRule.LanguageEnum.fromValue("zh-cn"))
            .withTimezone("Asia/Shanghai")
            .withUserName("huawei")
            .withTopics(listNotificationSaveRuleTopics)
            .withTemplateName("消息模板名称");
        CreateSqlAlarmRuleFrequency frequencybody = new CreateSqlAlarmRuleFrequency();
        frequencybody.withType(CreateSqlAlarmRuleFrequency.TypeEnum.fromValue("FIXED_RATE"))
            .withCronExpr("")
            .withHourOfDay(0)
            .withDayOfWeek(0)
            .withFixedRate(10)
            .withFixedRateUnit(CreateSqlAlarmRuleFrequency.FixedRateUnitEnum.fromValue("minute"));
        List<SqlRequest> listbodySqlRequests = new ArrayList<>();
        listbodySqlRequests.add(
            new SqlRequest()
                .withLogStreamId("1")
                .withLogGroupId("1")
                .withSql("select count(*) as t")
                .withSqlRequestTitle("demo")
                .withSearchTimeRange(10)
                .withSearchTimeRangeUnit(SqlRequest.SearchTimeRangeUnitEnum.fromValue("minute"))
        );
        body.withAlarmActionRuleName("");
        body.withNotificationFrequency(UpdateSqlAlarmRuleRequestBody.NotificationFrequencyEnum.NUMBER_5);
        body.withNotificationSaveRule(notificationSaveRulebody);
        body.withDomainId("");
        body.withSqlAlarmSendCode(UpdateSqlAlarmRuleRequestBody.SqlAlarmSendCodeEnum.NUMBER_0);
        body.withSqlAlarmSend(true);
        body.withSqlAlarmLevel(UpdateSqlAlarmRuleRequestBody.SqlAlarmLevelEnum.fromValue("Critical"));
        body.withConditionExpression("t>0");
        body.withFrequency(frequencybody);
        body.withSqlRequests(listbodySqlRequests);
        body.withSqlAlarmRuleDescription("huawei");
        body.withIsCssSql(false);
        body.withAlarmRuleAlias("zhangsan");
        body.withSqlAlarmRuleName("huawei");
        body.withSqlAlarmRuleId("");
        request.withBody(body);
        try {
            UpdateSqlAlarmRuleResponse response = client.updateSqlAlarmRule(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());
        }
    }
}

修改SQL告警规则

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
# coding: utf-8

import os
from huaweicloudsdkcore.auth.credentials import BasicCredentials
from huaweicloudsdklts.v2.region.lts_region import LtsRegion
from huaweicloudsdkcore.exceptions import exceptions
from huaweicloudsdklts.v2 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"]
    projectId = "{project_id}"

    credentials = BasicCredentials(ak, sk, projectId)

    client = LtsClient.new_builder() \
        .with_credentials(credentials) \
        .with_region(LtsRegion.value_of("<YOUR REGION>")) \
        .build()

    try:
        request = UpdateSqlAlarmRuleRequest()
        listTopicsNotificationSaveRule = [
            Topics(
                name="huawei",
                topic_urn="urn:smn:cn-north-7:1b06fc5dc0814a4da1594a9ade9cb93c:huawei",
                display_name="",
                push_policy=0
            )
        ]
        notificationSaveRulebody = SqlNotificationSaveRule(
            language="zh-cn",
            timezone="Asia/Shanghai",
            user_name="huawei",
            topics=listTopicsNotificationSaveRule,
            template_name="消息模板名称"
        )
        frequencybody = CreateSqlAlarmRuleFrequency(
            type="FIXED_RATE",
            cron_expr="",
            hour_of_day=0,
            day_of_week=0,
            fixed_rate=10,
            fixed_rate_unit="minute"
        )
        listSqlRequestsbody = [
            SqlRequest(
                log_stream_id="1",
                log_group_id="1",
                sql="select count(*) as t",
                sql_request_title="demo",
                search_time_range=10,
                search_time_range_unit="minute"
            )
        ]
        request.body = UpdateSqlAlarmRuleRequestBody(
            alarm_action_rule_name="",
            notification_frequency=5,
            notification_save_rule=notificationSaveRulebody,
            domain_id="",
            sql_alarm_send_code=0,
            sql_alarm_send=True,
            sql_alarm_level="Critical",
            condition_expression="t>0",
            frequency=frequencybody,
            sql_requests=listSqlRequestsbody,
            sql_alarm_rule_description="huawei",
            is_css_sql=False,
            alarm_rule_alias="zhangsan",
            sql_alarm_rule_name="huawei",
            sql_alarm_rule_id=""
        )
        response = client.update_sql_alarm_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)

修改SQL告警规则

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
package main

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

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")
    projectId := "{project_id}"

    auth := basic.NewCredentialsBuilder().
        WithAk(ak).
        WithSk(sk).
        WithProjectId(projectId).
        Build()

    client := lts.NewLtsClient(
        lts.LtsClientBuilder().
            WithRegion(region.ValueOf("<YOUR REGION>")).
            WithCredential(auth).
            Build())

    request := &model.UpdateSqlAlarmRuleRequest{}
	displayNameTopics:= ""
	pushPolicyTopics:= int32(0)
	var listTopicsNotificationSaveRule = []model.Topics{
        {
            Name: "huawei",
            TopicUrn: "urn:smn:cn-north-7:1b06fc5dc0814a4da1594a9ade9cb93c:huawei",
            DisplayName: &displayNameTopics,
            PushPolicy: &pushPolicyTopics,
        },
    }
	timezoneNotificationSaveRule:= "Asia/Shanghai"
	notificationSaveRulebody := &model.SqlNotificationSaveRule{
		Language: model.GetSqlNotificationSaveRuleLanguageEnum().ZH_CN,
		Timezone: &timezoneNotificationSaveRule,
		UserName: "huawei",
		Topics: listTopicsNotificationSaveRule,
		TemplateName: "消息模板名称",
	}
	cronExprFrequency:= ""
	hourOfDayFrequency:= int32(0)
	dayOfWeekFrequency:= int32(0)
	fixedRateFrequency:= int32(10)
	fixedRateUnitFrequency:= model.GetCreateSqlAlarmRuleFrequencyFixedRateUnitEnum().MINUTE
	frequencybody := &model.CreateSqlAlarmRuleFrequency{
		Type: model.GetCreateSqlAlarmRuleFrequencyTypeEnum().FIXED_RATE,
		CronExpr: &cronExprFrequency,
		HourOfDay: &hourOfDayFrequency,
		DayOfWeek: &dayOfWeekFrequency,
		FixedRate: &fixedRateFrequency,
		FixedRateUnit: &fixedRateUnitFrequency,
	}
	var listSqlRequestsbody = []model.SqlRequest{
        {
            LogStreamId: "1",
            LogGroupId: "1",
            Sql: "select count(*) as t",
            SqlRequestTitle: "demo",
            SearchTimeRange: int32(10),
            SearchTimeRangeUnit: model.GetSqlRequestSearchTimeRangeUnitEnum().MINUTE,
        },
    }
	alarmActionRuleNameUpdateSqlAlarmRuleRequestBody:= ""
	sqlAlarmRuleDescriptionUpdateSqlAlarmRuleRequestBody:= "huawei"
	isCssSqlUpdateSqlAlarmRuleRequestBody:= false
	alarmRuleAliasUpdateSqlAlarmRuleRequestBody:= "zhangsan"
	request.Body = &model.UpdateSqlAlarmRuleRequestBody{
		AlarmActionRuleName: &alarmActionRuleNameUpdateSqlAlarmRuleRequestBody,
		NotificationFrequency: model.GetUpdateSqlAlarmRuleRequestBodyNotificationFrequencyEnum().E_5,
		NotificationSaveRule: notificationSaveRulebody,
		DomainId: "",
		SqlAlarmSendCode: model.GetUpdateSqlAlarmRuleRequestBodySqlAlarmSendCodeEnum().E_0,
		SqlAlarmSend: true,
		SqlAlarmLevel: model.GetUpdateSqlAlarmRuleRequestBodySqlAlarmLevelEnum().CRITICAL,
		ConditionExpression: "t>0",
		Frequency: frequencybody,
		SqlRequests: listSqlRequestsbody,
		SqlAlarmRuleDescription: &sqlAlarmRuleDescriptionUpdateSqlAlarmRuleRequestBody,
		IsCssSql: &isCssSqlUpdateSqlAlarmRuleRequestBody,
		AlarmRuleAlias: &alarmRuleAliasUpdateSqlAlarmRuleRequestBody,
		SqlAlarmRuleName: "huawei",
		SqlAlarmRuleId: "",
	}
	response, err := client.UpdateSqlAlarmRule(request)
	if err == nil {
        fmt.Printf("%+v\n", response)
    } else {
        fmt.Println(err)
    }
}

更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。

状态码

状态码

描述

200

请求响应成功。

400

BadRequest 非法请求 建议根据error_msg直接修改该请求。

500

表明服务端能被请求访问到,但是服务内部出错。

错误码

请参见错误码