Docs Home Pulumi IaC Pulumi ESC Pulumi Insights Pulumi Cloud Packages Tutorials
  1. Packages
  2. Tencentcloud Provider
  3. API Docs
  4. WedataIntegrationRealtimeTask
tencentcloud 1.81.183 published on Wednesday, Apr 16, 2025 by tencentcloudstack
tencentcloudstack/terraform-provider-tencentcloud

tencentcloud.WedataIntegrationRealtimeTask

Explore with Pulumi AI

tencentcloud 1.81.183 published on Wednesday, Apr 16, 2025 by tencentcloudstack
tencentcloudstack/terraform-provider-tencentcloud

Provides a resource to create a wedata integration_realtime_task

Example Usage

import * as pulumi from "@pulumi/pulumi";
import * as tencentcloud from "@pulumi/tencentcloud";

const example = new tencentcloud.WedataIntegrationRealtimeTask("example", {
    description: "description.",
    projectId: "1612982498218618880",
    syncType: 1,
    taskInfo: {
        configs: [
            {
                name: "concurrency",
                value: "1",
            },
            {
                name: "TaskManager",
                value: "1",
            },
            {
                name: "JobManager",
                value: "1",
            },
            {
                name: "TolerateDirtyData",
                value: "0",
            },
            {
                name: "CheckpointingInterval",
                value: "1",
            },
            {
                name: "CheckpointingIntervalUnit",
                value: "min",
            },
            {
                name: "RestartStrategyFixedDelayAttempts",
                value: "-1",
            },
            {
                name: "ResourceAllocationType",
                value: "0",
            },
            {
                name: "TaskAlarmRegularList",
                value: "35",
            },
        ],
        executorId: "20230313175748567418",
        incharge: "100028439226",
    },
    taskMode: "1",
    taskName: "tf_example",
});
Copy
import pulumi
import pulumi_tencentcloud as tencentcloud

example = tencentcloud.WedataIntegrationRealtimeTask("example",
    description="description.",
    project_id="1612982498218618880",
    sync_type=1,
    task_info={
        "configs": [
            {
                "name": "concurrency",
                "value": "1",
            },
            {
                "name": "TaskManager",
                "value": "1",
            },
            {
                "name": "JobManager",
                "value": "1",
            },
            {
                "name": "TolerateDirtyData",
                "value": "0",
            },
            {
                "name": "CheckpointingInterval",
                "value": "1",
            },
            {
                "name": "CheckpointingIntervalUnit",
                "value": "min",
            },
            {
                "name": "RestartStrategyFixedDelayAttempts",
                "value": "-1",
            },
            {
                "name": "ResourceAllocationType",
                "value": "0",
            },
            {
                "name": "TaskAlarmRegularList",
                "value": "35",
            },
        ],
        "executor_id": "20230313175748567418",
        "incharge": "100028439226",
    },
    task_mode="1",
    task_name="tf_example")
Copy
package main

import (
	"github.com/pulumi/pulumi-terraform-provider/sdks/go/tencentcloud/tencentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := tencentcloud.NewWedataIntegrationRealtimeTask(ctx, "example", &tencentcloud.WedataIntegrationRealtimeTaskArgs{
			Description: pulumi.String("description."),
			ProjectId:   pulumi.String("1612982498218618880"),
			SyncType:    pulumi.Float64(1),
			TaskInfo: &tencentcloud.WedataIntegrationRealtimeTaskTaskInfoArgs{
				Configs: tencentcloud.WedataIntegrationRealtimeTaskTaskInfoConfigArray{
					&tencentcloud.WedataIntegrationRealtimeTaskTaskInfoConfigArgs{
						Name:  pulumi.String("concurrency"),
						Value: pulumi.String("1"),
					},
					&tencentcloud.WedataIntegrationRealtimeTaskTaskInfoConfigArgs{
						Name:  pulumi.String("TaskManager"),
						Value: pulumi.String("1"),
					},
					&tencentcloud.WedataIntegrationRealtimeTaskTaskInfoConfigArgs{
						Name:  pulumi.String("JobManager"),
						Value: pulumi.String("1"),
					},
					&tencentcloud.WedataIntegrationRealtimeTaskTaskInfoConfigArgs{
						Name:  pulumi.String("TolerateDirtyData"),
						Value: pulumi.String("0"),
					},
					&tencentcloud.WedataIntegrationRealtimeTaskTaskInfoConfigArgs{
						Name:  pulumi.String("CheckpointingInterval"),
						Value: pulumi.String("1"),
					},
					&tencentcloud.WedataIntegrationRealtimeTaskTaskInfoConfigArgs{
						Name:  pulumi.String("CheckpointingIntervalUnit"),
						Value: pulumi.String("min"),
					},
					&tencentcloud.WedataIntegrationRealtimeTaskTaskInfoConfigArgs{
						Name:  pulumi.String("RestartStrategyFixedDelayAttempts"),
						Value: pulumi.String("-1"),
					},
					&tencentcloud.WedataIntegrationRealtimeTaskTaskInfoConfigArgs{
						Name:  pulumi.String("ResourceAllocationType"),
						Value: pulumi.String("0"),
					},
					&tencentcloud.WedataIntegrationRealtimeTaskTaskInfoConfigArgs{
						Name:  pulumi.String("TaskAlarmRegularList"),
						Value: pulumi.String("35"),
					},
				},
				ExecutorId: pulumi.String("20230313175748567418"),
				Incharge:   pulumi.String("100028439226"),
			},
			TaskMode: pulumi.String("1"),
			TaskName: pulumi.String("tf_example"),
		})
		if err != nil {
			return err
		}
		return nil
	})
}
Copy
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Tencentcloud = Pulumi.Tencentcloud;

