獲取Rest Client算子返回值教程
更新時間 2023-07-21 00:31:14
最近更新時間: 2023-07-21 00:31:14
分享文章
本章節主要介紹DataArts Studio的獲取Rest Client算子返回值操作。
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

