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

调试

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

请求参数

名称 类型 是否必选 示例值 描述
Action String ListNodesByOutput

要执行的操作。

Outputs String aaaaa.1231412_out,bbbb.12313123_out

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

ProjectEnv String PROD

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

RegionId String cn-shanghai

地域信息,通常为服务所在的地域。例如,华东2(上海)为cn-shanghai,华北3(张家口)为cn-zhangjiakou。您无需填写RegionId,会根据调用的Endpoint自动解析。

返回数据

名称 类型 示例值 描述
Data Array of OutputNodePair

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

NodeList Array of Node

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

BaselineId Long 1235667

基线ID。

Connection String odps_first

数据源名称。

CronExpress String 00 00 00 * * ?

cron表达式。

Description String test

节点的描述信息。

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

DQC分区规则串。

DqcType Integer 1

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

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

NodeId Long 125677

节点的ID。

NodeName String liux_test_n****

节点的名称。

OwnerId String 19337906836551

负责人的ID。

ParamValues String a=b

节点的调度参数。

Priority Integer 1

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

ProgramType String ODPS_SQL

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

ProjectId Long 33671

工作空间的ID。

RelatedFlowId Long 1235655464

关联的业务流程ID。

RepeatInterval Integer 60

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

Repeatability Boolean true

是否可以重复运行。

ResGroupName String 默认资源组

资源组的名称。

SchedulerType String NORMAL

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

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

当前节点的输出名称。

ErrorCode String Invalid.Tenant.ConnectionNotExists

错误码。

ErrorMessage String The connection does not exist.

错误信息。

HttpStatusCode Integer 200

HTTP状态码。

RequestId String SDFSDFSDF-asdfDFSDF-SDFSDf-SDfSFD

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

Success Boolean true

调用是否成功。

示例

请求示例

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

正常返回示例

XML格式

<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_first</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>

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_first",
            "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
}

错误码

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