return await Deployment.RunAsync(() => 
{
    var example = new Tencentcloud.WedataIntegrationRealtimeTask("example", new()
    {
        Description = "description.",
        ProjectId = "1612982498218618880",
        SyncType = 1,
        TaskInfo = new Tencentcloud.Inputs.WedataIntegrationRealtimeTaskTaskInfoArgs
        {
            Configs = new[]
            {
                new Tencentcloud.Inputs.WedataIntegrationRealtimeTaskTaskInfoConfigArgs
                {
                    Name = "concurrency",
                    Value = "1",
                },
                new Tencentcloud.Inputs.WedataIntegrationRealtimeTaskTaskInfoConfigArgs
                {
                    Name = "TaskManager",
                    Value = "1",
                },
                new Tencentcloud.Inputs.WedataIntegrationRealtimeTaskTaskInfoConfigArgs
                {
                    Name = "JobManager",
                    Value = "1",
                },
                new Tencentcloud.Inputs.WedataIntegrationRealtimeTaskTaskInfoConfigArgs
                {
                    Name = "TolerateDirtyData",
                    Value = "0",
                },
                new Tencentcloud.Inputs.WedataIntegrationRealtimeTaskTaskInfoConfigArgs
                {
                    Name = "CheckpointingInterval",
                    Value = "1",
                },
                new Tencentcloud.Inputs.WedataIntegrationRealtimeTaskTaskInfoConfigArgs
                {
                    Name = "CheckpointingIntervalUnit",
                    Value = "min",
                },
                new Tencentcloud.Inputs.WedataIntegrationRealtimeTaskTaskInfoConfigArgs
                {
                    Name = "RestartStrategyFixedDelayAttempts",
                    Value = "-1",
                },
                new Tencentcloud.Inputs.WedataIntegrationRealtimeTaskTaskInfoConfigArgs
                {
                    Name = "ResourceAllocationType",
                    Value = "0",
                },
                new Tencentcloud.Inputs.WedataIntegrationRealtimeTaskTaskInfoConfigArgs
                {
                    Name = "TaskAlarmRegularList",
                    Value = "35",
                },
            },
            ExecutorId = "20230313175748567418",
            Incharge = "100028439226",
        },
        TaskMode = "1",
        TaskName = "tf_example",
    });

});
Copy
package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.tencentcloud.WedataIntegrationRealtimeTask;
import com.pulumi.tencentcloud.WedataIntegrationRealtimeTaskArgs;
import com.pulumi.tencentcloud.inputs.WedataIntegrationRealtimeTaskTaskInfoArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        var example = new WedataIntegrationRealtimeTask("example", WedataIntegrationRealtimeTaskArgs.builder()
            .description("description.")
            .projectId("1612982498218618880")
            .syncType(1)
            .taskInfo(WedataIntegrationRealtimeTaskTaskInfoArgs.builder()
                .configs(                
                    WedataIntegrationRealtimeTaskTaskInfoConfigArgs.builder()
                        .name("concurrency")
                        .value("1")
                        .build(),
                    WedataIntegrationRealtimeTaskTaskInfoConfigArgs.builder()
                        .name("TaskManager")
                        .value("1")
                        .build(),
                    WedataIntegrationRealtimeTaskTaskInfoConfigArgs.builder()
                        .name("JobManager")
                        .value("1")
                        .build(),
                    WedataIntegrationRealtimeTaskTaskInfoConfigArgs.builder()
                        .name("TolerateDirtyData")
                        .value("0")
                        .build(),
                    WedataIntegrationRealtimeTaskTaskInfoConfigArgs.builder()
                        .name("CheckpointingInterval")
                        .value("1")
                        .build(),
                    WedataIntegrationRealtimeTaskTaskInfoConfigArgs.builder()
                        .name("CheckpointingIntervalUnit")
                        .value("min")
                        .build(),
                    WedataIntegrationRealtimeTaskTaskInfoConfigArgs.builder()
                        .name("RestartStrategyFixedDelayAttempts")
                        .value("-1")
                        .build(),
                    WedataIntegrationRealtimeTaskTaskInfoConfigArgs.builder()
                        .name("ResourceAllocationType")
                        .value("0")
                        .build(),
                    WedataIntegrationRealtimeTaskTaskInfoConfigArgs.builder()
                        .name("TaskAlarmRegularList")
                        .value("35")
                        .build())
                .executorId("20230313175748567418")
                .incharge("100028439226")
                .build())
            .taskMode("1")
            .taskName("tf_example")
            .build());

    }
}
Copy
resources:
  example:
    type: tencentcloud:WedataIntegrationRealtimeTask
    properties:
      description: description.
      projectId: '1612982498218618880'
      syncType: 1
      taskInfo:
        configs:
          - name: concurrency
            value: '1'
          - name: TaskManager
            value: '1'
          - name: JobManager
            value: '1'
          - name: TolerateDirtyData
            value: '0'
          - name: CheckpointingInterval
            value: '1'
          - name: CheckpointingIntervalUnit
            value: min
          - name: RestartStrategyFixedDelayAttempts
            value: '-1'
          - name: ResourceAllocationType
            value: '0'
          - name: TaskAlarmRegularList
            value: '35'
        executorId: '20230313175748567418'
        incharge: '100028439226'
      taskMode: '1'
      taskName: tf_example
Copy

Create WedataIntegrationRealtimeTask Resource

Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

Constructor syntax

new WedataIntegrationRealtimeTask(name: string, args: WedataIntegrationRealtimeTaskArgs, opts?: CustomResourceOptions);
@overload
def WedataIntegrationRealtimeTask(resource_name: str,
                                  args: WedataIntegrationRealtimeTaskArgs,
                                  opts: Optional[ResourceOptions] = None)

@overload
def WedataIntegrationRealtimeTask(resource_name: str,
                                  opts: Optional[ResourceOptions] = None,
                                  project_id: Optional[str] = None,
                                  sync_type: Optional[float] = None,
                                  task_info: Optional[WedataIntegrationRealtimeTaskTaskInfoArgs] = None,
                                  task_mode: Optional[str] = None,
                                  task_name: Optional[str] = None,
                                  description: Optional[str] = None,
                                  wedata_integration_realtime_task_id: Optional[str] = None)
func NewWedataIntegrationRealtimeTask(ctx *Context, name string, args WedataIntegrationRealtimeTaskArgs, opts ...ResourceOption) (*WedataIntegrationRealtimeTask, error)
public WedataIntegrationRealtimeTask(string name, WedataIntegrationRealtimeTaskArgs args, CustomResourceOptions? opts = null)
public WedataIntegrationRealtimeTask(String name, WedataIntegrationRealtimeTaskArgs args)
public WedataIntegrationRealtimeTask(String name, WedataIntegrationRealtimeTaskArgs args, CustomResourceOptions options)

type: tencentcloud:WedataIntegrationRealtimeTask
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.

Parameters

name This property is required. string
The unique name of the resource.
args This property is required. WedataIntegrationRealtimeTaskArgs
The arguments to resource properties.
opts CustomResourceOptions
Bag of options to control resource's behavior.
resource_name This property is required. str
The unique name of the resource.
args This property is required. WedataIntegrationRealtimeTaskArgs
The arguments to resource properties.
opts ResourceOptions
Bag of options to control resource's behavior.
ctx Context
Context object for the current deployment.
name This property is required. string
The unique name of the resource.
args This property is required. WedataIntegrationRealtimeTaskArgs
The arguments to resource properties.
opts ResourceOption
Bag of options to control resource's behavior.
name This property is required. string
The unique name of the resource.
args This property is required. WedataIntegrationRealtimeTaskArgs
The arguments to resource properties.
opts CustomResourceOptions
Bag of options to control resource's behavior.
name This property is required. String
The unique name of the resource.
args This property is required. WedataIntegrationRealtimeTaskArgs
The arguments to resource properties.
options CustomResourceOptions
Bag of options to control resource's behavior.

WedataIntegrationRealtimeTask Resource Properties

To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

Inputs

In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.

The WedataIntegrationRealtimeTask resource accepts the following input properties:

