使用SDK管理SLS告警-以Go为例

packagemainimportsls_sdk"github.com/aliyun/alibaba-cloud-sdk-go/services/sls"funcmain() {
client, err :=sls_sdk.NewClientWithAccessKey("REGION_ID", "ACCESS_KEY_ID", "ACCESS_KEY_SECRET")
iferr!=nil {
// Handle exceptionspanic(err)
 }
...}

request :=sls_sdk.CreateInitUserAlertResourceRequest()
request.Domain="sls.aliyuncs.com"request.Region="cn-huhehaote"request.App="none"request.Language="cn"response, err :=client.InitUserAlertResource(request)
iferr!=nil {
log.Println(fmt.Sprintf("set alert %s", err.Error()))
panic(fmt.Errorf("set alert center resource err %v", err))
}
responseBytes, err :=json.Marshal(response)
log.Println(string(responseBytes), err)
...

request :=sls_sdk.CreateInitProjectAlertResourceRequest()
request.Domain="sls.aliyuncs.com"request.Region="cn-beijing"request.ProjectName="test-my-project-xxx"response, err :=client.InitProjectAlertResource(request)
iferr!=nil {
log.Println(fmt.Sprintf("set alert %s", err.Error()))
panic(fmt.Errorf("set alert project resource err %v", err))
}
responseBytes, err :=json.Marshal(response)
log.Println(string(responseBytes), err)

$goget-ugithub.com/aliyun/aliyun-log-go-sdk

packagemainimport (
"fmt"sls"github.com/aliyun/aliyun-log-go-sdk""github.com/gogo/protobuf/proto""math/rand""time")
funcmain() {
// 日志服务的服务入口。更多信息，请参见服务入口。// 此处以杭州为例，其它地域请根据实际情况填写。Endpoint :="cn-hangzhou.log.aliyuncs.com"// 配置AccessKey、服务入口、Project名称、Logstore名称等相关信息。// 阿里云访问密钥AccessKey。更多信息，请参见访问密钥。阿里云账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM用户进行API访问或日常运维。AccessKeyId :="your_access_key_id"AccessKeySecret :="your_access_key_secret"// RAM用户角色的临时安全令牌。此处取值为空，表示不使用临时安全令牌。更多信息，请参见授权用户角色。SecurityToken :=""// 创建日志服务Client。client :=sls.CreateNormalInterface(Endpoint, AccessKeyId, AccessKeySecret, SecurityToken)
....}

projectName :="test-my-project"alert :=&sls.Alert{
Name:        "test-alert-by-sdk",
State:       "Enabled",
DisplayName: "AlertTest By GO SDK ",
Description: "Description for alert by go sdk",
Schedule: &sls.Schedule{
Type:     sls.ScheduleTypeFixedRate,
Interval: "1m",
    },
Configuration: &sls.AlertConfiguration{
Version: "2.0",
Type:    "default",
GroupConfiguration: sls.GroupConfiguration{
Type: sls.GroupTypeNoGroup,
   },
QueryList: []*sls.AlertQuery{
    {
Query:        "* | select count(1) as count",
Start:        "-120s",
End:          "now",
TimeSpanType: "Custom",
StoreType:    sls.StoreTypeLog,
Store:        "test-alert",
Region:       "cn-hangzhou",
Project:      projectName,
    },
   },
Dashboard:      "test-dashboard",
MuteUntil:      time.Now().Unix(),
Threshold:      1,
NoDataFire:     true,
NoDataSeverity: sls.Medium,
SendResolved:   true,
Annotations: []*sls.Tag{
&sls.Tag{
Key:   "title",
Value: "this is title",
    },
&sls.Tag{
Key:   "desc",
Value: "this is desc, count is ${count}",
    },
   },
Labels: []*sls.Tag{
&sls.Tag{
Key:   "env",
Value: "test",
    },
   },
SeverityConfigurations: []*sls.SeverityConfiguration{
&sls.SeverityConfiguration{
Severity: sls.Critical,
EvalCondition: sls.ConditionConfiguration{
Condition: "count > 99",
     },
    },
&sls.SeverityConfiguration{
Severity: sls.High,
EvalCondition: sls.ConditionConfiguration{
Condition: "count > 80",
     },
    },
&sls.SeverityConfiguration{
Severity: sls.Medium,
EvalCondition: sls.ConditionConfiguration{
Condition: "count > 20",
     },
    },
&sls.SeverityConfiguration{
Severity: sls.Report,
EvalCondition: sls.ConditionConfiguration{
     },
    },
   },
PolicyConfiguration: sls.PolicyConfiguration{
AlertPolicyId:  "sls.builtin.dynamic",
ActionPolicyId: "xxxx.test",
RepeatInterval: "5m",
   },
    },
 }
