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.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack
tencentcloudstack/terraform-provider-tencentcloud

tencentcloud.WedataIntegrationRealtimeTask

Explore with Pulumi AI

tencentcloud logo
tencentcloud 1.81.189 published on Wednesday, Apr 30, 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",
});

    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")

    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
	})
}

    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",
    });

});

    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());

    }
}

    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

    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 string
    The unique name of the resource.
    args WedataIntegrationRealtimeTaskArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    resource_name str
    The unique name of the resource.
    args 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 string
    The unique name of the resource.
    args WedataIntegrationRealtimeTaskArgs
    The arguments to resource properties.
    opts ResourceOption
    Bag of options to control resource's behavior.
    name string
    The unique name of the resource.
    args WedataIntegrationRealtimeTaskArgs
    The arguments to resource properties.
    opts CustomResourceOptions
    Bag of options to control resource's behavior.
    name String
    The unique name of the resource.
    args 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 string
    Project ID.
    SyncType double
    Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
    TaskInfo WedataIntegrationRealtimeTaskTaskInfo
    Task Information.
    TaskMode string
    Task display mode, 0: canvas mode, 1: form mode.
    TaskName string
    Task name.
    Description string
    Description information.
    WedataIntegrationRealtimeTaskId string
    ID of the resource.
    ProjectId string
    Project ID.
    SyncType float64
    Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
    TaskInfo WedataIntegrationRealtimeTaskTaskInfoArgs
    Task Information.
    TaskMode string
    Task display mode, 0: canvas mode, 1: form mode.
    TaskName string
    Task name.
    Description string
    Description information.
    WedataIntegrationRealtimeTaskId string
    ID of the resource.
    projectId String
    Project ID.
    syncType Double
    Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
    taskInfo WedataIntegrationRealtimeTaskTaskInfo
    Task Information.
    taskMode String
    Task display mode, 0: canvas mode, 1: form mode.
    taskName String
    Task name.
    description String
    Description information.
    wedataIntegrationRealtimeTaskId String
    ID of the resource.
    projectId string
    Project ID.
    syncType number
    Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
    taskInfo WedataIntegrationRealtimeTaskTaskInfo
    Task Information.
    taskMode string
    Task display mode, 0: canvas mode, 1: form mode.
    taskName string
    Task name.
    description string
    Description information.
    wedataIntegrationRealtimeTaskId string
    ID of the resource.
    project_id str
    Project ID.
    sync_type float
    Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
    task_info WedataIntegrationRealtimeTaskTaskInfoArgs
    Task Information.
    task_mode str
    Task display mode, 0: canvas mode, 1: form mode.
    task_name str
    Task name.
    description str
    Description information.
    wedata_integration_realtime_task_id str
    ID of the resource.
    projectId String
    Project ID.
    syncType Number
    Synchronization type: 1. Whole database synchronization, 2. Single table synchronization.
    taskInfo Property Map
    Task Information.
    taskMode String
    Task display mode, 0: canvas mode, 1: form mode.
    taskName 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
    The unique name of the resulting resource.
    id
    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
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    name
    The unique name of the resulting resource.
    id
    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
    The unique name of the resulting resource.
    id
    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
    The unique name of the resulting resource.
    id
    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 string
    Schema ID from sink node.
    SourceSchemaId string
    Schema ID from source node.
    SinkSchemaId string
    Schema ID from sink node.
    SourceSchemaId string
    Schema ID from source node.
    sinkSchemaId String
    Schema ID from sink node.
    sourceSchemaId String
    Schema ID from source node.
    sinkSchemaId string
    Schema ID from sink node.
    sourceSchemaId string
    Schema ID from source node.
    sink_schema_id str
    Schema ID from sink node.
    source_schema_id str
    Schema ID from source node.
    sinkSchemaId String
    Schema ID from sink node.
    sourceSchemaId String
    Schema ID from source node.

    WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchema, WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaArgs

    Id string
    Schema ID.
    Name string
    Schema name.
    Type string
    Schema type.
    Alias string
    Schema alias.
    Comment string
    Schema comment.
    Properties List<WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaProperty>
    Schema extended attributes.
    Value string
    Schema value.
    Id string
    Schema ID.
    Name string
    Schema name.
    Type string
    Schema type.
    Alias string
    Schema alias.
    Comment string
    Schema comment.
    Properties []WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaProperty
    Schema extended attributes.
    Value string
    Schema value.
    id String
    Schema ID.
    name String
    Schema name.
    type String
    Schema type.
    alias String
    Schema alias.
    comment String
    Schema comment.
    properties List<WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaProperty>
    Schema extended attributes.
    value String
    Schema value.
    id string
    Schema ID.
    name string
    Schema name.
    type string
    Schema type.
    alias string
    Schema alias.
    comment string
    Schema comment.
    properties WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaProperty[]
    Schema extended attributes.
    value string
    Schema value.
    id str
    Schema ID.
    name str
    Schema name.
    type str
    Schema type.
    alias str
    Schema alias.
    comment str
    Schema comment.
    properties Sequence[WedataIntegrationRealtimeTaskTaskInfoMappingSourceSchemaProperty]
    Schema extended attributes.
    value str
    Schema value.
    id String
    Schema ID.
    name String
    Schema name.
    type 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 string
    Schema ID from sink node.
    SourceSchemaId string
    Schema ID from source node.
    SinkSchemaId string
    Schema ID from sink node.
    SourceSchemaId string
    Schema ID from source node.
    sinkSchemaId String
    Schema ID from sink node.
    sourceSchemaId String
    Schema ID from source node.
    sinkSchemaId string
    Schema ID from sink node.
    sourceSchemaId string
    Schema ID from source node.
    sink_schema_id str
    Schema ID from sink node.
    source_schema_id str
    Schema ID from source node.
    sinkSchemaId String
    Schema ID from sink node.
    sourceSchemaId String
    Schema ID from source node.

    WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchema, WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaArgs

    Id string
    Schema ID.
    Name string
    Schema name.
    Type string
    Schema type.
    Alias string
    Schema alias.
    Comment string
    Schema comment.
    Properties List<WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaProperty>
    Schema extended attributes.
    Value string
    Schema value.
    Id string
    Schema ID.
    Name string
    Schema name.
    Type string
    Schema type.
    Alias string
    Schema alias.
    Comment string
    Schema comment.
    Properties []WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaProperty
    Schema extended attributes.
    Value string
    Schema value.
    id String
    Schema ID.
    name String
    Schema name.
    type String
    Schema type.
    alias String
    Schema alias.
    comment String
    Schema comment.
    properties List<WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaProperty>
    Schema extended attributes.
    value String
    Schema value.
    id string
    Schema ID.
    name string
    Schema name.
    type string
    Schema type.
    alias string
    Schema alias.
    comment string
    Schema comment.
    properties WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaProperty[]
    Schema extended attributes.
    value string
    Schema value.
    id str
    Schema ID.
    name str
    Schema name.
    type str
    Schema type.
    alias str
    Schema alias.
    comment str
    Schema comment.
    properties Sequence[WedataIntegrationRealtimeTaskTaskInfoNodeNodeMappingSourceSchemaProperty]
    Schema extended attributes.
    value str
    Schema value.
    id String
    Schema ID.
    name String
    Schema name.
    type 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 string
    Schema ID.
    Name string
    Schema name.
    Type string
    Schema type.
    Alias string
    Schema alias.
    Comment string
    Schema comment.
    Properties List<WedataIntegrationRealtimeTaskTaskInfoNodeSchemaProperty>
    Schema extended attributes.
    Value string
    Schema value.
    Id string
    Schema ID.
    Name string
    Schema name.
    Type string
    Schema type.
    Alias string
    Schema alias.
    Comment string
    Schema comment.
    Properties []WedataIntegrationRealtimeTaskTaskInfoNodeSchemaProperty
    Schema extended attributes.
    Value string
    Schema value.
    id String
    Schema ID.
    name String
    Schema name.
    type String
    Schema type.
    alias String
    Schema alias.
    comment String
    Schema comment.
    properties List<WedataIntegrationRealtimeTaskTaskInfoNodeSchemaProperty>
    Schema extended attributes.
    value String
    Schema value.
    id string
    Schema ID.
    name string
    Schema name.
    type string
    Schema type.
    alias string
    Schema alias.
    comment string
    Schema comment.
    properties WedataIntegrationRealtimeTaskTaskInfoNodeSchemaProperty[]
    Schema extended attributes.
    value string
    Schema value.
    id str
    Schema ID.
    name str
    Schema name.
    type str
    Schema type.
    alias str
    Schema alias.
    comment str
    Schema comment.
    properties Sequence[WedataIntegrationRealtimeTaskTaskInfoNodeSchemaProperty]
    Schema extended attributes.
    value str
    Schema value.
    id String
    Schema ID.
    name String
    Schema name.
    type 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

    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 logo
    tencentcloud 1.81.189 published on Wednesday, Apr 30, 2025 by tencentcloudstack
    tencentcloudstack/terraform-provider-tencentcloud