ProjectId This property is required. string
Project ID.
SyncType This property is required. double
Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
TaskInfo This property is required. WedataIntegrationRealtimeTaskTaskInfo
Task Information.
TaskMode This property is required. string
Task display mode, 0: canvas mode, 1: form mode.
TaskName This property is required. string
Task name.
Description string
Description information.
WedataIntegrationRealtimeTaskId string
ID of the resource.
ProjectId This property is required. string
Project ID.
SyncType This property is required. float64
Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
TaskInfo This property is required. WedataIntegrationRealtimeTaskTaskInfoArgs
Task Information.
TaskMode This property is required. string
Task display mode, 0: canvas mode, 1: form mode.
TaskName This property is required. string
Task name.
Description string
Description information.
WedataIntegrationRealtimeTaskId string
ID of the resource.
projectId This property is required. String
Project ID.
syncType This property is required. Double
Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
taskInfo This property is required. WedataIntegrationRealtimeTaskTaskInfo
Task Information.
taskMode This property is required. String
Task display mode, 0: canvas mode, 1: form mode.
taskName This property is required. String
Task name.
description String
Description information.
wedataIntegrationRealtimeTaskId String
ID of the resource.
projectId This property is required. string
Project ID.
syncType This property is required. number
Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
taskInfo This property is required. WedataIntegrationRealtimeTaskTaskInfo
Task Information.
taskMode This property is required. string
Task display mode, 0: canvas mode, 1: form mode.
taskName This property is required. string
Task name.
description string
Description information.
wedataIntegrationRealtimeTaskId string
ID of the resource.
project_id This property is required. str
Project ID.
sync_type This property is required. float
Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
task_info This property is required. WedataIntegrationRealtimeTaskTaskInfoArgs
Task Information.
task_mode This property is required. str
Task display mode, 0: canvas mode, 1: form mode.
task_name This property is required. str
Task name.
description str
Description information.
wedata_integration_realtime_task_id str
ID of the resource.
projectId This property is required. String
Project ID.
syncType This property is required. Number
Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
taskInfo This property is required. Property Map
Task Information.
taskMode This property is required. String
Task display mode, 0: canvas mode, 1: form mode.
taskName This property is required. String
Task name.
description String
Description information.
wedataIntegrationRealtimeTaskId String
ID of the resource.

Outputs

All input properties are implicitly available as output properties. Additionally, the WedataIntegrationRealtimeTask resource produces the following output properties:

Id string
The provider-assigned unique ID for this managed resource.
TaskId string
Task ID.
Id string
The provider-assigned unique ID for this managed resource.
TaskId string
Task ID.
id String
The provider-assigned unique ID for this managed resource.
taskId String
Task ID.
id string
The provider-assigned unique ID for this managed resource.
taskId string
Task ID.
id str
The provider-assigned unique ID for this managed resource.
task_id str
Task ID.
id String
The provider-assigned unique ID for this managed resource.
taskId String
Task ID.

Look up Existing WedataIntegrationRealtimeTask Resource

Get an existing WedataIntegrationRealtimeTask resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

public static get(name: string, id: Input<ID>, state?: WedataIntegrationRealtimeTaskState, opts?: CustomResourceOptions): WedataIntegrationRealtimeTask
@staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        description: Optional[str] = None,
        project_id: Optional[str] = None,
        sync_type: Optional[float] = None,
        task_id: Optional[str] = None,
        task_info: Optional[WedataIntegrationRealtimeTaskTaskInfoArgs] = None,
        task_mode: Optional[str] = None,
        task_name: Optional[str] = None,
        wedata_integration_realtime_task_id: Optional[str] = None) -> WedataIntegrationRealtimeTask
func GetWedataIntegrationRealtimeTask(ctx *Context, name string, id IDInput, state *WedataIntegrationRealtimeTaskState, opts ...ResourceOption) (*WedataIntegrationRealtimeTask, error)
public static WedataIntegrationRealtimeTask Get(string name, Input<string> id, WedataIntegrationRealtimeTaskState? state, CustomResourceOptions? opts = null)
public static WedataIntegrationRealtimeTask get(String name, Output<String> id, WedataIntegrationRealtimeTaskState state, CustomResourceOptions options)
resources:  _:    type: tencentcloud:WedataIntegrationRealtimeTask    get:      id: ${id}
name This property is required.
The unique name of the resulting resource.
id This property is required.
The unique provider ID of the resource to lookup.
state
Any extra arguments used during the lookup.
opts
A bag of options that control this resource's behavior.
resource_name This property is required.
The unique name of the resulting resource.
id This property is required.
The unique provider ID of the resource to lookup.
name This property is required.
The unique name of the resulting resource.
id This property is required.
The unique provider ID of the resource to lookup.
state
Any extra arguments used during the lookup.
opts
A bag of options that control this resource's behavior.
name This property is required.
The unique name of the resulting resource.
id This property is required.
The unique provider ID of the resource to lookup.
state
Any extra arguments used during the lookup.
opts
A bag of options that control this resource's behavior.
name This property is required.
The unique name of the resulting resource.
id This property is required.
The unique provider ID of the resource to lookup.
state
Any extra arguments used during the lookup.
opts
A bag of options that control this resource's behavior.
The following state arguments are supported:
Description string
Description information.
ProjectId string
Project ID.
SyncType double
Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
TaskId string
Task ID.
TaskInfo WedataIntegrationRealtimeTaskTaskInfo
Task Information.
TaskMode string
Task display mode, 0: canvas mode, 1: form mode.
TaskName string
Task name.
WedataIntegrationRealtimeTaskId string
ID of the resource.
Description string
Description information.
ProjectId string
Project ID.
SyncType float64
Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
TaskId string
Task ID.
TaskInfo WedataIntegrationRealtimeTaskTaskInfoArgs
Task Information.
TaskMode string
Task display mode, 0: canvas mode, 1: form mode.
TaskName string
Task name.
WedataIntegrationRealtimeTaskId string
ID of the resource.
description String
Description information.
projectId String
Project ID.
syncType Double
Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
taskId String
Task ID.
taskInfo WedataIntegrationRealtimeTaskTaskInfo
Task Information.
taskMode String
Task display mode, 0: canvas mode, 1: form mode.
taskName String
Task name.
wedataIntegrationRealtimeTaskId String
ID of the resource.
description string
Description information.
projectId string
Project ID.
syncType number
Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
taskId string
Task ID.
taskInfo WedataIntegrationRealtimeTaskTaskInfo
Task Information.
taskMode string
Task display mode, 0: canvas mode, 1: form mode.
taskName string
Task name.
wedataIntegrationRealtimeTaskId string
ID of the resource.
description str
Description information.
project_id str
Project ID.
sync_type float
Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
task_id str
Task ID.
task_info WedataIntegrationRealtimeTaskTaskInfoArgs
Task Information.
task_mode str
Task display mode, 0: canvas mode, 1: form mode.
task_name str
Task name.
wedata_integration_realtime_task_id str
ID of the resource.
description String
Description information.
projectId String
Project ID.
syncType Number
Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
taskId String
Task ID.
taskInfo Property Map
Task Information.
taskMode String
Task display mode, 0: canvas mode, 1: form mode.
taskName String
Task name.
wedataIntegrationRealtimeTaskId String
ID of the resource.

Supporting Types

WedataIntegrationRealtimeTaskTaskInfo
, WedataIntegrationRealtimeTaskTaskInfoArgs

