文档

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

更新时间:

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

调试

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

授权信息

当前API暂无授权信息透出。

请求参数

名称类型必填描述示例值
ProjectEnvstring

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

PROD
Outputsstring

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

aaaaa.1231412_out,bbbb.12313123_out

返回参数

名称类型描述示例值
object
HttpStatusCodeinteger

HTTP 状态码。

200
RequestIdstring

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

SDFSDFSDF-asdfDFSDF-SDFSDf-SDfSFD
ErrorMessagestring

错误信息。

The connection does not exist.
ErrorCodestring

错误码。

Invalid.Tenant.ConnectionNotExists
Successboolean

调用是否成功。

true
Dataobject []

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

Outputstring

当前节点的输出名称。

test_0709_1.630003556_out
NodeListobject []

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

SchedulerTypestring

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

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

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

60
Repeatabilityboolean

是否可以重复运行。

true
FileTypestring

节点的类型。 常用的节点类型如下:

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

ODPS_SQL
ProjectIdlong

工作空间的 ID。

33671
ProgramTypestring

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

ODPS_SQL
Priorityinteger

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

1
OwnerIdstring

负责人的 ID。

19337906836551
Connectionstring

数据源名称。

odps_source
ParamValuesstring

节点的调度参数。

a=b
RelatedFlowIdlong

关联的业务流程 ID。

1235655464
DqcTypeinteger

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

1
BaselineIdlong

基线 ID。

1235667
Descriptionstring

节点的描述信息。

test
NodeNamestring

节点的名称。

liux_test_n****
ResGroupNamestring

资源组的名称。

默认资源组
DqcDescriptionstring

DQC 分区规则串。

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

cron 表达式。

00 00 00 * * ?
NodeIdlong

节点的 ID。

125677

示例

正常返回示例

JSON格式

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

错误码

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

变更历史

变更时间变更内容概要操作
暂无变更历史
  • 本页导读 (1)