feat(wedata): [127481633]add datasource

.changelog/3552.txt

@@ -0,0 +1,39 @@
+```release-note:new-data-source
+tencentcloud_wedata_resource_files
+```
+
+```release-note:new-data-source
+tencentcloud_wedata_workflow_folders
+```
+
+```release-note:new-data-source
+tencentcloud_wedata_workflows
+```
+
+```release-note:new-data-source
+tencentcloud_wedata_tasks
+```
+
+```release-note:new-data-source
+tencentcloud_wedata_task_versions
+```
+
+```release-note:new-data-source
+tencentcloud_wedata_upstream_tasks
+```
+
+```release-note:new-data-source
+tencentcloud_wedata_downstream_tasks
+```
+
+```release-note:new-data-source
+tencentcloud_wedata_task_code
+```
+
+```release-note:new-data-source
+tencentcloud_wedata_task_version
+```
+
+```release-note:new-resource
+tencentcloud_wedata_submit_task_operation
+```

tencentcloud/provider.go

@@ -1158,6 +1158,15 @@ func Provider() *schema.Provider {
 			"tencentcloud_eb_platform_event_patterns":                            eb.DataSourceTencentCloudEbPlatformEventPatterns(),
 			"tencentcloud_eb_platform_products":                                  eb.DataSourceTencentCloudEbPlatformProducts(),
 			"tencentcloud_eb_plateform_event_template":                           eb.DataSourceTencentCloudEbPlateformEventTemplate(),
+			"tencentcloud_wedata_resource_files":                                 wedata.DataSourceTencentCloudWedataResourceFiles(),
+			"tencentcloud_wedata_workflow_folders":                               wedata.DataSourceTencentCloudWedataWorkflowFolders(),
+			"tencentcloud_wedata_workflows":                                      wedata.DataSourceTencentCloudWedataWorkflows(),
+			"tencentcloud_wedata_tasks":                                          wedata.DataSourceTencentCloudWedataTasks(),
+			"tencentcloud_wedata_task_versions":                                  wedata.DataSourceTencentCloudWedataTaskVersions(),
+			"tencentcloud_wedata_upstream_tasks":                                 wedata.DataSourceTencentCloudWedataUpstreamTasks(),
+			"tencentcloud_wedata_downstream_tasks":                               wedata.DataSourceTencentCloudWedataDownstreamTasks(),
+			"tencentcloud_wedata_task_code":                                      wedata.DataSourceTencentCloudWedataTaskCode(),
+			"tencentcloud_wedata_task_version":                                   wedata.DataSourceTencentCloudWedataTaskVersion(),
 			"tencentcloud_wedata_rule_templates":                                 wedata.DataSourceTencentCloudWedataRuleTemplates(),
 			"tencentcloud_wedata_ops_workflows":                                  wedata.DataSourceTencentCloudWedataOpsWorkflows(),
 			"tencentcloud_wedata_ops_workflow":                                   wedata.DataSourceTencentCloudWedataOpsWorkflow(),
@@ -2285,6 +2294,7 @@ func Provider() *schema.Provider {
 			"tencentcloud_waf_bot_status_config":                                                    waf.ResourceTencentCloudWafBotStatusConfig(),
 			"tencentcloud_waf_bot_scene_ucb_rule":                                                   waf.ResourceTencentCloudWafBotSceneUCBRule(),
 			"tencentcloud_waf_attack_white_rule":                                                    waf.ResourceTencentCloudWafAttackWhiteRule(),
+			"tencentcloud_wedata_submit_task_operation":                                             wedata.ResourceTencentCloudWedataSubmitTaskOperation(),
 			"tencentcloud_wedata_rule_template":                                                     wedata.ResourceTencentCloudWedataRuleTemplate(),
 			"tencentcloud_wedata_datasource":                                                        wedata.ResourceTencentCloudWedataDatasource(),
 			"tencentcloud_wedata_function":                                                          wedata.ResourceTencentCloudWedataFunction(),

tencentcloud/provider.md

@@ -2220,6 +2220,15 @@ tencentcloud_waf_attack_white_rule
 
 Wedata
 Data Source
+tencentcloud_wedata_resource_files
+tencentcloud_wedata_workflow_folders
+tencentcloud_wedata_workflows
+tencentcloud_wedata_tasks
+tencentcloud_wedata_task_versions
+tencentcloud_wedata_upstream_tasks
+tencentcloud_wedata_downstream_tasks
+tencentcloud_wedata_task_code
+tencentcloud_wedata_task_version
 tencentcloud_wedata_rule_templates
 tencentcloud_wedata_ops_workflows
 tencentcloud_wedata_ops_workflow
@@ -2233,6 +2242,7 @@ tencentcloud_wedata_task_instance_executions
 tencentcloud_wedata_data_source_list
 
 Resource
+tencentcloud_wedata_submit_task_operation
 tencentcloud_wedata_datasource
 tencentcloud_wedata_function
 tencentcloud_wedata_script

tencentcloud/services/cls/resource_tc_cls_cloud_product_log_task_extension.go

@@ -29,15 +29,15 @@ func resourceTencentCloudClsCloudProductLogTaskReadPreRequest0(ctx context.Conte
 	logType := idSplit[2]
 
 	req.Filters = []*clsv20201016.Filter{
-		&clsv20201016.Filter{
+		{
 			Key:    common.StringPtr("instanceId"),
 			Values: common.StringPtrs([]string{instanceId}),
 		},
-		&clsv20201016.Filter{
+		{
 			Key:    common.StringPtr("assumerName"),
 			Values: common.StringPtrs([]string{assumerName}),
 		},
-		&clsv20201016.Filter{
+		{
 			Key:    common.StringPtr("logType"),
 			Values: common.StringPtrs([]string{logType}),
 		},
@@ -87,7 +87,7 @@ func resourceTencentCloudClsCloudProductLogTaskReadPreHandleResponse0(ctx contex
 	logsetRequest := clsv20201016.NewDescribeLogsetsRequest()
 	logsetResponse := clsv20201016.NewDescribeLogsetsResponse()
 	logsetRequest.Filters = []*clsv20201016.Filter{
-		&clsv20201016.Filter{
+		{
 			Key:    common.StringPtr("logsetId"),
 			Values: common.StringPtrs([]string{logsetId}),
 		},
@@ -128,7 +128,7 @@ func resourceTencentCloudClsCloudProductLogTaskReadPreHandleResponse0(ctx contex
 	topicRequest := clsv20201016.NewDescribeTopicsRequest()
 	topicResponse := clsv20201016.NewDescribeTopicsResponse()
 	topicRequest.Filters = []*clsv20201016.Filter{
-		&clsv20201016.Filter{
+		{
 			Key:    common.StringPtr("topicId"),
 			Values: common.StringPtrs([]string{topicId}),
 		},

tencentcloud/services/wedata/data_source_tc_wedata_downstream_tasks.go

@@ -0,0 +1,255 @@
+package wedata
+
+import (
+	"context"
+
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/resource"
+	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
+	wedatav20250806 "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/wedata/v20250806"
+
+	tccommon "github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/common"
+	"github.com/tencentcloudstack/terraform-provider-tencentcloud/tencentcloud/internal/helper"
+)
+
+func DataSourceTencentCloudWedataDownstreamTasks() *schema.Resource {
+	return &schema.Resource{
+		Read: dataSourceTencentCloudWedataDownstreamTasksRead,
+		Schema: map[string]*schema.Schema{
+			"project_id": {
+				Type:        schema.TypeString,
+				Required:    true,
+				Description: "Project ID.",
+			},
+
+			"task_id": {
+				Type:        schema.TypeString,
+				Required:    true,
+				Description: "Task ID.",
+			},
+
+			"data": {
+				Type:        schema.TypeList,
+				Computed:    true,
+				Description: "Describes the downstream dependency details.",
+				Elem: &schema.Resource{
+					Schema: map[string]*schema.Schema{
+						"task_id": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Task ID.",
+						},
+						"task_name": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Task name.",
+						},
+						"workflow_id": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Workflow id.",
+						},
+						"workflow_name": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Workflow name.",
+						},
+						"project_id": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Project ID.",
+						},
+						"status": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Task Status:\n\n* N: New\n\n* Y: Scheduling\n\n* F: Offline\n\n* O: Paused\n\n* T: Offlining (in the process of being taken offline)\n\nI* NVALID: Invalid.",
+						},
+						"task_type_id": {
+							Type:        schema.TypeInt,
+							Required:    true,
+							Description: "Task type id.",
+						},
+						"task_type_desc": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Task type description.\n-20: universal data synchronization.\n - 25:  ETLTaskType\n - 26:  ETLTaskType\n - 30:  python\n - 31:  pyspark\n - 34:  hivesql\n - 35:  shell\n - 36:  sparksql\n - 21:  jdbcsql\n - 32:  dlc\n - 33:  ImpalaTaskType\n - 40:  CDWTaskType\n - 41:  kettle\n - 42:  TCHouse-X\n - 43:  TCHouse-X SQL\n - 46:  dlcsparkTaskType\n - 47:  TiOneMachineLearningTaskType\n - 48:  Trino\n - 50:  DLCPyspark\n - 23:  TencentDistributedSQL\n - 39:  spark\n - 92:  MRTaskType\n - 38:  ShellScript\n - 70:  HiveSQLScrip\n-130: branch.\n-131: merge.\n-132: Notebook \n-133: SSH node.\n - 134:  StarRocks\n - 137:  For-each\n-10000: custom business common.",
+						},
+						"schedule_desc": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Specifies scheduling plan display description information.",
+						},
+						"start_time": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Task start time.",
+						},
+						"end_time": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Task end time.",
+						},
+						"delay_time": {
+							Type:        schema.TypeInt,
+							Required:    true,
+							Description: "Delay time.",
+						},
+						"cycle_type": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Cycle Type, Default: D\nSupported types:\n* O: One-time\n\n* Y: Yearly\n\n* M: Monthly\n\n* W: Weekly\n\n* D: Daily\n\n* H: Hourly\n\n* I: Minute\n\n* C: Crontab expression type.",
+						},
+						"owner_uin": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Owner ID.",
+						},
+						"task_action": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Elastic cycle configuration.",
+						},
+						"init_strategy": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "Initialization strategy for scheduling.",
+						},
+						"crontab_expression": {
+							Type:        schema.TypeString,
+							Required:    true,
+							Description: "crontab expression.",
+						},
+					},
+				},
+			},
+
+			"result_output_file": {
+				Type:        schema.TypeString,
+				Optional:    true,
+				Description: "Used to save results.",
+			},
+		},
+	}
+}
+
+func dataSourceTencentCloudWedataDownstreamTasksRead(d *schema.ResourceData, meta interface{}) error {
+	defer tccommon.LogElapsed("data_source.tencentcloud_wedata_downstream_tasks.read")()
+	defer tccommon.InconsistentCheck(d, meta)()
+
+	logId := tccommon.GetLogId(nil)
+	ctx := tccommon.NewResourceLifeCycleHandleFuncContext(context.Background(), logId, d, meta)
+
+	service := WedataService{client: meta.(tccommon.ProviderMeta).GetAPIV3Conn()}
+
+	paramMap := make(map[string]interface{})
+	if v, ok := d.GetOk("project_id"); ok {
+		paramMap["ProjectId"] = helper.String(v.(string))
+	}
+
+	if v, ok := d.GetOk("task_id"); ok {
+		paramMap["TaskId"] = helper.String(v.(string))
+	}
+
+	var respData []*wedatav20250806.TaskDependDto
+	err := resource.Retry(tccommon.ReadRetryTimeout, func() *resource.RetryError {
+		result, e := service.DescribeWedataDownstreamTasksByFilter(ctx, paramMap)
+		if e != nil {
+			return tccommon.RetryError(e)
+		}
+		respData = result
+		return nil
+	})
+	if err != nil {
+		return err
+	}
+
+	ids := make([]string, 0, len(respData))
+	itemsList := make([]map[string]interface{}, 0, len(respData))
+
+	for _, items := range respData {
+		itemsMap := map[string]interface{}{}
+
+		if items.TaskId != nil {
+			itemsMap["task_id"] = items.TaskId
+			ids = append(ids, *items.TaskId)
+		}
+
+		if items.TaskName != nil {
+			itemsMap["task_name"] = items.TaskName
+		}
+
+		if items.WorkflowId != nil {
+			itemsMap["workflow_id"] = items.WorkflowId
+		}
+
+		if items.WorkflowName != nil {
+			itemsMap["workflow_name"] = items.WorkflowName
+		}
+
+		if items.ProjectId != nil {
+			itemsMap["project_id"] = items.ProjectId
+		}
+
+		if items.Status != nil {
+			itemsMap["status"] = items.Status
+		}
+
+		if items.TaskTypeId != nil {
+			itemsMap["task_type_id"] = items.TaskTypeId
+		}
+
+		if items.TaskTypeDesc != nil {
+			itemsMap["task_type_desc"] = items.TaskTypeDesc
+		}
+
+		if items.ScheduleDesc != nil {
+			itemsMap["schedule_desc"] = items.ScheduleDesc
+		}
+
+		if items.StartTime != nil {
+			itemsMap["start_time"] = items.StartTime
+		}
+
+		if items.EndTime != nil {
+			itemsMap["end_time"] = items.EndTime
+		}
+
+		if items.DelayTime != nil {
+			itemsMap["delay_time"] = items.DelayTime
+		}
+
+		if items.CycleType != nil {
+			itemsMap["cycle_type"] = items.CycleType
+		}
+
+		if items.OwnerUin != nil {
+			itemsMap["owner_uin"] = items.OwnerUin
+		}
+
+		if items.TaskAction != nil {
+			itemsMap["task_action"] = items.TaskAction
+		}
+
+		if items.InitStrategy != nil {
+			itemsMap["init_strategy"] = items.InitStrategy
+		}
+
+		if items.CrontabExpression != nil {
+			itemsMap["crontab_expression"] = items.CrontabExpression
+		}
+
+		itemsList = append(itemsList, itemsMap)
+	}
+
+	_ = d.Set("data", itemsList)
+
+	d.SetId(helper.DataResourceIdsHash(ids))
+
+	output, ok := d.GetOk("result_output_file")
+	if ok && output.(string) != "" {
+		if e := tccommon.WriteToFile(output.(string), itemsList); e != nil {
+			return e
+		}
+	}
+
+	return nil
+}

tencentcloud/services/wedata/data_source_tc_wedata_downstream_tasks.md

@@ -0,0 +1,10 @@
+Use this data source to query detailed information of wedata wedata_downstream_tasks
+
+Example Usage
+
+```hcl
+data "tencentcloud_wedata_downstream_tasks" "wedata_downstream_tasks" {
+	project_id = "2905622749543821312"
+	task_id = "20251015164958429"
+}
+```