diff --git a/.changelog/3523.txt b/.changelog/3523.txt new file mode 100644 index 0000000000..1e77fa55be --- /dev/null +++ b/.changelog/3523.txt @@ -0,0 +1,3 @@ +```release-note:new-resource +tencentcloud_cynosdb_cls_delivery +``` \ No newline at end of file diff --git a/tencentcloud/provider.go b/tencentcloud/provider.go index 7aca6e82d1..04fdf43359 100644 --- a/tencentcloud/provider.go +++ b/tencentcloud/provider.go @@ -1745,6 +1745,7 @@ func Provider() *schema.Provider { "tencentcloud_cynosdb_upgrade_proxy_version": cynosdb.ResourceTencentCloudCynosdbUpgradeProxyVersion(), "tencentcloud_cynosdb_backup_config": cynosdb.ResourceTencentCloudCynosdbBackupConfig(), "tencentcloud_cynosdb_ssl": cynosdb.ResourceTencentCloudCynosdbSsl(), + "tencentcloud_cynosdb_cls_delivery": cynosdb.ResourceTencentCloudCynosdbClsDelivery(), "tencentcloud_vod_adaptive_dynamic_streaming_template": vod.ResourceTencentCloudVodAdaptiveDynamicStreamingTemplate(), "tencentcloud_vod_image_sprite_template": vod.ResourceTencentCloudVodImageSpriteTemplate(), "tencentcloud_vod_procedure_template": vod.ResourceTencentCloudVodProcedureTemplate(), diff --git a/tencentcloud/provider.md b/tencentcloud/provider.md index b17431ed87..791bd1853d 100644 --- a/tencentcloud/provider.md +++ b/tencentcloud/provider.md @@ -545,6 +545,7 @@ tencentcloud_cynosdb_proxy_end_point tencentcloud_cynosdb_upgrade_proxy_version tencentcloud_cynosdb_backup_config tencentcloud_cynosdb_ssl +tencentcloud_cynosdb_cls_delivery Direct Connect(DC) Data Source diff --git a/tencentcloud/services/cynosdb/resource_tc_cynosdb_cls_delivery.go b/tencentcloud/services/cynosdb/resource_tc_cynosdb_cls_delivery.go new file mode 100644 index 0000000000..4abb56263b --- /dev/null +++ b/tencentcloud/services/cynosdb/resource_tc_cynosdb_cls_delivery.go @@ -0,0 +1,613 @@ +package cynosdb + +import ( + "context" + "fmt" + "log" + "strconv" + "strings" + "time" + + "github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource" + "github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema" + cynosdb "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cynosdb/v20190107" + cynosdbv20190107 "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/cynosdb/v20190107" + + tccommon "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/common" + "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper" +) + +func ResourceTencentCloudCynosdbClsDelivery() *schema.Resource { + return &schema.Resource{ + Create: resourceTencentCloudCynosdbClsDeliveryCreate, + Read: resourceTencentCloudCynosdbClsDeliveryRead, + Update: resourceTencentCloudCynosdbClsDeliveryUpdate, + Delete: resourceTencentCloudCynosdbClsDeliveryDelete, + Importer: &schema.ResourceImporter{ + State: schema.ImportStatePassthrough, + }, + Schema: map[string]*schema.Schema{ + "instance_id": { + Type: schema.TypeString, + Required: true, + ForceNew: true, + Description: "Instance ID.", + }, + + "cls_info_list": { + Type: schema.TypeList, + Required: true, + ForceNew: true, + MaxItems: 1, + Description: "Log delivery configuration.", + Elem: &schema.Resource{ + Schema: map[string]*schema.Schema{ + "topic_operation": { + Type: schema.TypeString, + Required: true, + Description: "Log topic operations: Optional: create or reuse. create: Creates a new log topic using TopicName. reuse: Reuses an existing log topic using TopicId. Reusing an existing log topic and creating a new log set is not allowed.", + }, + "group_operation": { + Type: schema.TypeString, + Required: true, + Description: "Log set operations: Optional: create or reuse. create: Creates a new log set, using the GroupName. reuse: Reuses an existing log set, using the GroupId. The combination of reusing an existing log topic and creating a new log set is not allowed.", + }, + "region": { + Type: schema.TypeString, + Required: true, + Description: "Log delivery region.", + }, + "topic_id": { + Type: schema.TypeString, + Optional: true, + Computed: true, + Description: "Log topic ID.", + }, + "topic_name": { + Type: schema.TypeString, + Optional: true, + Computed: true, + Description: "Log topic name.", + }, + "group_id": { + Type: schema.TypeString, + Optional: true, + Computed: true, + Description: "Log set ID.", + }, + "group_name": { + Type: schema.TypeString, + Optional: true, + Computed: true, + Description: "Log set name.", + }, + }, + }, + }, + + "log_type": { + Type: schema.TypeString, + Optional: true, + ForceNew: true, + Computed: true, + Description: "Log type.", + }, + + "enable_cls_delivery": { + Type: schema.TypeBool, + Optional: true, + Default: true, + Description: "Whether to enable CLS delivery. Default value: true (enabled).", + }, + + // computed + "status": { + Type: schema.TypeString, + Computed: true, + Description: "Delivery status. running, offlined.", + }, + }, + } +} + +func resourceTencentCloudCynosdbClsDeliveryCreate(d *schema.ResourceData, meta interface{}) error { + defer tccommon.LogElapsed("resource.tencentcloud_cynosdb_cls_delivery.create")() + defer tccommon.InconsistentCheck(d, meta)() + + var ( + logId = tccommon.GetLogId(tccommon.ContextNil) + ctx = tccommon.NewResourceLifeCycleHandleFuncContext(context.Background(), logId, d, meta) + service = CynosdbService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()} + request = cynosdbv20190107.NewCreateCLSDeliveryRequest() + response = cynosdbv20190107.NewCreateCLSDeliveryResponse() + instanceId string + groupId string + topicId string + ) + + if v, ok := d.GetOk("instance_id"); ok { + request.InstanceId = helper.String(v.(string)) + instanceId = v.(string) + } + + if v, ok := d.GetOk("cls_info_list"); ok { + for _, item := range v.([]interface{}) { + cLSInfoListMap := item.(map[string]interface{}) + cLSInfo := cynosdbv20190107.CLSInfo{} + if v, ok := cLSInfoListMap["topic_operation"].(string); ok && v != "" { + cLSInfo.TopicOperation = helper.String(v) + } + + if v, ok := cLSInfoListMap["group_operation"].(string); ok && v != "" { + cLSInfo.GroupOperation = helper.String(v) + } + + if v, ok := cLSInfoListMap["region"].(string); ok && v != "" { + cLSInfo.Region = helper.String(v) + } + + if v, ok := cLSInfoListMap["topic_id"].(string); ok && v != "" { + cLSInfo.TopicId = helper.String(v) + } + + if v, ok := cLSInfoListMap["topic_name"].(string); ok && v != "" { + cLSInfo.TopicName = helper.String(v) + } + + if v, ok := cLSInfoListMap["group_id"].(string); ok && v != "" { + cLSInfo.GroupId = helper.String(v) + } + + if v, ok := cLSInfoListMap["group_name"].(string); ok && v != "" { + cLSInfo.GroupName = helper.String(v) + } + + request.CLSInfoList = append(request.CLSInfoList, &cLSInfo) + } + } + + if v, ok := d.GetOk("log_type"); ok { + request.LogType = helper.String(v.(string)) + } + + reqErr := resource.Retry(tccommon.WriteRetryTimeout, func() *resource.RetryError { + result, e := meta.(tccommon.ProviderMeta).GetAPIV3Conn().UseCynosdbClient().CreateCLSDeliveryWithContext(ctx, request) + if e != nil { + return tccommon.RetryError(e) + } else { + log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, request.GetAction(), request.ToJsonString(), result.ToJsonString()) + } + + if result == nil || result.Response == nil { + return tccommon.RetryError(fmt.Errorf("Create cynosdb cls delivery failed, Response is nil.")) + } + + response = result + return nil + }) + + if reqErr != nil { + log.Printf("[CRITAL]%s create cynosdb cls delivery failed, reason:%+v", logId, reqErr) + return reqErr + } + + if response.Response.TaskId == nil { + return fmt.Errorf("TaskId is nil.") + } + + // wait for create + taskId := response.Response.TaskId + conf := tccommon.BuildStateChangeConf([]string{}, []string{"success"}, 10*tccommon.ReadRetryTimeout, time.Second, service.taskStateRefreshFunc(strconv.FormatInt(*taskId, 10), []string{})) + if _, e := conf.WaitForState(); e != nil { + return e + } + + // get cls info + clsReq := cynosdbv20190107.NewDescribeTasksRequest() + clsResp := cynosdbv20190107.NewDescribeTasksResponse() + clsReq.Filters = []*cynosdb.QueryFilter{ + { + ExactMatch: helper.Bool(true), + Names: helper.Strings([]string{"TaskId"}), + Values: helper.Strings([]string{strconv.FormatInt(*taskId, 10)}), + }, + } + reqErr = resource.Retry(tccommon.ReadRetryTimeout, func() *resource.RetryError { + result, e := meta.(tccommon.ProviderMeta).GetAPIV3Conn().UseCynosdbClient().DescribeTasksWithContext(ctx, clsReq) + if e != nil { + return tccommon.RetryError(e) + } else { + log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, clsReq.GetAction(), clsReq.ToJsonString(), result.ToJsonString()) + } + + if result == nil || result.Response == nil { + return tccommon.RetryError(fmt.Errorf("Describe cynosdb cls delivery failed, Response is nil.")) + } + + clsResp = result + return nil + }) + + if reqErr != nil { + log.Printf("[CRITAL]%s describe cynosdb cls delivery failed, reason:%+v", logId, reqErr) + return reqErr + } + + if clsResp.Response.TaskList == nil || len(clsResp.Response.TaskList) == 0 { + return fmt.Errorf("TaskList is nil.") + } + + if len(clsResp.Response.TaskList) != 1 { + return fmt.Errorf("TaskList length is not 1.") + } + + if clsResp.Response.TaskList[0].InstanceCLSDeliveryInfos == nil || len(clsResp.Response.TaskList[0].InstanceCLSDeliveryInfos) == 0 { + return fmt.Errorf("InstanceCLSDeliveryInfos is nil.") + } + + instanceCLSDeliveryInfo := clsResp.Response.TaskList[0].InstanceCLSDeliveryInfos[0] + if instanceCLSDeliveryInfo.GroupId == nil || instanceCLSDeliveryInfo.TopicId == nil { + return fmt.Errorf("GroupId or TopicId is nil.") + } + + groupId = *instanceCLSDeliveryInfo.GroupId + topicId = *instanceCLSDeliveryInfo.TopicId + d.SetId(strings.Join([]string{instanceId, groupId, topicId}, tccommon.FILED_SP)) + + // operate cls delivery + if v, ok := d.GetOkExists("enable_cls_delivery"); ok { + if !v.(bool) { + // stop cls delivery + request := cynosdb.NewStopCLSDeliveryRequest() + response := cynosdb.NewStopCLSDeliveryResponse() + request.InstanceId = helper.String(instanceId) + request.CLSTopicIds = helper.Strings([]string{topicId}) + if v, ok := d.GetOk("log_type"); ok { + request.LogType = helper.String(v.(string)) + } + reqErr := resource.Retry(tccommon.WriteRetryTimeout, func() *resource.RetryError { + result, e := meta.(tccommon.ProviderMeta).GetAPIV3Conn().UseCynosdbClient().StopCLSDeliveryWithContext(ctx, request) + if e != nil { + return tccommon.RetryError(e) + } else { + log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, request.GetAction(), request.ToJsonString(), result.ToJsonString()) + } + + if result == nil || result.Response == nil { + return tccommon.RetryError(fmt.Errorf("Stop cynosdb cls delivery failed, Response is nil.")) + } + + response = result + return nil + }) + + if reqErr != nil { + log.Printf("[CRITAL]%s stop cynosdb cls delivery failed, reason:%+v", logId, reqErr) + return reqErr + } + + if response.Response.TaskId == nil { + return fmt.Errorf("TaskId is nil.") + } + + // wait for start + taskId := response.Response.TaskId + conf := tccommon.BuildStateChangeConf([]string{}, []string{"success"}, 10*tccommon.ReadRetryTimeout, time.Second, service.taskStateRefreshFunc(strconv.FormatInt(*taskId, 10), []string{})) + if _, e := conf.WaitForState(); e != nil { + return e + } + } + } + + return resourceTencentCloudCynosdbClsDeliveryRead(d, meta) +} + +func resourceTencentCloudCynosdbClsDeliveryRead(d *schema.ResourceData, meta interface{}) error { + defer tccommon.LogElapsed("resource.tencentcloud_cynosdb_cls_delivery.read")() + defer tccommon.InconsistentCheck(d, meta)() + + var ( + logId = tccommon.GetLogId(tccommon.ContextNil) + ctx = tccommon.NewResourceLifeCycleHandleFuncContext(context.Background(), logId, d, meta) + service = CynosdbService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()} + ) + + idSplit := strings.Split(d.Id(), tccommon.FILED_SP) + if len(idSplit) != 3 { + return fmt.Errorf("id is broken,%s", d.Id()) + } + + instanceId := idSplit[0] + groupId := idSplit[1] + topicId := idSplit[2] + + respData, err := service.DescribeCynosdbClsDeliveryById(ctx, instanceId, groupId, topicId) + if err != nil { + return err + } + + if respData == nil { + log.Printf("[WARN]%s resource `cynosdb_cls_delivery` [%s] not found, please check if it has been deleted.\n", logId, d.Id()) + d.SetId("") + return nil + } + + if respData.InstanceId != nil { + _ = d.Set("instance_id", respData.InstanceId) + } + + tmpList := make([]map[string]interface{}, 0, 1) + tmpMap := make(map[string]interface{}, 0) + if respData.Region != nil { + tmpMap["region"] = respData.Region + } + + if respData.TopicId != nil { + tmpMap["topic_id"] = respData.TopicId + } + + if respData.TopicName != nil { + tmpStr := trimPrefixSuffix(*respData.TopicName, "_topic") + tmpMap["topic_name"] = tmpStr + } + + if respData.GroupId != nil { + tmpMap["group_id"] = respData.GroupId + } + + if respData.GroupName != nil { + tmpStr := trimPrefixSuffix(*respData.GroupName, "_group") + tmpMap["group_name"] = tmpStr + } + + tmpList = append(tmpList, tmpMap) + _ = d.Set("cls_info_list", tmpList) + + if respData.LogType != nil { + _ = d.Set("log_type", respData.LogType) + } + + if respData.Status != nil { + _ = d.Set("status", respData.Status) + } + + return nil +} + +func resourceTencentCloudCynosdbClsDeliveryUpdate(d *schema.ResourceData, meta interface{}) error { + defer tccommon.LogElapsed("resource.tencentcloud_cynosdb_cls_delivery.update")() + defer tccommon.InconsistentCheck(d, meta)() + + var ( + logId = tccommon.GetLogId(tccommon.ContextNil) + ctx = tccommon.NewResourceLifeCycleHandleFuncContext(context.Background(), logId, d, meta) + service = CynosdbService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()} + ) + + idSplit := strings.Split(d.Id(), tccommon.FILED_SP) + if len(idSplit) != 3 { + return fmt.Errorf("id is broken,%s", d.Id()) + } + + instanceId := idSplit[0] + topicId := idSplit[2] + + if d.HasChange("enable_cls_delivery") { + if v, ok := d.GetOkExists("enable_cls_delivery"); ok { + if v.(bool) { + // start cls delivery + request := cynosdb.NewStartCLSDeliveryRequest() + response := cynosdb.NewStartCLSDeliveryResponse() + request.InstanceId = helper.String(instanceId) + request.CLSTopicIds = helper.Strings([]string{topicId}) + if v, ok := d.GetOk("log_type"); ok { + request.LogType = helper.String(v.(string)) + } + reqErr := resource.Retry(tccommon.WriteRetryTimeout, func() *resource.RetryError { + result, e := meta.(tccommon.ProviderMeta).GetAPIV3Conn().UseCynosdbClient().StartCLSDeliveryWithContext(ctx, request) + if e != nil { + return tccommon.RetryError(e) + } else { + log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, request.GetAction(), request.ToJsonString(), result.ToJsonString()) + } + + if result == nil || result.Response == nil { + return tccommon.RetryError(fmt.Errorf("Start cynosdb cls delivery failed, Response is nil.")) + } + + response = result + return nil + }) + + if reqErr != nil { + log.Printf("[CRITAL]%s start cynosdb cls delivery failed, reason:%+v", logId, reqErr) + return reqErr + } + + if response.Response.TaskId == nil { + return fmt.Errorf("TaskId is nil.") + } + + // wait for start + taskId := response.Response.TaskId + conf := tccommon.BuildStateChangeConf([]string{}, []string{"success"}, 10*tccommon.ReadRetryTimeout, time.Second, service.taskStateRefreshFunc(strconv.FormatInt(*taskId, 10), []string{})) + if _, e := conf.WaitForState(); e != nil { + return e + } + } else { + // stop cls delivery + request := cynosdb.NewStopCLSDeliveryRequest() + response := cynosdb.NewStopCLSDeliveryResponse() + request.InstanceId = helper.String(instanceId) + request.CLSTopicIds = helper.Strings([]string{topicId}) + if v, ok := d.GetOk("log_type"); ok { + request.LogType = helper.String(v.(string)) + } + reqErr := resource.Retry(tccommon.WriteRetryTimeout, func() *resource.RetryError { + result, e := meta.(tccommon.ProviderMeta).GetAPIV3Conn().UseCynosdbClient().StopCLSDeliveryWithContext(ctx, request) + if e != nil { + return tccommon.RetryError(e) + } else { + log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, request.GetAction(), request.ToJsonString(), result.ToJsonString()) + } + + if result == nil || result.Response == nil { + return tccommon.RetryError(fmt.Errorf("Stop cynosdb cls delivery failed, Response is nil.")) + } + + response = result + return nil + }) + + if reqErr != nil { + log.Printf("[CRITAL]%s stop cynosdb cls delivery failed, reason:%+v", logId, reqErr) + return reqErr + } + + if response.Response.TaskId == nil { + return fmt.Errorf("TaskId is nil.") + } + + // wait for start + taskId := response.Response.TaskId + conf := tccommon.BuildStateChangeConf([]string{}, []string{"success"}, 10*tccommon.ReadRetryTimeout, time.Second, service.taskStateRefreshFunc(strconv.FormatInt(*taskId, 10), []string{})) + if _, e := conf.WaitForState(); e != nil { + return e + } + } + } + } + + return resourceTencentCloudCynosdbClsDeliveryRead(d, meta) +} + +func resourceTencentCloudCynosdbClsDeliveryDelete(d *schema.ResourceData, meta interface{}) error { + defer tccommon.LogElapsed("resource.tencentcloud_cynosdb_cls_delivery.delete")() + defer tccommon.InconsistentCheck(d, meta)() + + var ( + logId = tccommon.GetLogId(tccommon.ContextNil) + ctx = tccommon.NewResourceLifeCycleHandleFuncContext(context.Background(), logId, d, meta) + service = CynosdbService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()} + ) + + idSplit := strings.Split(d.Id(), tccommon.FILED_SP) + if len(idSplit) != 3 { + return fmt.Errorf("id is broken,%s", d.Id()) + } + + instanceId := idSplit[0] + groupId := idSplit[1] + topicId := idSplit[2] + + respData, err := service.DescribeCynosdbClsDeliveryById(ctx, instanceId, groupId, topicId) + if err != nil { + return err + } + + if respData == nil { + log.Printf("[WARN]%s resource `cynosdb_cls_delivery` [%s] not found, please check if it has been deleted.\n", logId, d.Id()) + d.SetId("") + return nil + } + + // check status + status := respData.Status + if status != nil && *status == "running" { + // stop cls delivery first + request := cynosdb.NewStopCLSDeliveryRequest() + response := cynosdb.NewStopCLSDeliveryResponse() + request.InstanceId = helper.String(instanceId) + request.CLSTopicIds = helper.Strings([]string{topicId}) + if v, ok := d.GetOk("log_type"); ok { + request.LogType = helper.String(v.(string)) + } + reqErr := resource.Retry(tccommon.WriteRetryTimeout, func() *resource.RetryError { + result, e := meta.(tccommon.ProviderMeta).GetAPIV3Conn().UseCynosdbClient().StopCLSDeliveryWithContext(ctx, request) + if e != nil { + return tccommon.RetryError(e) + } else { + log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, request.GetAction(), request.ToJsonString(), result.ToJsonString()) + } + + if result == nil || result.Response == nil { + return tccommon.RetryError(fmt.Errorf("Stop cynosdb cls delivery failed, Response is nil.")) + } + + response = result + return nil + }) + + if reqErr != nil { + log.Printf("[CRITAL]%s stop cynosdb cls delivery failed, reason:%+v", logId, reqErr) + return reqErr + } + + if response.Response.TaskId == nil { + return fmt.Errorf("TaskId is nil.") + } + + // wait for start + taskId := response.Response.TaskId + conf := tccommon.BuildStateChangeConf([]string{}, []string{"success"}, 10*tccommon.ReadRetryTimeout, time.Second, service.taskStateRefreshFunc(strconv.FormatInt(*taskId, 10), []string{})) + if _, e := conf.WaitForState(); e != nil { + return e + } + } + + request := cynosdbv20190107.NewDeleteCLSDeliveryRequest() + response := cynosdbv20190107.NewDeleteCLSDeliveryResponse() + request.InstanceId = helper.String(instanceId) + request.CLSTopicIds = helper.Strings([]string{topicId}) + if v, ok := d.GetOk("log_type"); ok { + request.LogType = helper.String(v.(string)) + } + reqErr := resource.Retry(tccommon.WriteRetryTimeout, func() *resource.RetryError { + result, e := meta.(tccommon.ProviderMeta).GetAPIV3Conn().UseCynosdbClient().DeleteCLSDeliveryWithContext(ctx, request) + if e != nil { + return tccommon.RetryError(e) + } else { + log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, request.GetAction(), request.ToJsonString(), result.ToJsonString()) + } + + if result == nil || result.Response == nil { + return tccommon.RetryError(fmt.Errorf("Delete cynosdb cls delivery failed, Response is nil.")) + } + + response = result + return nil + }) + + if reqErr != nil { + log.Printf("[CRITAL]%s delete cynosdb cls delivery failed, reason:%+v", logId, reqErr) + return reqErr + } + + if response.Response.TaskId == nil { + return fmt.Errorf("TaskId is nil.") + } + + // wait for delete + taskId := response.Response.TaskId + conf := tccommon.BuildStateChangeConf([]string{}, []string{"success"}, 10*tccommon.ReadRetryTimeout, time.Second, service.taskStateRefreshFunc(strconv.FormatInt(*taskId, 10), []string{})) + if _, e := conf.WaitForState(); e != nil { + return e + } + + return nil +} + +func trimPrefixSuffix(str string, suffixStr string) string { + prefix := "cloud_cynos_" + suffix := suffixStr + + if strings.HasPrefix(str, prefix) { + str = strings.TrimPrefix(str, prefix) + } + + if strings.HasSuffix(str, suffix) { + str = strings.TrimSuffix(str, suffix) + } + + return str +} diff --git a/tencentcloud/services/cynosdb/resource_tc_cynosdb_cls_delivery.md b/tencentcloud/services/cynosdb/resource_tc_cynosdb_cls_delivery.md new file mode 100644 index 0000000000..b32c521ffd --- /dev/null +++ b/tencentcloud/services/cynosdb/resource_tc_cynosdb_cls_delivery.md @@ -0,0 +1,47 @@ +Provides a resource to create a Cynosdb cls delivery + +~> **NOTE:** Destroying this resource will not cause the CLS log set and log topic to be destroyed synchronously. If you need to delete it, you need to access the console page to delete it. + +Example Usage + +If topic_operation/group_operation is create + +```hcl +resource "tencentcloud_cynosdb_cls_delivery" "example" { + instance_id = "cynosdbmysql-ins-anknkhvi" + cls_info_list { + topic_operation = "create" + group_operation = "create" + region = "ap-guangzhou" + topic_name = "tf-example-topic" + group_name = "tf-example-group" + } + log_type = "slow" + enable_cls_delivery = true +} +``` + +If topic_operation/group_operation is reuse + +```hcl +resource "tencentcloud_cynosdb_cls_delivery" "example" { + instance_id = "cynosdbmysql-ins-anknkhvi" + cls_info_list { + topic_operation = "reuse" + group_operation = "reuse" + region = "ap-guangzhou" + topic_id = "8e38f7c1-17ec-4acb-a4cb-7dc14baaef47" + group_id = "7e3bb8b7-81d5-4e6b-b150-f139b90c146e" + } + log_type = "slow" + enable_cls_delivery = false +} +``` + +Import + +Cynosdb cls delivery can be imported using the ${instanceId}#${groupId}#${topicId}, e.g. + +``` +terraform import tencentcloud_cynosdb_cls_delivery.example cynosdbmysql-ins-anknkhvi#7e3bb8b7-81d5-4e6b-b150-f139b90c146e#8e38f7c1-17ec-4acb-a4cb-7dc14baaef47 +``` diff --git a/tencentcloud/services/cynosdb/resource_tc_cynosdb_cls_delivery_test.go b/tencentcloud/services/cynosdb/resource_tc_cynosdb_cls_delivery_test.go new file mode 100644 index 0000000000..2f2326a4f4 --- /dev/null +++ b/tencentcloud/services/cynosdb/resource_tc_cynosdb_cls_delivery_test.go @@ -0,0 +1,76 @@ +package cynosdb_test + +import ( + "testing" + + "github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource" + + tcacctest "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/acctest" +) + +func TestAccTencentCloudCynosdbClsDeliveryResource_basic(t *testing.T) { + t.Parallel() + resource.Test(t, resource.TestCase{ + PreCheck: func() { + tcacctest.AccPreCheck(t) + }, + Providers: tcacctest.AccProviders, + Steps: []resource.TestStep{ + { + Config: testAccCynosdbClsDelivery, + Check: resource.ComposeTestCheckFunc( + resource.TestCheckResourceAttrSet("tencentcloud_cynosdb_cls_delivery.example", "id"), + resource.TestCheckResourceAttrSet("tencentcloud_cynosdb_cls_delivery.example", "instance_id"), + resource.TestCheckResourceAttrSet("tencentcloud_cynosdb_cls_delivery.example", "cls_info_list"), + resource.TestCheckResourceAttrSet("tencentcloud_cynosdb_cls_delivery.example", "log_type"), + resource.TestCheckResourceAttrSet("tencentcloud_cynosdb_cls_delivery.example", "enable_cls_delivery"), + ), + }, + { + Config: testAccCynosdbClsDeliveryUpdate, + Check: resource.ComposeTestCheckFunc( + resource.TestCheckResourceAttrSet("tencentcloud_cynosdb_cls_delivery.example", "id"), + resource.TestCheckResourceAttrSet("tencentcloud_cynosdb_cls_delivery.example", "instance_id"), + resource.TestCheckResourceAttrSet("tencentcloud_cynosdb_cls_delivery.example", "cls_info_list"), + resource.TestCheckResourceAttrSet("tencentcloud_cynosdb_cls_delivery.example", "log_type"), + resource.TestCheckResourceAttrSet("tencentcloud_cynosdb_cls_delivery.example", "enable_cls_delivery"), + ), + }, + { + ResourceName: "tencentcloud_cynosdb_cls_delivery.example", + ImportState: true, + ImportStateVerify: true, + }, + }, + }) +} + +const testAccCynosdbClsDelivery = ` +resource "tencentcloud_cynosdb_cls_delivery" "example" { + instance_id = "cynosdbmysql-ins-anknkhvi" + cls_info_list { + topic_operation = "reuse" + group_operation = "reuse" + region = "ap-guangzhou" + topic_id = "8e38f7c1-17ec-4acb-a4cb-7dc14baaef47" + group_id = "7e3bb8b7-81d5-4e6b-b150-f139b90c146e" + } + log_type = "slow" + enable_cls_delivery = true +} +` + +const testAccCynosdbClsDeliveryUpdate = ` +resource "tencentcloud_cynosdb_cls_delivery" "example" { + instance_id = "cynosdbmysql-ins-anknkhvi" + cls_info_list { + topic_operation = "reuse" + group_operation = "reuse" + region = "ap-guangzhou" + topic_id = "8e38f7c1-17ec-4acb-a4cb-7dc14baaef47" + group_id = "7e3bb8b7-81d5-4e6b-b150-f139b90c146e" + } + log_type = "slow" + enable_cls_delivery = false +} +` diff --git a/tencentcloud/services/cynosdb/service_tencentcloud_cynosdb.go b/tencentcloud/services/cynosdb/service_tencentcloud_cynosdb.go index a06a5c0151..bd4ce9d15d 100644 --- a/tencentcloud/services/cynosdb/service_tencentcloud_cynosdb.go +++ b/tencentcloud/services/cynosdb/service_tencentcloud_cynosdb.go @@ -3009,3 +3009,49 @@ func (me *CynosdbService) taskStateRefreshFunc(taskId string, failStates []strin return object, *object.Response.TaskList[0].Status, nil } } + +func (me *CynosdbService) DescribeCynosdbClsDeliveryById(ctx context.Context, instanceId, groupId, topicId string) (ret *cynosdb.InstanceCLSDeliveryInfo, errRet error) { + logId := tccommon.GetLogId(ctx) + + request := cynosdb.NewDescribeInstanceCLSLogDeliveryRequest() + response := cynosdb.NewDescribeInstanceCLSLogDeliveryResponse() + request.InstanceId = &instanceId + + defer func() { + if errRet != nil { + log.Printf("[CRITAL]%s api[%s] fail, request body [%s], reason[%s]\n", logId, request.GetAction(), request.ToJsonString(), errRet.Error()) + } + }() + + errRet = resource.Retry(tccommon.ReadRetryTimeout, func() *resource.RetryError { + ratelimit.Check(request.GetAction()) + result, e := me.client.UseCynosdbClient().DescribeInstanceCLSLogDelivery(request) + if e != nil { + return tccommon.RetryError(e) + } else { + log.Printf("[DEBUG]%s api[%s] success, request body [%s], response body [%s]\n", logId, request.GetAction(), request.ToJsonString(), result.ToJsonString()) + } + + if result == nil || result.Response == nil || result.Response.InstanceCLSDeliveryInfos == nil { + return tccommon.RetryError(fmt.Errorf("Describe cynosdb cls delivery failed, Response is nil.")) + } + + response = result + return nil + }) + + if errRet != nil { + return + } + + for _, item := range response.Response.InstanceCLSDeliveryInfos { + if item.GroupId != nil && item.TopicId != nil { + if groupId == *item.GroupId && topicId == *item.TopicId { + ret = item + break + } + } + } + + return +} diff --git a/website/docs/r/cynosdb_cls_delivery.html.markdown b/website/docs/r/cynosdb_cls_delivery.html.markdown new file mode 100644 index 0000000000..7f712fb6c1 --- /dev/null +++ b/website/docs/r/cynosdb_cls_delivery.html.markdown @@ -0,0 +1,86 @@ +--- +subcategory: "TDSQL-C MySQL(CynosDB)" +layout: "tencentcloud" +page_title: "TencentCloud: tencentcloud_cynosdb_cls_delivery" +sidebar_current: "docs-tencentcloud-resource-cynosdb_cls_delivery" +description: |- + Provides a resource to create a Cynosdb cls delivery +--- + +# tencentcloud_cynosdb_cls_delivery + +Provides a resource to create a Cynosdb cls delivery + +~> **NOTE:** Destroying this resource will not cause the CLS log set and log topic to be destroyed synchronously. If you need to delete it, you need to access the console page to delete it. + +## Example Usage + +### If topic_operation/group_operation is create + +```hcl +resource "tencentcloud_cynosdb_cls_delivery" "example" { + instance_id = "cynosdbmysql-ins-anknkhvi" + cls_info_list { + topic_operation = "create" + group_operation = "create" + region = "ap-guangzhou" + topic_name = "tf-example-topic" + group_name = "tf-example-group" + } + log_type = "slow" + enable_cls_delivery = true +} +``` + +### If topic_operation/group_operation is reuse + +```hcl +resource "tencentcloud_cynosdb_cls_delivery" "example" { + instance_id = "cynosdbmysql-ins-anknkhvi" + cls_info_list { + topic_operation = "reuse" + group_operation = "reuse" + region = "ap-guangzhou" + topic_id = "8e38f7c1-17ec-4acb-a4cb-7dc14baaef47" + group_id = "7e3bb8b7-81d5-4e6b-b150-f139b90c146e" + } + log_type = "slow" + enable_cls_delivery = false +} +``` + +## Argument Reference + +The following arguments are supported: + +* `cls_info_list` - (Required, List, ForceNew) Log delivery configuration. +* `instance_id` - (Required, String, ForceNew) Instance ID. +* `enable_cls_delivery` - (Optional, Bool) Whether to enable CLS delivery. Default value: true (enabled). +* `log_type` - (Optional, String, ForceNew) Log type. + +The `cls_info_list` object supports the following: + +* `group_operation` - (Required, String) Log set operations: Optional: create or reuse. create: Creates a new log set, using the GroupName. reuse: Reuses an existing log set, using the GroupId. The combination of reusing an existing log topic and creating a new log set is not allowed. +* `region` - (Required, String) Log delivery region. +* `topic_operation` - (Required, String) Log topic operations: Optional: create or reuse. create: Creates a new log topic using TopicName. reuse: Reuses an existing log topic using TopicId. Reusing an existing log topic and creating a new log set is not allowed. +* `group_id` - (Optional, String) Log set ID. +* `group_name` - (Optional, String) Log set name. +* `topic_id` - (Optional, String) Log topic ID. +* `topic_name` - (Optional, String) Log topic name. + +## Attributes Reference + +In addition to all arguments above, the following attributes are exported: + +* `id` - ID of the resource. +* `status` - Delivery status. running, offlined. + + +## Import + +Cynosdb cls delivery can be imported using the ${instanceId}#${groupId}#${topicId}, e.g. + +``` +terraform import tencentcloud_cynosdb_cls_delivery.example cynosdbmysql-ins-anknkhvi#7e3bb8b7-81d5-4e6b-b150-f139b90c146e#8e38f7c1-17ec-4acb-a4cb-7dc14baaef47 +``` + diff --git a/website/tencentcloud.erb b/website/tencentcloud.erb index 244e028921..8975360ff2 100644 --- a/website/tencentcloud.erb +++ b/website/tencentcloud.erb @@ -4489,6 +4489,9 @@
  • tencentcloud_cynosdb_binlog_save_days
    • +
  • + tencentcloud_cynosdb_cls_delivery +
  • tencentcloud_cynosdb_cluster