err :=client.CreateAlert(projectName, alert)
iferr!=nil {
panic(err)
 }

alerts, _, _, err :=client.ListAlert(projectName, "", "", 0, 100)

alert, err :=client.GetAlert(projectName, "test-alert-by-sdk")

err :=client.DisableAlert(projectName, "test-alert-by-sdk")

err :=client.EnableAlert(projectName, "test-alert-by-sdk")

resourceAlertPolicy :=new(sls.ResourceAlertPolicy)
resourceAlertPolicy.PolicyId="my-alert-policy"resourceAlertPolicy.PolicyName="测试告警策略"resourceAlertPolicy.GroupPolicy=`"fire(action_policy="my-test-action-policy", group={"alert.region": alert.region}, group_wait="30s", group_interval="10m", repeat_interval="4h")"`resourceAlertPolicy.SilencePolicy=""resourceAlertPolicy.InhibitPolicy=""policyVal, _ :=json.Marshal(resourceAlertPolicy)
myAlertPolicyRecord :=new(sls.ResourceRecord)
myAlertPolicyRecord.Id=resourceAlertPolicy.PolicyIdmyAlertPolicyRecord.Tag=resourceAlertPolicy.PolicyNamemyAlertPolicyRecord.Value=string(policyVal)
err :=client.CreateResourceRecord(sls.ResourceNameActionPolicy, myAlertPolicyRecord)

resourceActionPolicy :=new(sls.ResourceActionPolicy)
resourceActionPolicy.ActionPolicyId="my-action-policy"resourceActionPolicy.ActionPolicyName="测试行动策略"resourceActionPolicy.PrimaryPolicyScript=`if alert.labels.a == ("x" or "y"):fire(type="voice", users=["test-user-1"], groups=[], oncall_groups=[], template_id="sls.builtin.cn", check_quota="true", period="any")stop()fire(type="dingtalk", url="https://oapi.dingtalk.com/robot/send?access_token=xxxx", template_id="sls.builtin.cn", users=["test-user-1"], groups=[], oncall_groups=[], check_quota="none", period="any")fire(type="webhook", url="http://test.xxxx.com", method="POST", headers={}, template_id="sls.builtin.cn", check_quota="none", period="any")`alertPolicyVal, _ :=json.Marshal(resourceActionPolicy)
myActionPolicyRecord :=new(sls.ResourceRecord)
myActionPolicyRecord.Id=resourceAlertPolicy.PolicyIdmyActionPolicyRecord.Tag=resourceAlertPolicy.PolicyNamemyActionPolicyRecord.Value=string(alertPolicyVal)
err :=client.CreateResourceRecord(sls.ResourceNameActionPolicy, myActionPolicyRecord)

customUser :=new(sls.ResourceRecord)
user :=new(sls.ResourceUser)
user.UserId="test-user-1"user.UserName="test user name"user.Phone="13888888888"user.CountryCode="86"user.Enabled=trueuser.VoiceEnabled=trueuser.SmsEnabled=trueuserVal, _ :=json.Marshal(user)
customUser.Id=user.UserIdcustomUser.Tag=user.UserNamecustomUser.Value=string(userVal)
err :=client.CreateResourceRecord(sls.ResourceNameUser, customUser)

user.UserName="new name"userVal, _=json.Marshal(user)
customUser.Value=string(userVal)
err=client.UpdateResourceRecord(sls.ResourceNameUser, customUser)

err :=client.DeleteResourceRecord(sls.ResourceNameUser, "test-user-1")

resourceRecord, err :=client.GetResourceRecord(sls.ResourceNameUser, "test-user-1")
iferr!=nil {
panic(err)
 }
user :=new(sls.ResourceUser)
err=json.Unmarshal([]byte(resourceRecord.Value), user)

resourceRecords, total, count, err :=client.ListResourceRecord(sls.ResourceNameUser, 0, 100)
iferr!=nil {
panic(err)
 }
resourceUsers := []*sls.ResourceUser{}
for_, resourceRecord :=rangeresourceRecords {
user :=new(sls.ResourceUser)
err=json.Unmarshal([]byte(resourceRecord.Value), user)
iferr==nil {
resourceUsers=append(resourceUsers, user)
    }
 }

const (
// 告警策略ResourceNameAlertPolicy="sls.alert.alert_policy"// 行动策略ResourceNameActionPolicy="sls.alert.action_policy"// 用户ResourceNameUser="sls.common.user"// 用户组ResourceNameUserGroup="sls.common.user_group"// 内容模板ResourceNameContentTemplate="sls.alert.content_template"// Webhook集成ResourceNameWebhookIntegration="sls.alert.webhook_application"// 全局配置ResourceNameGlobalConfig="sls.alert.global_config")