AppId string
User App Id.
Configs List<WedataIntegrationRealtimeTaskTaskInfoConfig>
Task configuration.
CreateTime string
Create time.
CreatorUin string
Creator User ID.
DataProxyUrls List<string>
Data proxy url.
ExecuteContexts List<WedataIntegrationRealtimeTaskTaskInfoExecuteContext>
Execute context.
ExecutorGroupName string
Executor group name.
ExecutorId string
Executor resource ID.
ExtConfigs List<WedataIntegrationRealtimeTaskTaskInfoExtConfig>
Node extension configuration information.
HasVersion bool
Whether the task been submitted.
InLongManagerUrl string
InLong manager url.
InLongManagerVersion string
InLong manager version.
InLongStreamId string
InLong stream id.
Incharge string
Incharge user.
InputDatasourceType string
Input datasource type.
InstanceVersion double
Instance version.
LastRunTime string
The last time the task was run.
Locked bool
Whether the task been locked.
Locker string
User locked task.
Mappings List<WedataIntegrationRealtimeTaskTaskInfoMapping>
Node mapping.
Nodes List<WedataIntegrationRealtimeTaskTaskInfoNode>
Task Node Information.
NumRecordsIn double
Number of reads.
NumRecordsOut double
Number of writes.
NumRestarts double
Times of restarts.
OperatorUin string
Operator User ID.
OutputDatasourceType string
Output datasource type.
OwnerUin string
Owner User ID.
ReadPhase double
Reading stage, 0: full amount, 1: partial full amount, 2: all incremental.
ReaderDelay double
Read latency.
RunningCu double
The amount of resources consumed by real-time task.
ScheduleTaskId string
Task scheduling id (job id such as oceanus or us).
Status double
Task status 1. Not started | Task initialization, 2. Task starting, 3. Running, 4. Paused, 5. Task stopping, 6. Stopped, 7. Execution failed, 8. deleted, 9. Locked, 404. unknown status.
StopTime string
The time the task was stopped.
Submit bool
Whether the task version has been submitted for operation and maintenance.
SwitchResource double
Resource tiering status, 0: in progress, 1: successful, 2: failed.
TaskAlarmRegularLists List<string>
Task alarm regular.
TaskGroupId string
Inlong Task Group ID.
UpdateTime string
Update time.
WorkflowId string
The workflow id to which the task belongs.
AppId string
User App Id.
Configs []WedataIntegrationRealtimeTaskTaskInfoConfig
Task configuration.
CreateTime string
Create time.
CreatorUin string
Creator User ID.
DataProxyUrls []string
Data proxy url.
ExecuteContexts []WedataIntegrationRealtimeTaskTaskInfoExecuteContext
Execute context.
ExecutorGroupName string
Executor group name.
ExecutorId string
Executor resource ID.
ExtConfigs []WedataIntegrationRealtimeTaskTaskInfoExtConfig
Node extension configuration information.
HasVersion bool
Whether the task been submitted.
InLongManagerUrl string
InLong manager url.
InLongManagerVersion string
InLong manager version.
InLongStreamId string
InLong stream id.
Incharge string
Incharge user.
InputDatasourceType string
Input datasource type.
InstanceVersion float64
Instance version.
LastRunTime string
The last time the task was run.
Locked bool
Whether the task been locked.
Locker string
User locked task.
Mappings []WedataIntegrationRealtimeTaskTaskInfoMapping
Node mapping.
Nodes []WedataIntegrationRealtimeTaskTaskInfoNode
Task Node Information.
NumRecordsIn float64
Number of reads.
NumRecordsOut float64
Number of writes.
NumRestarts float64
Times of restarts.
OperatorUin string
Operator User ID.
OutputDatasourceType string
Output datasource type.
OwnerUin string
Owner User ID.
ReadPhase float64
Reading stage, 0: full amount, 1: partial full amount, 2: all incremental.
ReaderDelay float64
Read latency.
RunningCu float64
The amount of resources consumed by real-time task.
ScheduleTaskId string
Task scheduling id (job id such as oceanus or us).
Status float64
Task status 1. Not started | Task initialization, 2. Task starting, 3. Running, 4. Paused, 5. Task stopping, 6. Stopped, 7. Execution failed, 8. deleted, 9. Locked, 404. unknown status.
StopTime string
The time the task was stopped.
Submit bool
Whether the task version has been submitted for operation and maintenance.
SwitchResource float64
Resource tiering status, 0: in progress, 1: successful, 2: failed.
TaskAlarmRegularLists []string
Task alarm regular.
TaskGroupId string
Inlong Task Group ID.
UpdateTime string
Update time.
WorkflowId string
The workflow id to which the task belongs.
appId String
User App Id.
configs List<WedataIntegrationRealtimeTaskTaskInfoConfig>
Task configuration.
createTime String
Create time.
creatorUin String
Creator User ID.
dataProxyUrls List<String>
Data proxy url.
executeContexts List<WedataIntegrationRealtimeTaskTaskInfoExecuteContext>
Execute context.
executorGroupName String
Executor group name.
executorId String
Executor resource ID.
extConfigs List<WedataIntegrationRealtimeTaskTaskInfoExtConfig>
Node extension configuration information.
hasVersion Boolean
Whether the task been submitted.
inLongManagerUrl String
InLong manager url.
inLongManagerVersion String
InLong manager version.
inLongStreamId String
InLong stream id.
incharge String
Incharge user.
inputDatasourceType String
Input datasource type.
instanceVersion Double
Instance version.
lastRunTime String
The last time the task was run.
locked Boolean
Whether the task been locked.
locker String
User locked task.
mappings List<WedataIntegrationRealtimeTaskTaskInfoMapping>
Node mapping.
nodes List<WedataIntegrationRealtimeTaskTaskInfoNode>
Task Node Information.
numRecordsIn Double
Number of reads.
numRecordsOut Double
Number of writes.
numRestarts Double
Times of restarts.
operatorUin String
Operator User ID.
outputDatasourceType String
Output datasource type.
ownerUin String
Owner User ID.
readPhase Double
Reading stage, 0: full amount, 1: partial full amount, 2: all incremental.
readerDelay Double
Read latency.
runningCu Double
The amount of resources consumed by real-time task.
scheduleTaskId String
Task scheduling id (job id such as oceanus or us).
status Double
Task status 1. Not started | Task initialization, 2. Task starting, 3. Running, 4. Paused, 5. Task stopping, 6. Stopped, 7. Execution failed, 8. deleted, 9. Locked, 404. unknown status.
stopTime String
The time the task was stopped.
submit Boolean
Whether the task version has been submitted for operation and maintenance.
switchResource Double
Resource tiering status, 0: in progress, 1: successful, 2: failed.
taskAlarmRegularLists List<String>
Task alarm regular.
taskGroupId String
Inlong Task Group ID.
updateTime String
Update time.
workflowId String
The workflow id to which the task belongs.
appId string
User App Id.
configs WedataIntegrationRealtimeTaskTaskInfoConfig[]
Task configuration.
createTime string
Create time.
creatorUin string
Creator User ID.
dataProxyUrls string[]
Data proxy url.
executeContexts WedataIntegrationRealtimeTaskTaskInfoExecuteContext[]
Execute context.
executorGroupName string
Executor group name.
executorId string
Executor resource ID.
extConfigs WedataIntegrationRealtimeTaskTaskInfoExtConfig[]
Node extension configuration information.
hasVersion boolean
Whether the task been submitted.
inLongManagerUrl string
InLong manager url.
inLongManagerVersion string
InLong manager version.
inLongStreamId string
InLong stream id.
incharge string
Incharge user.
inputDatasourceType string
Input datasource type.
instanceVersion number
Instance version.
lastRunTime string
The last time the task was run.
locked boolean
Whether the task been locked.
locker string
User locked task.
mappings WedataIntegrationRealtimeTaskTaskInfoMapping[]
Node mapping.
nodes WedataIntegrationRealtimeTaskTaskInfoNode[]
Task Node Information.
numRecordsIn number
Number of reads.
numRecordsOut number
Number of writes.
numRestarts number
Times of restarts.
operatorUin string
Operator User ID.
outputDatasourceType string
Output datasource type.
ownerUin string
Owner User ID.
readPhase number
Reading stage, 0: full amount, 1: partial full amount, 2: all incremental.
readerDelay number
Read latency.
runningCu number
The amount of resources consumed by real-time task.
scheduleTaskId string
Task scheduling id (job id such as oceanus or us).
status number
Task status 1. Not started | Task initialization, 2. Task starting, 3. Running, 4. Paused, 5. Task stopping, 6. Stopped, 7. Execution failed, 8. deleted, 9. Locked, 404. unknown status.
stopTime string
The time the task was stopped.
submit boolean
Whether the task version has been submitted for operation and maintenance.
switchResource number
Resource tiering status, 0: in progress, 1: successful, 2: failed.
taskAlarmRegularLists string[]
Task alarm regular.
taskGroupId string
Inlong Task Group ID.
updateTime string
Update time.
workflowId string
The workflow id to which the task belongs.
app_id str
User App Id.
configs Sequence[WedataIntegrationRealtimeTaskTaskInfoConfig]
Task configuration.
create_time str
Create time.
creator_uin str
Creator User ID.
data_proxy_urls Sequence[str]
Data proxy url.
execute_contexts Sequence[WedataIntegrationRealtimeTaskTaskInfoExecuteContext]
Execute context.
executor_group_name str
Executor group name.
executor_id str
Executor resource ID.
ext_configs Sequence[WedataIntegrationRealtimeTaskTaskInfoExtConfig]
Node extension configuration information.
has_version bool
Whether the task been submitted.
in_long_manager_url str
InLong manager url.
in_long_manager_version str
InLong manager version.
in_long_stream_id str
InLong stream id.
incharge str
Incharge user.
input_datasource_type str
Input datasource type.
instance_version float
Instance version.
last_run_time str
The last time the task was run.
locked bool
Whether the task been locked.
locker str
User locked task.
mappings Sequence[WedataIntegrationRealtimeTaskTaskInfoMapping]
Node mapping.
nodes Sequence[WedataIntegrationRealtimeTaskTaskInfoNode]
Task Node Information.
num_records_in float
Number of reads.
num_records_out float
Number of writes.
num_restarts float
Times of restarts.
operator_uin str
Operator User ID.
output_datasource_type str
Output datasource type.
owner_uin str
Owner User ID.
read_phase float
Reading stage, 0: full amount, 1: partial full amount, 2: all incremental.
reader_delay float
Read latency.
running_cu float
The amount of resources consumed by real-time task.
schedule_task_id str
Task scheduling id (job id such as oceanus or us).
status float
Task status 1. Not started | Task initialization, 2. Task starting, 3. Running, 4. Paused, 5. Task stopping, 6. Stopped, 7. Execution failed, 8. deleted, 9. Locked, 404. unknown status.
stop_time str
The time the task was stopped.
submit bool
Whether the task version has been submitted for operation and maintenance.
switch_resource float
Resource tiering status, 0: in progress, 1: successful, 2: failed.
task_alarm_regular_lists Sequence[str]
Task alarm regular.
task_group_id str
Inlong Task Group ID.
update_time str
Update time.
workflow_id str
The workflow id to which the task belongs.
appId String
User App Id.
configs List<Property Map>
Task configuration.
createTime String
Create time.
creatorUin String
Creator User ID.
dataProxyUrls List<String>
Data proxy url.
executeContexts List<Property Map>
Execute context.
executorGroupName String
Executor group name.
executorId String
Executor resource ID.
extConfigs List<Property Map>
Node extension configuration information.
hasVersion Boolean
Whether the task been submitted.
inLongManagerUrl String
InLong manager url.
inLongManagerVersion String
InLong manager version.
inLongStreamId String
InLong stream id.
incharge String
Incharge user.
inputDatasourceType String
Input datasource type.
instanceVersion Number
Instance version.
lastRunTime String
The last time the task was run.
locked Boolean
Whether the task been locked.
locker String
User locked task.
mappings List<Property Map>
Node mapping.
nodes List<Property Map>
Task Node Information.
numRecordsIn Number
Number of reads.
numRecordsOut Number
Number of writes.
numRestarts Number
Times of restarts.
operatorUin String
Operator User ID.
outputDatasourceType String
Output datasource type.
ownerUin String
Owner User ID.
readPhase Number
Reading stage, 0: full amount, 1: partial full amount, 2: all incremental.
readerDelay Number
Read latency.
runningCu Number
The amount of resources consumed by real-time task.
scheduleTaskId String
Task scheduling id (job id such as oceanus or us).
status Number
Task status 1. Not started | Task initialization, 2. Task starting, 3. Running, 4. Paused, 5. Task stopping, 6. Stopped, 7. Execution failed, 8. deleted, 9. Locked, 404. unknown status.
stopTime String
The time the task was stopped.
submit Boolean
Whether the task version has been submitted for operation and maintenance.
switchResource Number
Resource tiering status, 0: in progress, 1: successful, 2: failed.
taskAlarmRegularLists List<String>
Task alarm regular.
taskGroupId String
Inlong Task Group ID.
updateTime String
Update time.
workflowId String
The workflow id to which the task belongs.

