CreateNode
Define and create data development nodes within Alibaba Cloud DataWorks projects. Specify project ID, container, and node configuration to automate workflows and tasks.
Instructions
创建数据开发节点 *此Tool有MCP Resource,请查看CreateNode(MCP Resource)获取更多使用此Tool的示例详情。
Input Schema
Name | Required | Description | Default |
---|---|---|---|
ContainerId | No | 当你需要将节点创建在一个容器内部时,你需要指定这个参数。该参数为一个容器的唯一标识,这个容器可以是一个Workflow或者一个容器节点。><notice>该参数填写后,FlowSpec中定义的path字段将无效></notice> | |
ProjectId | No | DataWorks工作空间的ID | |
Scene | Yes | 节点创建的场景,决定节点创建在手动节点区域还是数据开发区域。DataworksManualWorkflow只在填写了ContainerId且Container为手动工作流时才能使用。可选值:- DATAWORKS_PROJECT 项目目录- DATAWORKS_MANUAL_WORKFLOW 手动工作流- DATAWORKS_MANUAL_TASK 手动任务 | |
Spec | Yes | { "title": "CycleWorkflow Schema", "description": "定义周期性工作流及其节点配置的JSON Schema", "type": "object", "required": ["version", "kind", "spec"], "properties": { "version": { "type": "string", "const": "1.1.0", "description": "Schema版本号,当前固定值1.1.0" }, "kind": { "type": "string", "enum": ["Workflow", "Node"], "description": "资源类型,标识工作流的具体类型" }, "spec": { "type": "object", "description": "工作流核心配置规范", "required": ["nodes"], "properties": { "nodes": { "type": "array", "description": "工作流节点列表", "items": { "type": "object", "required": ["name", "script"], "properties": { "recurrence": { "type": "string", "enum": ["Normal", "Pause", "Skip", "NoneAuto"], "description": "节点执行策略:Normal-正常执行, Pause-暂停执行, Skip-跳过执行, NoneAuto-非自动执行" }, "id": { "type": "string", "description": "节点唯一标识符" }, "timeout": { "type": "integer", "minimum": 0, "description": "执行超时时间(单位:秒)" }, "instanceMode": { "type": "string", "enum": ["T+1", "Immediately"], "description": "实例生成模式:T+1-次日生成, Immediately-立即生成" }, "rerunMode": { "type": "string", "enum": ["Allowed", "Denied", "FailureAllowed"], "description": "重跑策略:Allowed-允许重跑, Denied-禁止重跑, FailureAllowed-失败时允许重跑" }, "rerunTimes": { "type": "integer", "minimum": 0, "description": "最大重跑次数" }, "rerunInterval": { "type": "integer", "minimum": 0, "description": "重跑间隔时间(单位:秒)" }, "datasource": { "type": "object", "description": "数据源配置", "required": ["name", "type"], "properties": { "name": { "type": "string", "description": "数据源名称" }, "type": { "type": "string", "enum": ["odps"], "description": "数据源类型(当前仅支持odps)" } } }, "script": { "type": "object", "description": "节点执行脚本配置", "required": ["path", "runtime"], "properties": { "language": { "type": "string", "description": "脚本语言类型" }, "path": { "type": "string", "description": "脚本存储路径,末尾与节点名称相同,不需要有后缀" }, "runtime": { "type": "object", "description": "运行时环境配置", "required": ["command"], "properties": { "command": { "type": "string", "enum": ["ODPS_SQL"], "description": "执行命令" }, "cu": { "type": "string", "description": "计算资源单位配置" } } } } }, "trigger": { "type": "object", "description": "节点触发策略配置", "required": ["type"], "properties": { "type": { "type": "string", "enum": ["Scheduler", "Manual", "Streaming", "None"], "description": "触发类型:Scheduler-定时调度, Manual-手动触发, Streaming-流式触发, None-无触发" }, "cron": { "type": "string", "description": "Cron表达式(仅适用于Scheduler类型)" }, "startTime": { "type": "string", "format": "yyyy-MM-dd hh:mm:ss", "description": "调度开始时间" }, "endTime": { "type": "string", "format": "yyyy-MM-dd hh:mm:ss", "description": "调度结束时间" } } }, "runtimeResource": { "type": "object", "description": "运行时资源配置", "required": ["resourceGroup"], "properties": { "resourceGroup": { "type": "string", "description": "资源组名称" } } }, "name": { "type": "string", "description": "节点名称" }, "owner": { "type": "string", "description": "节点负责人" }, "inputs": { "type": "object", "description": "节点输入配置", "properties": { "nodeOutputs": { "type": "array", "description": "输入依赖列表", "items": { "type": "object", "required": ["data"], "properties": { "data": { "type": "string", "description": "输入依赖标识" }, "refTableName": { "type": "string", "description": "关联数据表名称(当artifactType为Table时必填)" }, "isDefault": { "type": "boolean", "description": "是否默认输入项" } } } } } }, "outputs": { "type": "object", "description": "节点输入配置", "properties": { "nodeOutputs": { "type": "array", "description": "输入依赖列表", "items": { "type": "object", "required": ["data"], "properties": { "data": { "type": "string", "description": "输入依赖标识" }, "refTableName": { "type": "string", "description": "关联数据表名称(当artifactType为Table时必填)" }, "isDefault": { "type": "boolean", "description": "是否默认输入项" } } } } } } } } } } } } } |
Input Schema (JSON Schema)
You must be authenticated.
Other Tools from DataWorks MCP Server
- AbolishDataServiceApi
- AbolishDeployment
- ApprovePermissionApplyOrder
- AttachDataQualityRulesToEvaluationTask
- BatchUpdateTasks
- CloneDataSource
- ConvertTimestamps
- CreateAlertRule
- CreateDataQualityEvaluationTask
- CreateDataQualityEvaluationTaskInstance
- CreateDataQualityRule
- CreateDataServiceApi
- CreateDataSource
- CreateDeployment
- CreateDIAlarmRule
- CreateDIJob
- CreateDISyncTask
- CreateFunction
- CreateNode
- CreatePermissionApplyOrder
- CreateProjectMember
- CreateResource
- CreateWorkflowDefinition
- CreateWorkflowInstances
- DeleteAlertRule
- DeleteDataQualityEvaluationTask
- DeleteDataQualityRule
- DeleteDataServiceApi
- DeleteDataSource
- DeleteDIAlarmRule
- DeleteDIJob
- DeleteFunction
- DeleteNode
- DeleteProjectMember
- DeleteResource
- DeleteTask
- DeleteWorkflow
- DeleteWorkflowDefinition
- ExecDeploymentStage
- ExecuteAdhocWorkflowInstance
- GetAlertMessage
- GetAlertRule
- GetCreateWorkflowInstancesResult
- GetDataQualityEvaluationTask
- GetDataQualityEvaluationTaskInstance
- GetDataQualityRule
- GetDataQualityRuleTemplate
- GetDataServiceApi
- GetDataServiceApiTest
- GetDataServicePublishedApi
- GetDataSource
- GetDeployment
- GetDIJob
- GetDIJobLog
- GetFunction
- GetJobStatus
- GetMetaDBTableList
- GetMetaTableBasicInfo
- GetMetaTableChangeLog
- GetMetaTableColumn
- GetMetaTableIntroWiki
- GetMetaTableOutput
- GetMetaTablePartition
- GetNetwork
- GetNode
- GetPermissionApplyOrderDetail
- GetProject
- GetProjectMember
- GetProjectRole
- GetRemind
- GetResource
- GetResourceGroup
- GetRoute
- GetTask
- GetTaskInstance
- GetTaskInstanceLog
- GetTopic
- GetTopicInfluence
- GetWorkflow
- GetWorkflowDefinition
- GetWorkflowInstance
- GrantMemberProjectRoles
- ImportWorkflowDefinition
- ListAlertMessages
- ListAlertRules
- ListDataAssets
- ListDataAssetTags
- ListDataQualityEvaluationTaskInstances
- ListDataQualityEvaluationTasks
- ListDataQualityResults
- ListDataQualityRules
- ListDataQualityRuleTemplates
- ListDataServiceApis
- ListDataServicePublishedApis
- ListDataSources
- ListDataSourceSharedRules
- ListDeployments
- ListDIAlarmRules
- ListDIJobEvents
- ListDIJobMetrics
- ListDIJobRunDetails
- ListDIJobs
- ListDownstreamTaskInstances
- ListDownstreamTasks
- ListFunctions
- ListLineage
- ListNetworks
- ListNodeDependencies
- ListNodes
- ListPermissionApplyOrders
- ListProjectMembers
- ListProjectRoles
- ListProjects
- ListResourceGroups
- ListResources
- ListRoutes
- ListTables
- ListTaskInstanceOperationLogs
- ListTaskInstances
- ListTaskOperationLogs
- ListTasks
- ListTopics
- ListUpstreamTaskInstances
- ListUpstreamTasks
- ListWorkflowDefinitions
- ListWorkflowInstances
- ListWorkflows
- MoveFunction
- MoveNode
- MoveResource
- MoveWorkflowDefinition
- PublishDataServiceApi
- RemoveTaskInstanceDependencies
- RenameFunction
- RenameNode
- RenameResource
- RenameWorkflowDefinition
- RerunTaskInstances
- ResumeTaskInstances
- RevokeMemberProjectRoles
- RevokeTablePermission
- SaveDataServiceApiTestResult
- SearchMetaTables
- SetSuccessTaskInstances
- StartDIJob
- StartWorkflowInstances
- StopDIJob
- StopTaskInstances
- StopWorkflowInstances
- SubmitDataServiceApi
- SuspendTaskInstances
- TestDataServiceApi
- TestDataSourceConnectivity
- ToTimestamps
- TriggerSchedulerTaskInstance
- UpdateAlertRule
- UpdateDataQualityEvaluationTask
- UpdateDataQualityRule
- UpdateDataServiceApi
- UpdateDataSource
- UpdateDIAlarmRule
- UpdateDIJob
- UpdateFunction
- UpdateNode
- UpdateResource
- UpdateTask
- UpdateTaskInstances
- UpdateWorkflow
- UpdateWorkflowDefinition
Related Tools
- @aliyun/alibabacloud-dataworks-mcp-server
- @aliyun/alibabacloud-dataworks-mcp-server
- @aliyun/alibabacloud-dataworks-mcp-server
- @aliyun/alibabacloud-dataworks-mcp-server
- @aliyun/alibabacloud-dataworks-mcp-server