


package mainimport ("context""encoding/json""fmt""github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common""github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/errors""github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/common/profile"config "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/config/v20220802""github.com/tencentyun/scf-go-lib/cloudfunction")// maingofunc main() {cloudfunction.Start(ReceiveMessage)}type Tag struct {TagKey stringTagValue string}type ClientContext struct {InvokingEvent *InvokingEventRuleParameters map[string]string //规则参数ResultToken string //加密令牌OrderingTimestamp int64 //评估时间戳}type InvokingEvent struct {TriggerType stringConfigurationItem *ConfigurationItem}type ConfigurationItem struct {AccountId int64 //资源所属用户IDRegion string //资源地域Zone string //资源可用区Configuration string //资源详细配置ResourceCreationTime int64 //资源创建时间戳ResourceType string //资源类型ResourceId string //资源IDResourceStatus string //资源IDResourceName string //资源名称Tags []Tag //资源标签CaptureTime int64 //资源快照时间戳}// ReceiveMessage 接受消费消息{// "InvokingEvent": {// "TriggerType": "MANUAL",// "ConfigurationItem": {// "AccountId": 100004293724,// "Region": "ap-guangzhou",// "Zone": "",// "Configuration": { //每种资源类型Configuration内容字段不同// "CidrBlock": "172.16.0.0/16",// "IsDefault": true,// "Ipv6CidrBlock": "",// "DnsServerSet": null,// "DomainName": "",// "DhcpOptionsId": ""// },// "ResourceCreationTime": 1520431078,// "ResourceType": "QCS::VPC::Vpc",// "ResourceId": "vpc-q252nx9j",// "ResourceStatus": "",// "ResourceName": "Default-VPC",// "Tags": null,// "CaptureTime": 1686500243// }// },// "RuleParameters": {// "234": "324"// },// "ResultToken": "Wm9yZlY3WmlKa3cxaW1oQpgtklO2shRhG1gtxnC4qyszJtkSz5ZpZDshF6YyaaIAagGsEAcidC-VFNJHtRfXfam_FHMR_RhhelEAT4ApsKFQIBEZNaWN284dZS02f7uRT6w_zwHz5E1dXmNYvancDRgiCQHip_uUrif0Toypdbh1tuLODHgVN1csbaPKu3hb2-O-PBh824HACVUkDXJAp2KMQnqhNagmlUULjY-GMyM=",// "OrderingTimestamp": 1686537830//}func ReceiveMessage(ctx context.Context, event ClientContext) error {eventStr, _ := json.Marshal(event)fmt.Println("SCF:ReceiveMessage:Event:", string(eventStr))putRuleResule(event)return nil}//自定义判断资源是否合规---对资源进行评估,需要根据实际业务自行实现评估逻辑,返回COMPLIANT、NON_COMPLIANT;以下代码仅供参考func getComplianceType(configurationStr string) string {return "COMPLIANT"}func putRuleResule(event ClientContext) {evaluations := make([]*config.Evaluation, 0)//1:设置评估结果,格式需符合以下示例要求。complianceType := getComplianceType(event.InvokingEvent.ConfigurationItem.Configuration)configuration := "xxxx"desiredValue := "xxxxx"evaluation := &config.Evaluation{ComplianceResourceId: &event.InvokingEvent.ConfigurationItem.ResourceId,ComplianceResourceType: &event.InvokingEvent.ConfigurationItem.ResourceType,ComplianceRegion: &event.InvokingEvent.ConfigurationItem.Region,ComplianceType: &complianceType,Annotation: &config.Annotation{Configuration: &configuration,DesiredValue: &desiredValue,},}evaluations = append(evaluations, evaluation)//2:上报评估结果//需具备权限Config_QCSLinkedRoleInConfigRecorder服务角色credential := common.NewCredential("xxxx","xxxxx",)cpf := profile.NewClientProfile()cpf.HttpProfile.Endpoint = "config.internal.tencentcloudapi.com"client, _ := config.NewClient(credential, "ap-guangzhou", cpf)request := config.NewPutEvaluationsRequest()request.ResultToken = &event.ResultTokenrequest.Evaluations = evaluationsresponse, err := client.PutEvaluations(request)if _, ok := err.(*errors.TencentCloudSDKError); ok {fmt.Printf("An API error has returned: %s", err)return}if err != nil {panic(err)}// 输出json格式的字符串回包fmt.Printf("%s", response.ToJsonString())}





文档反馈