WedataIntegrationRealtimeTaskTaskInfoConfig
, WedataIntegrationRealtimeTaskTaskInfoConfigArgs

Name string
Configuration name.
Value string
Configuration value.
Name string
Configuration name.
Value string
Configuration value.
name String
Configuration name.
value String
Configuration value.
name string
Configuration name.
value string
Configuration value.
name str
Configuration name.
value str
Configuration value.
name String
Configuration name.
value String
Configuration value.

WedataIntegrationRealtimeTaskTaskInfoExecuteContext
, WedataIntegrationRealtimeTaskTaskInfoExecuteContextArgs

Name string
Configuration name.
Value string
Configuration value.
Name string
Configuration name.
Value string
Configuration value.
name String
Configuration name.
value String
Configuration value.
name string
Configuration name.
value string
Configuration value.
name str
Configuration name.
value str
Configuration value.
name String
Configuration name.
value String
Configuration value.

WedataIntegrationRealtimeTaskTaskInfoExtConfig
, WedataIntegrationRealtimeTaskTaskInfoExtConfigArgs

Name string
Configuration name.
Value string
Configuration value.
Name string
Configuration name.
Value string
Configuration value.
name String
Configuration name.
value String
Configuration value.
name string
Configuration name.
value string
Configuration value.
name str
Configuration name.
value str
Configuration value.
name String
Configuration name.
value String
Configuration value.

