消息发布

• 消息发布

  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

  # coding: utf-8 import os from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdksmn.v2.region.smn_region import SmnRegion from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdksmn.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 = SmnClient.new_builder() \ .with_credentials(credentials) \ .with_region(SmnRegion.value_of("<YOUR REGION>")) \ .build() try: request = PublishMessageRequest() request.topic_urn = "{topic_urn}" listMessageAttributesbody = [ MessageAttribute( name="smn_protocol", type="PROTOCOL", value="[email, sms]" ) ] request.body = PublishMessageRequestBody( message_attributes=listMessageAttributesbody, time_to_live="3600", message="Message test message v2", subject="test message v2" ) response = client.publish_message(request) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg)

• 使用消息结构体方式的消息发布

  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

  # coding: utf-8 import os from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdksmn.v2.region.smn_region import SmnRegion from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdksmn.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 = SmnClient.new_builder() \ .with_credentials(credentials) \ .with_region(SmnRegion.value_of("<YOUR REGION>")) \ .build() try: request = PublishMessageRequest() request.topic_urn = "{topic_urn}" listMessageAttributesbody = [ MessageAttribute( name="smn_protocol", type="PROTOCOL", value="[email, sms]" ) ] request.body = PublishMessageRequestBody( message_attributes=listMessageAttributesbody, time_to_live="3600", message_structure="{ "default": "Message structure test message v2", "sms": "Message structure test message v2", "email": "Message structure test message v2", "wechat": "{\"msgtype\":\"text\",\"text\":{\"content\":\"Message structure test message v2\"}}", "dingding": "{\"msgtype\":\"markdown\",\"at\":{\"atMobiles\": [\"15XXXXXX\"],\"atUserIds\": [\"1234567XXX\"],\"isAtAll\": true},\"markdown\":{\"content\":\"Message structure test message v2 @15XXXXXX @1234567XXX\",\"title\":\"Message structure title\"}}", "feishu": "{\"msgtype\":\"text\",\"text\":{\"content\":\"Message structure test message v2\"}}", "welinkRed": "{\"msgtype\":\"text\",\"text\":{\"content\":\"Message structure test message v2\"}}", "http": "Message structure test message v2", "https": "Message structure test message v2", "dingTalkBot": "{\"msgtype\":\"markdown\",\"markdown\":{\"content\":\"Message structure test message v2 dingTalkBot markdown\",\"title\":\"Message structure title\"}}", "functionstage": "Message structure test message v2" }", subject="test message v2" ) response = client.publish_message(request) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg)

• 使用消息模板方式的消息发布

  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

  # coding: utf-8 import os from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdksmn.v2.region.smn_region import SmnRegion from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdksmn.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 = SmnClient.new_builder() \ .with_credentials(credentials) \ .with_region(SmnRegion.value_of("<YOUR REGION>")) \ .build() try: request = PublishMessageRequest() request.topic_urn = "{topic_urn}" listMessageAttributesbody = [ MessageAttribute( name="smn_protocol", type="PROTOCOL", value="[email, sms]" ) ] listTagsbody = { "topic_urn": "topic_urn3331", "topic_id": "topic_id3332" } request.body = PublishMessageRequestBody( message_attributes=listMessageAttributesbody, time_to_live="3600", tags=listTagsbody, message_template_name="confirm_message", subject="test message template v2" ) response = client.publish_message(request) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg)

• 消息发布

  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

  package main import ( "fmt" "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic" smn "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/smn/v2" "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/smn/v2/model" region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/smn/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 := smn.NewSmnClient( smn.SmnClientBuilder(). WithRegion(region.ValueOf("<YOUR REGION>")). WithCredential(auth). Build()) request := &model.PublishMessageRequest{} request.TopicUrn = "{topic_urn}" valueMessageAttributes:= "[email, sms]" var valueMessageAttributesInterface interface{} = valueMessageAttributes var listMessageAttributesbody = []model.MessageAttribute{ { Name: "smn_protocol", Type: model.GetMessageAttributeTypeEnum().PROTOCOL, Value: &valueMessageAttributesInterface, }, } timeToLivePublishMessageRequestBody:= "3600" messagePublishMessageRequestBody:= "Message test message v2" subjectPublishMessageRequestBody:= "test message v2" request.Body = &model.PublishMessageRequestBody{ MessageAttributes: &listMessageAttributesbody, TimeToLive: &timeToLivePublishMessageRequestBody, Message: &messagePublishMessageRequestBody, Subject: &subjectPublishMessageRequestBody, } response, err := client.PublishMessage(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } }

