上云无忧 > 文档中心 > 天翼云数据治理中心 DataArts Studio 数据开发使用教程 - 获取Rest Client算子返回值教程
数据治理中心 DataArts Studio
天翼云数据治理中心 DataArts Studio 数据开发使用教程 - 获取Rest Client算子返回值教程

文档简介:
本章节主要介绍DataArts Studio的获取Rest Client算子返回值操作。 Rest Client算子可以执行RESTful请求。 本教程主要介绍如何获取Rest Client的返回值,包含以下两个使用场景举例。 通过“响应消息体解析为传递参数定义”获取返回值。 通过EL表达式获取返回值。
*产品来源:中国电信天翼云。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠

Rest Client算子可以执行RESTful请求。

本教程主要介绍如何获取Rest Client的返回值,包含以下两个使用场景举例。

  • 通过“响应消息体解析为传递参数定义”获取返回值。
  • 通过EL表达式获取返回值。

通过“响应消息体解析为传递参数定义”获取返回值

如下图所示,第一个Rest Client调用了MRS服务查询集群列表的API,下图为API返回值的JSON消息体。

  • 使用场景:需要获取集群列表中第一个集群的cluster Id,然后作为参数传递给后面的节点使用。
  • 关键配置:在第一个Rest Client的“响应消息体解析为传递参数定义”配置中,配置clusterId=clusters[0].clusterId,后续的Rest Client节点就可以用${clusterId}的方式引用到集群列表中的第一个集群的cluster Id。

Rest Clien作业样例1

JSON消息体

通过EL表达式获取返回值

Rest Client算子可与EL表达式相配合,根据具体的场景选择不同的EL表达式来实现更丰富的用法。您可以参考本教程,根据您的实际业务需要,开发您自己的作业。EL表达式用法可参考表达式概述。

如下图所示,Rest Client调用了MRS服务查询集群列表的API,然后执行Kafka Client发送消息。

  • 使用场景:Kafka Client发送字符串消息,消息内容为集群列表中第一个集群的cluster Id。
  • 关键配置:在Kafka Client中使用如下EL表达式获取Rest API返回消息体中的特定字段:
#{JSONUtil.toString(JSONUtil.path(Job.getNodeOutput("Rest_Client_4901"),"clusters[0].clusterId"))}复制

Rest Client作业样例2

相似文档
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部