IBM MQ输入

1.1 版本

1.2 應用場景

使用者需要實時讀取 IBM MQ 中的資料，將資料解析後，寫入指定資料庫中，並使用資料進行報表和實時企業戰情室製作和展示。

1.3 功能簡介

FineDataLink 的「資料開發-實時任務」支援使用「IBM MQ輸入」算子實時讀取資料。

1.4 功能限制

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

「IBM MQ輸入」算子設定介面如下圖所示：

各設定項說明如下：

3.1 IBM MQ輸入算子讀取資料

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

自訂位置和名稱後，點選進入實時任務設計頁面。如下圖所示：

2）拖入「IBM MQ輸入」算子，選擇資料源，設定 Topic 和匯出欄位。如下圖所示：

點選「資料預覽」，可預覽資料：

取出的資料為 JSON 格式資料。

3.2 解析資料

1）拖入「JSON解析」算子，解析 3.1 節取出的資料。如下圖所示：

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

3.3 資料匯出

拖入「DB表匯出」算子，將資料匯出至指定的資料庫中。如下圖所示：

DB表匯出設定詳情參見：DB表输出（实时任务）

寫入方式預設即可。

3.4 任務啟動和管理

點選「啟動」按鈕，即可啟動實時任務，如下圖所示：

可在 任務管理界面 看到任務運作狀態和運作詳情。