WebSocket輸入

1.1 版本

1.2 應用場景

物網路連結資料是透過 WebSocket 協定開放的，希望實時任務讀取 WebSocket 資料。

1.3 功能簡介

資料開發-實時任務中，新增「WebSocket 輸入」算子，支援讀取 WebSocket 資料。如下圖所示：

1.4 功能限制

5.0.1.5 及之後版本，實時任務中若使用「WebSocket 輸入」節點，不能再使用  分組匯總（實時任務）、Flink SQL、維度表輸入&資料聯動（多個實時資料源進行聯動）。

1）需要先配置 WebSocket資料連結

2）「WebSocket 輸入」算子介面如下圖所示：

實時任務中讀取 WebSocket 資料，經過 JSON 解析後，匯出到資料庫表中。

注：需要先配置 WebSocket資料連結

3.1 WebSocket 輸入

1）進入 FineDataLink 工程，點選「資料開發>實時任務」，建立實時任務。如下圖所示：

2）進入編輯頁面後，拖入「WebSocket 輸入」算子，讀取 WebSocket 資料。如下圖所示：

點選「資料預覽」，如下圖所示：

3.2 JSON 解析

拖入「JSON 解析」算子，解析 WebSocket 資料。如下圖所示：

點選「資料預覽」，如下圖所示：

3.3 資料匯出

拖入「DB表匯出」算子，將處理後的資料匯出。如下圖所示：

3.4 啟動任務

點選右上角的「啟動」按鈕，啟動實時任務。啟動後介面如下圖所示：