全部产品
Search
文档中心

大数据开发治理平台 DataWorks:ListNodesByOutput

更新时间:Mar 08, 2024

调用ListNodesByOutput根据节点的输出结果精确查询目标节点。

调试

您可以在OpenAPI Explorer中直接运行该接口,免去您计算签名的困扰。运行成功后,OpenAPI Explorer可以自动生成SDK代码示例。

请求参数

名称

类型

是否必选

示例值

描述

Action String ListNodesByOutput

系统规定参数。取值:ListNodesByOutput

ProjectEnv String PROD

调度运维中心的环境标识,PROD表示生产环境,DEV表示开发环境。

Outputs String aaaaa.1231412_out,bbbb.12313123_out

节点的输出名称。支持配置多个输出名称,配置多个名称时请使用英文逗号(,)分隔。

返回数据

名称

类型

示例值

描述

HttpStatusCode Integer 200

HTTP状态码。

RequestId String SDFSDFSDF-asdfDFSDF-SDFSDf-SDfSFD

请求的ID。用于定位日志,排查问题。

ErrorMessage String The connection does not exist.

错误信息。

ErrorCode String Invalid.Tenant.ConnectionNotExists

错误码。

Success Boolean true

调用是否成功。

Data Array of OutputNodePair

返回的目标节点信息列表。

Output String test_0709_1.630003556_out

当前节点的输出名称。

NodeList Array of Node

input和output对应的节点信息列表。

SchedulerType String NORMAL

节点任务的调度类型,取值如下:

  • NORMAL:正常调度任务。该任务被日常调度。
  • MANUAL:手动任务。该任务不会被日常调度。
  • PAUSE:冻结任务。该任务被日常调度,但启动调度时直接被置为失败状态。
  • SKIP:空跑任务。该任务被日常调度,但启动调度时直接被置为成功状态。
RepeatInterval Integer 60

节点运行出错后重新调度的频率。

Repeatability Boolean true

是否可以重复运行。

FileType String ODPS_SQL

节点的类型。

常用的节点类型如下:

6(Shell)、10(ODPS SQL)、11(ODPS MR)、23(数据集成)、24(ODPS Script)、99(虚拟节点)、221(PyODPS 2)、225(ODPS Spark)、227(EMR Hive)、228(EMR Spark)、229(EMR Spark SQL)、230(EMR MR)、239(OSS对象检查)、257(EMR Shell)、258(EMR Spark Shell)、259(EMR Presto)、260(EMR Impala)、900(实时同步)、1089(跨租户节点)、1091(Hologres开发)、1093(Hologres SQL)、1100(赋值节点)、1221(PyODPS 3)。

ProjectId Long 33671

工作空间的ID。

ProgramType String ODPS_SQL

节点的类型。该参数已废弃,节点类型请参考FileType。

Priority Integer 1

节点运行的优先级,取值分为1、3、5、7和8。取值越大,优先级越高。默认优先级为1。

OwnerId String 19337906836551

负责人的ID。

Connection String odps_source

数据源名称。

ParamValues String a=b

节点的调度参数。

RelatedFlowId Long 1235655464

关联的业务流程ID。

DqcType Integer 1

DQC类型,0表示有关联dqc,1表示没有关联dqc。

BaselineId Long 1235667

基线ID。

Description String test

节点的描述信息。

NodeName String liux_test_n****

节点的名称。

ResGroupName String 默认资源组

资源组的名称。

DqcDescription String [{"projectName":"ztjy_dim","tableName":"dim_user_agent_manage_area_a","partition":"ds\u003d$[yyyy-mm-dd-1]"}]

DQC分区规则串。

CronExpress String 00 00 00 * * ?

cron表达式。

NodeId Long 125677

节点的ID。

示例

请求示例

http(s)://[Endpoint]/?Action=ListNodesByOutput
&Outputs=aaaaa.1231412_out,bbbb.12313123_out
&ProjectEnv=PROD
&RegionId=cn-shanghai
&<公共请求参数>

正常返回示例

XML格式

HTTP/1.1 200 OK
Content-Type:application/xml

<ListNodesByOutputResponse>
    <RequestId>SDFSDFSDF-asdfDFSDF-SDFSDf-SDfSFD</RequestId>
    <HttpStatusCode>200</HttpStatusCode>
    <Data>
        <Output>test_0709_1.630003556_out</Output>
        <NodeList>
            <BaselineId>1235667</BaselineId>
            <ResGroupName>默认资源组</ResGroupName>
            <Description>test</Description>
            <NodeName>liux_test_n****</NodeName>
            <DqcType>1</DqcType>
            <Priority>1</Priority>
            <ParamValues>a=b</ParamValues>
            <Connection>odps_source</Connection>
            <ProjectId>33671</ProjectId>
            <RelatedFlowId>1235655464</RelatedFlowId>
            <SchedulerType>NORMAL</SchedulerType>
            <CronExpress>00 00 00 * * ?</CronExpress>
            <Repeatability>true</Repeatability>
            <OwnerId>19337906836551</OwnerId>
            <FileType>ODPS_SQL</FileType>
            <DqcDescription>[{"projectName":"ztjy_dim","tableName":"dim_user_agent_manage_area_a","partition":"ds\u003d$[yyyy-mm-dd-1]"}]</DqcDescription>
            <NodeId>125677</NodeId>
            <ProgramType>ODPS_SQL</ProgramType>
            <RepeatInterval>60</RepeatInterval>
        </NodeList>
    </Data>
    <ErrorCode>Invalid.Tenant.ConnectionNotExists</ErrorCode>
    <ErrorMessage>The connection does not exist.</ErrorMessage>
    <Success>true</Success>
</ListNodesByOutputResponse>

JSON格式

HTTP/1.1 200 OK
Content-Type:application/json

{
  "RequestId" : "SDFSDFSDF-asdfDFSDF-SDFSDf-SDfSFD",
  "HttpStatusCode" : 200,
  "Data" : {
    "Output" : "test_0709_1.630003556_out",
    "NodeList" : {
      "BaselineId" : 1235667,
      "ResGroupName" : "默认资源组",
      "Description" : "test",
      "NodeName" : "liux_test_n****",
      "DqcType" : 1,
      "Priority" : 1,
      "ParamValues" : "a=b",
      "Connection" : "odps_source",
      "ProjectId" : 33671,
      "RelatedFlowId" : 1235655464,
      "SchedulerType" : "NORMAL",
      "CronExpress" : "00 00 00 * * ?",
      "Repeatability" : true,
      "OwnerId" : 19337906836551,
      "FileType" : "ODPS_SQL",
      "DqcDescription" : "[{\"projectName\":\"ztjy_dim\",\"tableName\":\"dim_user_agent_manage_area_a\",\"partition\":\"ds\\u003d$[yyyy-mm-dd-1]\"}]",
      "NodeId" : 125677,
      "ProgramType" : "ODPS_SQL",
      "RepeatInterval" : 60
    }
  },
  "ErrorCode" : "Invalid.Tenant.ConnectionNotExists",
  "ErrorMessage" : "The connection does not exist.",
  "Success" : true
}

错误码

访问错误中心查看更多错误码。