WedataIntegrationRealtimeTaskTaskInfoMapping
, WedataIntegrationRealtimeTaskTaskInfoMappingArgs

extConfigs List<Property Map>
Node extension configuration information.
schemaMappings List<Property Map>
Schema mapping information.
sinkId String
Sink node ID.
sourceId String
Source node ID.
sourceSchemas List<Property Map>
Source node schema information.

WedataIntegrationRealtimeTaskTaskInfoMappingExtConfig
, WedataIntegrationRealtimeTaskTaskInfoMappingExtConfigArgs

Name string
Configuration name.
Value string
Configuration value.
Name string
Configuration name.
Value string
Configuration value.
name String
Configuration name.
value String
Configuration value.
name string
Configuration name.
value string
Configuration value.
name str
Configuration name.
value str
Configuration value.
name String
Configuration name.
value String
Configuration value.

WedataIntegrationRealtimeTaskTaskInfoMappingSchemaMapping
, WedataIntegrationRealtimeTaskTaskInfoMappingSchemaMappingArgs

SinkSchemaId This property is required. string
Schema ID from sink node.
SourceSchemaId This property is required. string
Schema ID from source node.
SinkSchemaId This property is required. string
Schema ID from sink node.
SourceSchemaId This property is required. string
Schema ID from source node.
sinkSchemaId This property is required. String
Schema ID from sink node.
sourceSchemaId This property is required. String
Schema ID from source node.
sinkSchemaId This property is required. string
Schema ID from sink node.
sourceSchemaId This property is required. string
Schema ID from source node.
sink_schema_id This property is required. str
Schema ID from sink node.
source_schema_id This property is required. str
Schema ID from source node.
sinkSchemaId This property is required. String
Schema ID from sink node.
sourceSchemaId This property is required. String
Schema ID from source node.

WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchema
, WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaArgs

Id This property is required. string
Schema ID.
Name This property is required. string
Schema name.
Type This property is required. string
Schema type.
Alias string
Schema alias.
Comment string
Schema comment.
Properties List<WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaProperty>
Schema extended attributes.
Value string
Schema value.
Id This property is required. string
Schema ID.
Name This property is required. string
Schema name.
Type This property is required. string
Schema type.
Alias string
Schema alias.
Comment string
Schema comment.
Properties []WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaProperty
Schema extended attributes.
Value string
Schema value.
id This property is required. String
Schema ID.
name This property is required. String
Schema name.
type This property is required. String
Schema type.
alias String
Schema alias.
comment String
Schema comment.
properties List<WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaProperty>
Schema extended attributes.
value String
Schema value.
id This property is required. string
Schema ID.
name This property is required. string
Schema name.
type This property is required. string
Schema type.
alias string
Schema alias.
comment string
Schema comment.
properties WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaProperty[]
Schema extended attributes.
value string
Schema value.
id This property is required. str
Schema ID.
name This property is required. str
Schema name.
type This property is required. str
Schema type.
alias str
Schema alias.
comment str
Schema comment.
properties Sequence[WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaProperty]
Schema extended attributes.
value str
Schema value.
id This property is required. String
Schema ID.
name This property is required. String
Schema name.
type This property is required. String
Schema type.
alias String
Schema alias.
comment String
Schema comment.
properties List<Property Map>
Schema extended attributes.
value String
Schema value.

WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaProperty
, WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaPropertyArgs

Name string
Attributes name.
Value string
Attributes value.
Name string
Attributes name.
Value string
Attributes value.
name String
Attributes name.
value String
Attributes value.
name string
Attributes name.
value string
Attributes value.
name str
Attributes name.
value str
Attributes value.
name String
Attributes name.
value String
Attributes value.

WedataIntegrationRealtimeTaskTaskInfoNode
, WedataIntegrationRealtimeTaskTaskInfoNodeArgs