• 使用消息结构体方式的消息发布

  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

  package main import ( "fmt" "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic" smn "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/smn/v2" "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/smn/v2/model" region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/smn/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 := smn.NewSmnClient( smn.SmnClientBuilder(). WithRegion(region.ValueOf("<YOUR REGION>")). WithCredential(auth). Build()) request := &model.PublishMessageRequest{} request.TopicUrn = "{topic_urn}" valueMessageAttributes:= "[email, sms]" var valueMessageAttributesInterface interface{} = valueMessageAttributes var listMessageAttributesbody = []model.MessageAttribute{ { Name: "smn_protocol", Type: model.GetMessageAttributeTypeEnum().PROTOCOL, Value: &valueMessageAttributesInterface, }, } timeToLivePublishMessageRequestBody:= "3600" messageStructurePublishMessageRequestBody:= "{ "default": "Message structure test message v2", "sms": "Message structure test message v2", "email": "Message structure test message v2", "wechat": "{\"msgtype\":\"text\",\"text\":{\"content\":\"Message structure test message v2\"}}", "dingding": "{\"msgtype\":\"markdown\",\"at\":{\"atMobiles\": [\"15XXXXXX\"],\"atUserIds\": [\"1234567XXX\"],\"isAtAll\": true},\"markdown\":{\"content\":\"Message structure test message v2 @15XXXXXX @1234567XXX\",\"title\":\"Message structure title\"}}", "feishu": "{\"msgtype\":\"text\",\"text\":{\"content\":\"Message structure test message v2\"}}", "welinkRed": "{\"msgtype\":\"text\",\"text\":{\"content\":\"Message structure test message v2\"}}", "http": "Message structure test message v2", "https": "Message structure test message v2", "dingTalkBot": "{\"msgtype\":\"markdown\",\"markdown\":{\"content\":\"Message structure test message v2 dingTalkBot markdown\",\"title\":\"Message structure title\"}}", "functionstage": "Message structure test message v2" }" subjectPublishMessageRequestBody:= "test message v2" request.Body = &model.PublishMessageRequestBody{ MessageAttributes: &listMessageAttributesbody, TimeToLive: &timeToLivePublishMessageRequestBody, MessageStructure: &messageStructurePublishMessageRequestBody, Subject: &subjectPublishMessageRequestBody, } response, err := client.PublishMessage(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } }

• 使用消息模板方式的消息发布

  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

  package main import ( "fmt" "github.com/huaweicloud/huaweicloud-sdk-go-v3/core/auth/basic" smn "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/smn/v2" "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/smn/v2/model" region "github.com/huaweicloud/huaweicloud-sdk-go-v3/services/smn/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 := smn.NewSmnClient( smn.SmnClientBuilder(). WithRegion(region.ValueOf("<YOUR REGION>")). WithCredential(auth). Build()) request := &model.PublishMessageRequest{} request.TopicUrn = "{topic_urn}" valueMessageAttributes:= "[email, sms]" var valueMessageAttributesInterface interface{} = valueMessageAttributes var listMessageAttributesbody = []model.MessageAttribute{ { Name: "smn_protocol", Type: model.GetMessageAttributeTypeEnum().PROTOCOL, Value: &valueMessageAttributesInterface, }, } var listTagsbody = map[string]string{ "topic_urn": "topic_urn3331", "topic_id": "topic_id3332", } timeToLivePublishMessageRequestBody:= "3600" messageTemplateNamePublishMessageRequestBody:= "confirm_message" subjectPublishMessageRequestBody:= "test message template v2" request.Body = &model.PublishMessageRequestBody{ MessageAttributes: &listMessageAttributesbody, TimeToLive: &timeToLivePublishMessageRequestBody, Tags: listTagsbody, MessageTemplateName: &messageTemplateNamePublishMessageRequestBody, Subject: &subjectPublishMessageRequestBody, } response, err := client.PublishMessage(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } }

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