[發明專利]一種基于NiFi實現定時監控接口程序運行狀態的方法和裝置

在審

• 申請號: 202111507532.0
• 申請日: 2021-12-10
• 公開（公告）號: CN114168424A
• 公開（公告）日: 2022-03-11
• 發明（設計）人: 吳志雄;張婉如;林雪紅
• 申請（專利權）人: 南威軟件股份有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30
• 代理公司: 泉州市文華專利代理有限公司 35205
• 代理人: 陳雪瑩

1.一種基于NiFi實現定時監控接口程序運行狀態的方法，其特征在于，包括：監控任務表配置過程以及程序監控過程；

所述監控任務表配置過程包括：根據待監控的接口通過關系型數據庫配置監控任務表，所述監控任務表包括主鍵、檢測時間、檢測參數、檢測方法、請求鏈接、結果狀態、結果代碼、結果信息以及檢測協議字段；

所述程序監控過程包括：定時從所述監控任務表獲取待監控的請求接口數據，所述待監控的請求接口數據包括主鍵、檢測參數、檢測方法、請求鏈接以及檢測協議；根據所述待監控的請求接口數據分別對各接口發送請求，檢測各接口程序的運行狀態是否正常，將返回結果的接口的結果狀態、結果代碼、結果信息、檢測時間根據對應的主鍵更新所述監控任務表，用于后期查看和維護。

2.根據權利要求1所述的方法，其特征在于：通過QueryDatabaseTable組件從所述監控任務表獲取待監控的請求接口數據，通過所述QueryDatabaseTable組件設置SchedulingStrategy屬性為CRON driven，用于定時查詢檢測接口程序運行狀態。

3.根據權利要求1所述的方法，其特征在于：所述程序監控過程中，從所述監控任務表獲取待監控的請求接口數據，具體為：先通過ConvertAvroToJSON組件配置JSON containeroptions屬性為array，處理多條數據需選擇array；然后通過SplitJson組件配置確定JSON對象的輸出表達式，將一個JSON對象拆分為多個單獨的JSON對象，對流進行數據格式處理；接著通過EvaluateJsonPath組件自定義上游傳遞值，取出需要的字段添加到屬性列表提供給下游取值。

4.根據權利要求1所述的方法，其特征在于：所述檢測協議字段包括http或者https；所述程序監控過程中，根據所述待監控的請求接口數據分別對各接口發送請求，當檢測協議字段為http時，直接使用InvokeHTTP組件配置Remote URL、HTTP Method對http協議的接口發送請求，當檢測協議字段為https時，通過InvokeHTTPS自定義組件配置Remote URL、HTTPMethod、Params對https協議的接口發送請求。

5.根據權利要求1所述的方法，其特征在于：所述程序監控過程中，將返回結果的接口的結果狀態、結果代碼、結果信息以及檢測時間根據對應的主鍵更新所述監控任務表，具體為：通過UpdateAttribute組件將返回結果的接口的結果狀態、結果代碼、結果信息、檢測時間拼接成sql，然后根據對應的主鍵通過PutSQL組件更新所述監控任務表的檢測時間、結果狀態、結果代碼以及結果信息。

6.一種基于NiFi實現定時監控接口程序運行狀態的裝置，其特征在于，包括：監控任務表配置模塊以及程序監控模塊；

所述監控任務表配置模塊，用于根據待監控的接口通過關系型數據庫配置監控任務表，所述監控任務表包括主鍵、檢測時間、檢測參數、檢測方法、請求鏈接、結果狀態、結果代碼、結果信息以及檢測協議字段；

所述程序監控模塊，用于從所述監控任務表獲取待監控的請求接口數據，所述待監控的請求接口數據包括主鍵、檢測參數、檢測方法、請求鏈接以及檢測協議；根據所述待監控的請求接口數據分別對各接口發送請求，檢測各接口程序的運行狀態是否正常，將返回結果的接口的結果狀態、結果代碼、結果信息、檢測時間根據對應的主鍵更新所述監控任務表，用于后期查看和維護。

7.根據權利要求6所述的裝置，其特征在于：所述程序監控模塊中，通過QueryDatabaseTable組件從所述監控任務表獲取待監控的請求接口數據，通過所述QueryDatabaseTable組件設置Scheduling Strategy屬性為CRON driven，用于定時查詢檢測接口程序運行狀態。