[發明專利]數據處理方法、裝置及計算機可讀存儲介質

在審

• 申請號: 202110013898.6
• 申請日: 2021-01-06
• 公開（公告）號: CN112765166A
• 公開（公告）日: 2021-05-07
• 發明（設計）人: 陳泉
• 申請（專利權）人: 深圳市歡太科技有限公司;OPPO廣東移動通信有限公司
• 主分類號: G06F16/22
• 分類號: G06F16/22;G06F16/23;G06F16/25
• 代理公司: 北京恒博知識產權代理有限公司 11528
• 代理人: 范勝祥

本申請公開了一種數據處理方法、裝置及計算機可讀存儲介質。該數據處理方法包括獲取業務數據流，并獲取用于處理業務數據流的Flink SQL任務；獲取Flink SQL任務中的業務配置參數，并將業務配置參數寫入至數據庫中；將數據庫與業務數據流進行維表關聯，生成處理數據。本申請可在應用Flink SQL處理數據時將更改或新增的業務配置參數保存在可與Flink SQL進行維表關聯的數據庫中，以使Flink SQL在無需重新啟動的情況下實時使用業務配置參數。

技術領域

本申請涉及計算機技術領域，特別的涉及一種數據處理方法、裝置及計算機可讀存儲介質。

背景技術

隨著軟件程序功能的日益復雜，程序的配置也越來越多，如各種數據庫配置、應用配置、服務器配置等，但是往往在實際使用過程中如果能夠支持動態配置的話，應用就會顯得更加靈活可控。

現有的動態配置方式一般包括兩種，其一是在啟動或者停止程序的過程中，通過啟停腳本，傳遞配置參數到程序中，實現對配置參數的使用，以達到動態配置的效果，但這種方式需要多次重新啟動程序。其二是通過配置管理中心工具實時獲取更新的配置參數，并直接將更新的配置參數加載于正在運行的程序中，這種方式雖然不需要停止程序，但在應用Flink SQL處理數據時無法加載配置參數，進而導致無法動態更新配置參數。

發明內容

本申請實施例提供了一種數據處理方法、裝置及計算機可讀存儲介質，可在應用Flink SQL處理數據時使用業務動態配置參數。

第一方面，本申請實施例提供了一種數據處理方法，包括：

獲取業務數據流，并獲取用于處理業務數據流的Flink SQL任務；

獲取Flink SQL任務中的業務配置參數，并將業務配置參數寫入至數據庫中；

將數據庫與業務數據流進行維表關聯，生成處理數據。

第二方面，本申請實施例提供了一種數據處理裝置，包括：

獲取模塊，用于獲取業務數據流，并獲取用于處理業務數據流的Flink SQL任務；

第一處理模塊，用于獲取Flink SQL任務中的業務配置參數，并將業務配置參數寫入至數據庫中；

第二處理模塊，用于將數據庫與業務數據流進行維表關聯，生成處理數據。

第三方面，本申請實施例又提供了一種數據處理裝置，包括處理器、存儲器以及通信接口；

處理器與存儲器、通信接口相連；

存儲器，用于存儲可執行程序代碼；

處理器通過讀取存儲器中存儲的可執行程序代碼來運行與可執行程序代碼對應的程序，以用于執行本申請實施例第一方面實現方式提供的數據處理方法。

第四方面，本申請實施例提供了一種計算機可讀存儲介質，計算機存儲介質存儲有計算機程序，計算機程序包括程序指令，程序指令當被處理器執行時，可實現本申請實施例第一方面實現方式提供的數據處理方法。

第五方面，本申請實施例提供了一種計算機程序產品，當該計算機程序產品在數據處理裝置上運行時，使得該數據處理裝置執行本申請實施例第一方面實現方式提供的數據處理方法。

在本申請實施例中，通過獲取業務數據流，并獲取用于處理業務數據流的FlinkSQL任務，然后獲取Flink SQL任務中的業務配置參數，并將業務配置參數寫入至數據庫中，進而將數據庫與業務數據流進行維表關聯，生成處理數據。可在應用Flink SQL處理數據時將更改或新增的業務配置參數保存在可與Flink SQL進行維表關聯的數據庫中，以使FlinkSQL在無需重新啟動的情況下實時加載業務配置參數。

附圖說明