AppId string
User App Id.
Configs List<WedataIntegrationRealtimeTaskTaskInfoNodeConfig>
Node configuration information.
CreateTime string
Create time.
CreatorUin string
Creator User ID.
DataSourceType string
Data source type: MYSQL, POSTGRE, ORACLE, SQLSERVER, FTP, HIVE, HDFS, ICEBERG, KAFKA, HBASE, SPARK, TBASE, DB2, DM, GAUSSDB, GBASE, IMPALA, ES, S3_DATAINSIGHT, GREENPLUM, PHOENIX, SAP_HANA, SFTP, OCEANBASE, CLICKHOUSE, KUDU, VERTICA, REDIS, COS, DLC, DORIS, CKAFKA, DTS_KAFKA, S3, CDW, TDSQLC, TDSQL, MONGODB, SYBASE, REST_API, StarRocks, TCHOUSE_X.
DatasourceId string
Datasource ID.
Description string
Node Description.
ExtConfigs List<WedataIntegrationRealtimeTaskTaskInfoNodeExtConfig>
Node extension configuration information.
Id string
Schema ID.
Name string
Schema name.
NodeMapping WedataIntegrationRealtimeTaskTaskInfoNodeNodeMapping
Node mapping.
NodeType string
Node type: INPUT,OUTPUT,JOIN,FILTER,TRANSFORM.
OperatorUin string
Operator User ID.
OwnerUin string
Owner User ID.
ProjectId string
Project ID.
Schemas List<WedataIntegrationRealtimeTaskTaskInfoNodeSchema>
Schema information.
TaskId string
The task id to which the node belongs.
UpdateTime string
Update time.
AppId string
User App Id.
Configs []WedataIntegrationRealtimeTaskTaskInfoNodeConfig
Node configuration information.
CreateTime string
Create time.
CreatorUin string
Creator User ID.
DataSourceType string
Data source type: MYSQL, POSTGRE, ORACLE, SQLSERVER, FTP, HIVE, HDFS, ICEBERG, KAFKA, HBASE, SPARK, TBASE, DB2, DM, GAUSSDB, GBASE, IMPALA, ES, S3_DATAINSIGHT, GREENPLUM, PHOENIX, SAP_HANA, SFTP, OCEANBASE, CLICKHOUSE, KUDU, VERTICA, REDIS, COS, DLC, DORIS, CKAFKA, DTS_KAFKA, S3, CDW, TDSQLC, TDSQL, MONGODB, SYBASE, REST_API, StarRocks, TCHOUSE_X.
DatasourceId string
Datasource ID.
Description string
Node Description.
ExtConfigs []WedataIntegrationRealtimeTaskTaskInfoNodeExtConfig
Node extension configuration information.
Id string
Schema ID.
Name string
Schema name.
NodeMapping WedataIntegrationRealtimeTaskTaskInfoNodeNodeMapping
Node mapping.
NodeType string
Node type: INPUT,OUTPUT,JOIN,FILTER,TRANSFORM.
OperatorUin string
Operator User ID.
OwnerUin string
Owner User ID.
ProjectId string
Project ID.
Schemas []WedataIntegrationRealtimeTaskTaskInfoNodeSchema
Schema information.
TaskId string
The task id to which the node belongs.
UpdateTime string
Update time.
appId String
User App Id.
configs List<WedataIntegrationRealtimeTaskTaskInfoNodeConfig>
Node configuration information.
createTime String
Create time.
creatorUin String
Creator User ID.
dataSourceType String
Data source type: MYSQL, POSTGRE, ORACLE, SQLSERVER, FTP, HIVE, HDFS, ICEBERG, KAFKA, HBASE, SPARK, TBASE, DB2, DM, GAUSSDB, GBASE, IMPALA, ES, S3_DATAINSIGHT, GREENPLUM, PHOENIX, SAP_HANA, SFTP, OCEANBASE, CLICKHOUSE, KUDU, VERTICA, REDIS, COS, DLC, DORIS, CKAFKA, DTS_KAFKA, S3, CDW, TDSQLC, TDSQL, MONGODB, SYBASE, REST_API, StarRocks, TCHOUSE_X.
datasourceId String
Datasource ID.
description String
Node Description.
extConfigs List<WedataIntegrationRealtimeTaskTaskInfoNodeExtConfig>
Node extension configuration information.
id String
Schema ID.
name String
Schema name.
nodeMapping WedataIntegrationRealtimeTaskTaskInfoNodeNodeMapping
Node mapping.
nodeType String
Node type: INPUT,OUTPUT,JOIN,FILTER,TRANSFORM.
operatorUin String
Operator User ID.
ownerUin String
Owner User ID.
projectId String
Project ID.
schemas List<WedataIntegrationRealtimeTaskTaskInfoNodeSchema>
Schema information.
taskId String
The task id to which the node belongs.
updateTime String
Update time.
appId string
User App Id.
configs WedataIntegrationRealtimeTaskTaskInfoNodeConfig[]
Node configuration information.
createTime string
Create time.
creatorUin string
Creator User ID.
dataSourceType string
Data source type: MYSQL, POSTGRE, ORACLE, SQLSERVER, FTP, HIVE, HDFS, ICEBERG, KAFKA, HBASE, SPARK, TBASE, DB2, DM, GAUSSDB, GBASE, IMPALA, ES, S3_DATAINSIGHT, GREENPLUM, PHOENIX, SAP_HANA, SFTP, OCEANBASE, CLICKHOUSE, KUDU, VERTICA, REDIS, COS, DLC, DORIS, CKAFKA, DTS_KAFKA, S3, CDW, TDSQLC, TDSQL, MONGODB, SYBASE, REST_API, StarRocks, TCHOUSE_X.
datasourceId string
Datasource ID.
description string
Node Description.
extConfigs WedataIntegrationRealtimeTaskTaskInfoNodeExtConfig[]
Node extension configuration information.
id string
Schema ID.
name string
Schema name.
nodeMapping WedataIntegrationRealtimeTaskTaskInfoNodeNodeMapping
Node mapping.
nodeType string
Node type: INPUT,OUTPUT,JOIN,FILTER,TRANSFORM.
operatorUin string
Operator User ID.
ownerUin string
Owner User ID.
projectId string
Project ID.
schemas WedataIntegrationRealtimeTaskTaskInfoNodeSchema[]
Schema information.
taskId string
The task id to which the node belongs.
updateTime string
Update time.
app_id str
User App Id.
configs Sequence[WedataIntegrationRealtimeTaskTaskInfoNodeConfig]
Node configuration information.
create_time str
Create time.
creator_uin str
Creator User ID.
data_source_type str
Data source type: MYSQL, POSTGRE, ORACLE, SQLSERVER, FTP, HIVE, HDFS, ICEBERG, KAFKA, HBASE, SPARK, TBASE, DB2, DM, GAUSSDB, GBASE, IMPALA, ES, S3_DATAINSIGHT, GREENPLUM, PHOENIX, SAP_HANA, SFTP, OCEANBASE, CLICKHOUSE, KUDU, VERTICA, REDIS, COS, DLC, DORIS, CKAFKA, DTS_KAFKA, S3, CDW, TDSQLC, TDSQL, MONGODB, SYBASE, REST_API, StarRocks, TCHOUSE_X.
datasource_id str
Datasource ID.
description str
Node Description.
ext_configs Sequence[WedataIntegrationRealtimeTaskTaskInfoNodeExtConfig]
Node extension configuration information.
id str
Schema ID.
name str
Schema name.
node_mapping WedataIntegrationRealtimeTaskTaskInfoNodeNodeMapping
Node mapping.
node_type str
Node type: INPUT,OUTPUT,JOIN,FILTER,TRANSFORM.
operator_uin str
Operator User ID.
owner_uin str
Owner User ID.
project_id str
Project ID.
schemas Sequence[WedataIntegrationRealtimeTaskTaskInfoNodeSchema]
Schema information.
task_id str
The task id to which the node belongs.
update_time str
Update time.
appId String
User App Id.
configs List<Property Map>
Node configuration information.
createTime String
Create time.
creatorUin String
Creator User ID.
dataSourceType String
Data source type: MYSQL, POSTGRE, ORACLE, SQLSERVER, FTP, HIVE, HDFS, ICEBERG, KAFKA, HBASE, SPARK, TBASE, DB2, DM, GAUSSDB, GBASE, IMPALA, ES, S3_DATAINSIGHT, GREENPLUM, PHOENIX, SAP_HANA, SFTP, OCEANBASE, CLICKHOUSE, KUDU, VERTICA, REDIS, COS, DLC, DORIS, CKAFKA, DTS_KAFKA, S3, CDW, TDSQLC, TDSQL, MONGODB, SYBASE, REST_API, StarRocks, TCHOUSE_X.
datasourceId String
Datasource ID.
description String
Node Description.
extConfigs List<Property Map>
Node extension configuration information.
id String
Schema ID.
name String
Schema name.
nodeMapping Property Map
Node mapping.
nodeType String
Node type: INPUT,OUTPUT,JOIN,FILTER,TRANSFORM.
operatorUin String
Operator User ID.
ownerUin String
Owner User ID.
projectId String
Project ID.
schemas List<Property Map>
Schema information.
taskId String
The task id to which the node belongs.
updateTime String
Update time.

WedataIntegrationRealtimeTaskTaskInfoNodeConfig
, WedataIntegrationRealtimeTaskTaskInfoNodeConfigArgs

Name string
Configuration name.
Value string
Configuration value.
Name string
Configuration name.
Value string
Configuration value.
name String
Configuration name.
value String
Configuration value.
name string
Configuration name.
value string
Configuration value.
name str
Configuration name.
value str
Configuration value.
name String
Configuration name.
value String
Configuration value.

