Spring Cloud

Spring Cloud Data Flow 介紹

陳冠丞 Lio Chen 2021/10/08 09:10:48
1790

前言

      建立微服務通常遇到的問題是如何將其組合及應用及管理,而Spring Cloud Data Flow提供工具來為Streaming和Batch數據管道創建複雜的拓撲。數據管道由Spring Boot應用程序組成使用Spring Cloud Stream或Spring Cloud Task的微服務架構

這裡要示範如何使用GUI介面就能設定及執行。

 

一、服務設定

      Spring Cloud Data Flow是基於雲端架構,可部署在Cloud Foundry、Kubernetes,基於方便示範使用的是本機方式執行

首先下載下列程式

https://repo1.maven.org/maven2/org/springframework/cloud/spring-cloud-dataflow-server/2.8.1/spring-cloud-dataflow-server-2.8.1.jar

https://repo1.maven.org/maven2/org/springframework/cloud/spring-cloud-skipper-server/2.7.1/spring-cloud-skipper-server-2.7.1.jar

先執行skipper

java -jar spring-cloud-skipper-server-2.7.1.jar

執行輸入網址http://localhost:7577/api出現下面畫面

再執行dataflow-server

java -jar spring-cloud-dataflow-server-2.8.1.jar

執行輸入網址http://localhost:9393/dashboard/出現下面畫面

這樣Server就可以開始使用了

 

二、範例應用

      Spring Cloud Data Flow 有提供範例程式,可以匯入使用

點選ADD APPLICTION(S)後打開Import application starters from dataflow.spring.io.選擇Task application starters for Maven匯入

會匯入三個task appliction

接下來就是建立一個task

選擇Tasks按下CREATE TASK按鈕

出現建立TASK畫面


拖曳timestamp並將節點拉好

結果如下

按下CREATE TASK並輸入建立task的名稱及描述

按下CREATE THE TASK

點擊名稱test進入Task明細

按LAUNCH TASK進入執行平台參數及程式參數設定

設定好按LAUNCH TASK執行

Task的執行訊息

按VIEW LOG就可以本次執行的LOG

也可以設定複雜的task如下

三、結論

      本次示範的只有簡單的Task執行,Spring Cloud Data Flow的功能像是可以用DSL設定Flowe會專屬及Streaming設定及佈署上Cloud Foundry、Kubernetes等多項功能,等待去研究使用

 

參考連結

  Spring Cloud Data Flow 官網介紹

 

 

陳冠丞 Lio Chen