WedataIntegrationRealtimeTaskTaskInfoNodeExtConfig
, WedataIntegrationRealtimeTaskTaskInfoNodeExtConfigArgs

Name string
Configuration name.
Value string
Configuration value.
Name string
Configuration name.
Value string
Configuration value.
name String
Configuration name.
value String
Configuration value.
name string
Configuration name.
value string
Configuration value.
name str
Configuration name.
value str
Configuration value.
name String
Configuration name.
value String
Configuration value.

WedataIntegrationRealtimeTaskTaskInfoNodeNodeMapping
, WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingArgs

extConfigs List<Property Map>
Node extension configuration information.
schemaMappings List<Property Map>
Schema mapping information.
sinkId String
Sink node ID.
sourceId String
Source node ID.
sourceSchemas List<Property Map>
Source node schema information.

WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingExtConfig
, WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingExtConfigArgs

Name string
Configuration name.
Value string
Configuration value.
Name string
Configuration name.
Value string
Configuration value.
name String
Configuration name.
value String
Configuration value.
name string
Configuration name.
value string
Configuration value.
name str
Configuration name.
value str
Configuration value.
name String
Configuration name.
value String
Configuration value.

WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSchemaMapping
, WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSchemaMappingArgs

SinkSchemaId This property is required. string
Schema ID from sink node.
SourceSchemaId This property is required. string
Schema ID from source node.
SinkSchemaId This property is required. string
Schema ID from sink node.
SourceSchemaId This property is required. string
Schema ID from source node.
sinkSchemaId This property is required. String
Schema ID from sink node.
sourceSchemaId This property is required. String
Schema ID from source node.
sinkSchemaId This property is required. string
Schema ID from sink node.
sourceSchemaId This property is required. string
Schema ID from source node.
sink_schema_id This property is required. str
Schema ID from sink node.
source_schema_id This property is required. str
Schema ID from source node.
sinkSchemaId This property is required. String
Schema ID from sink node.
sourceSchemaId This property is required. String
Schema ID from source node.

WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchema
, WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaArgs

Id This property is required. string
Schema ID.
Name This property is required. string
Schema name.
Type This property is required. string
Schema type.
Alias string
Schema alias.
Comment string
Schema comment.
Properties List<WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaProperty>
Schema extended attributes.
Value string
Schema value.
Id This property is required. string
Schema ID.
Name This property is required. string
Schema name.
Type This property is required. string
Schema type.
Alias string
Schema alias.
Comment string
Schema comment.
Properties []WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaProperty
Schema extended attributes.
Value string
Schema value.
id This property is required. String
Schema ID.
name This property is required. String
Schema name.
type This property is required. String
Schema type.
alias String
Schema alias.
comment String
Schema comment.
properties List<WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaProperty>
Schema extended attributes.
value String
Schema value.
id This property is required. string
Schema ID.
name This property is required. string
Schema name.
type This property is required. string
Schema type.
alias string
Schema alias.
comment string
Schema comment.
properties WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaProperty[]
Schema extended attributes.
value string
Schema value.
id This property is required. str
Schema ID.
name This property is required. str
Schema name.
type This property is required. str
Schema type.
alias str
Schema alias.
comment str
Schema comment.
properties Sequence[WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaProperty]
Schema extended attributes.
value str
Schema value.
id This property is required. String
Schema ID.
name This property is required. String
Schema name.
type This property is required. String
Schema type.
alias String
Schema alias.
comment String
Schema comment.
properties List<Property Map>
Schema extended attributes.
value String
Schema value.

WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaProperty
, WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaPropertyArgs

Name string
Attributes name.
Value string
Attributes value.
Name string
Attributes name.
Value string
Attributes value.
name String
Attributes name.
value String
Attributes value.
name string
Attributes name.
value string
Attributes value.
name str
Attributes name.
value str
Attributes value.
name String
Attributes name.
value String
Attributes value.

WedataIntegrationRealtimeTaskTaskInfoNodeSchema
, WedataIntegrationRealtimeTaskTaskInfoNodeSchemaArgs

Id This property is required. string
Schema ID.
Name This property is required. string
Schema name.
Type This property is required. string
Schema type.
Alias string
Schema alias.
Comment string
Schema comment.
Properties List<WedataIntegrationRealtimeTaskTaskInfoNodeSchemaProperty>
Schema extended attributes.
Value string
Schema value.
Id This property is required. string
Schema ID.
Name This property is required. string
Schema name.
Type This property is required. string
Schema type.
Alias string
Schema alias.
Comment string
Schema comment.
Properties []WedataIntegrationRealtimeTaskTaskInfoNodeSchemaProperty
Schema extended attributes.
Value string
Schema value.
id This property is required. String
Schema ID.
name This property is required. String
Schema name.
type This property is required. String
Schema type.
alias String
Schema alias.
comment String
Schema comment.
properties List<WedataIntegrationRealtimeTaskTaskInfoNodeSchemaProperty>
Schema extended attributes.
value String
Schema value.
id This property is required. string
Schema ID.
name This property is required. string
Schema name.
type This property is required. string
Schema type.
alias string
Schema alias.
comment string
Schema comment.
properties WedataIntegrationRealtimeTaskTaskInfoNodeSchemaProperty[]
Schema extended attributes.
value string
Schema value.
id This property is required. str
Schema ID.
name This property is required. str
Schema name.
type This property is required. str
Schema type.
alias str
Schema alias.
comment str
Schema comment.
properties Sequence[WedataIntegrationRealtimeTaskTaskInfoNodeSchemaProperty]
Schema extended attributes.
value str
Schema value.
id This property is required. String
Schema ID.
name This property is required. String
Schema name.
type This property is required. String
Schema type.
alias String
Schema alias.
comment String
Schema comment.
properties List<Property Map>
Schema extended attributes.
value String
Schema value.

WedataIntegrationRealtimeTaskTaskInfoNodeSchemaProperty
, WedataIntegrationRealtimeTaskTaskInfoNodeSchemaPropertyArgs

Name string
Attributes name.
Value string
Attributes value.
Name string
Attributes name.
Value string
Attributes value.
name String
Attributes name.
value String
Attributes value.
name string
Attributes name.
value string
Attributes value.
name str
Attributes name.
value str
Attributes value.
name String
Attributes name.
value String
Attributes value.

Import

wedata integration_realtime_task can be imported using the id, e.g.

$ pulumi import tencentcloud:index/wedataIntegrationRealtimeTask:WedataIntegrationRealtimeTask example 1776563389209296896#h9d39630a-ae45-4460-90b2-0b093cbfef5d
Copy

To learn more about importing existing cloud resources, see Importing resources.

Package Details

Repository
tencentcloud tencentcloudstack/terraform-provider-tencentcloud
License
Notes
This Pulumi package is based on the tencentcloud Terraform Provider.
tencentcloud 1.81.183 published on Wednesday, Apr 16, 2025 by tencentcloudstack
tencentcloudstack/terraform-provider-tencentcloud