[發(fā)明專利]數(shù)據(jù)特征提取方法、裝置、計(jì)算機(jī)設(shè)備以及存儲(chǔ)介質(zhì)

在審

• 申請(qǐng)?zhí)枺?/td>: 201910036799.2
• 申請(qǐng)日: 2019-01-15
• 公開（公告）號(hào): CN111435356A
• 公開（公告）日: 2020-07-21
• 發(fā)明（設(shè)計(jì)）人: 胡健超
• 申請(qǐng)（專利權(quán)）人: 杭州海康威視數(shù)字技術(shù)股份有限公司
• 主分類號(hào): G06F16/25
• 分類號(hào): G06F16/25;G06F9/54;G06F9/50
• 代理公司: 北京三高永信知識(shí)產(chǎn)權(quán)代理有限責(zé)任公司 11138
• 代理人: 李珂珂

1.一種數(shù)據(jù)特征提取方法，其特征在于，所述方法包括：

從開源流處理平臺(tái)中獲取數(shù)據(jù)流，將所述數(shù)據(jù)流中的各個(gè)數(shù)據(jù)存儲(chǔ)至數(shù)據(jù)隊(duì)列中，每個(gè)數(shù)據(jù)攜帶類型標(biāo)識(shí)，所述類型標(biāo)識(shí)用于指示數(shù)據(jù)類型；

按照所述數(shù)據(jù)隊(duì)列中的存儲(chǔ)順序，從所述數(shù)據(jù)隊(duì)列中獲取待進(jìn)行特征提取的數(shù)據(jù)；

每獲取到一個(gè)數(shù)據(jù)時(shí)，基于所述數(shù)據(jù)的類型標(biāo)識(shí)，獲取至少一個(gè)目標(biāo)模型，該類型標(biāo)識(shí)對(duì)應(yīng)至少一個(gè)目標(biāo)模型；

將所述數(shù)據(jù)輸入至所述至少一個(gè)目標(biāo)模型中，得到至少一個(gè)第一特征，一個(gè)第一特征與一個(gè)目標(biāo)模型對(duì)應(yīng)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述將所述數(shù)據(jù)輸入至所述至少一個(gè)目標(biāo)模型中，得到至少一個(gè)第一特征，包括：

根據(jù)所述數(shù)據(jù)的類型標(biāo)識(shí)，對(duì)數(shù)據(jù)庫(kù)中所述至少一個(gè)目標(biāo)模型的第二特征進(jìn)行加鎖，所述第二特征為上一次模型運(yùn)算過(guò)程中所產(chǎn)生的特征；

將所述數(shù)據(jù)以及每個(gè)第二特征輸入至對(duì)應(yīng)的目標(biāo)模型，得到至少一個(gè)第一特征；

將所述至少一個(gè)第一特征存儲(chǔ)在所述數(shù)據(jù)庫(kù)中；

釋放所述數(shù)據(jù)庫(kù)中每個(gè)第二特征的鎖。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述方法還包括：

當(dāng)從所述數(shù)據(jù)庫(kù)中獲取不到所述至少一個(gè)目標(biāo)模型的第二特征時(shí)，持續(xù)獲取所述至少一個(gè)目標(biāo)模型的第二特征；

當(dāng)在預(yù)設(shè)次數(shù)內(nèi)獲取到所述至少一個(gè)目標(biāo)模型的第二特征時(shí)，將所述數(shù)據(jù)以及每個(gè)第二特征輸入至對(duì)應(yīng)的目標(biāo)模型，得到至少一個(gè)第一特征，當(dāng)在預(yù)設(shè)次數(shù)內(nèi)獲取不到所述至少一個(gè)目標(biāo)模型的第二特征時(shí)，丟棄所述數(shù)據(jù)，獲取所述數(shù)據(jù)隊(duì)列中的下一個(gè)數(shù)據(jù)。

4.根據(jù)權(quán)利要求2所述的方法，其特征在于，所述將所述至少一個(gè)第一特征存儲(chǔ)在所述數(shù)據(jù)庫(kù)中，包括：

通過(guò)封裝接口，根據(jù)數(shù)據(jù)輸出接口的輸出協(xié)議，封裝所述至少一個(gè)第一特征；

通過(guò)所述數(shù)據(jù)輸出接口，將所述至少一個(gè)第一特征存儲(chǔ)在數(shù)據(jù)庫(kù)中。

5.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

訂閱模型消息，所述模型消息包括更新標(biāo)識(shí)，所述更新標(biāo)識(shí)用于指示更新指示緩存區(qū)中的模型；

當(dāng)接收到所述模型消息后，根據(jù)所述模型消息中的更新標(biāo)識(shí)，更新所述緩存區(qū)中的模型。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，所述根據(jù)所述模型消息中的更新標(biāo)識(shí)，更新所述緩存區(qū)中的模型，包括下述至少一項(xiàng)：

當(dāng)所述模型消息中的更新標(biāo)識(shí)為刪除標(biāo)識(shí)時(shí)，刪除所述緩存區(qū)中與所述刪除標(biāo)識(shí)對(duì)應(yīng)的模型；

當(dāng)所述模型消息中的更新標(biāo)識(shí)為增加標(biāo)識(shí)時(shí)，將所述增加標(biāo)識(shí)指示的模型存儲(chǔ)至緩存區(qū)中；

當(dāng)所述模型消息中的更新標(biāo)識(shí)為替換標(biāo)識(shí)時(shí)，將所述緩存區(qū)中與所述替換標(biāo)識(shí)對(duì)應(yīng)的模型替換為所述替換標(biāo)識(shí)指示的模型。

7.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述從開源流處理平臺(tái)中獲取數(shù)據(jù)流，將所述數(shù)據(jù)流中的各個(gè)數(shù)據(jù)存儲(chǔ)至數(shù)據(jù)隊(duì)列中，包括：

啟動(dòng)數(shù)據(jù)接收服務(wù)，所述數(shù)據(jù)接收服務(wù)用于從開源流處理平臺(tái)接收數(shù)據(jù)流；

接收數(shù)據(jù)流；

當(dāng)數(shù)據(jù)隊(duì)列中的數(shù)據(jù)未滿時(shí)，將所述數(shù)據(jù)流中的各個(gè)數(shù)據(jù)寫入到所述數(shù)據(jù)隊(duì)列中。

8.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述從開源流處理平臺(tái)中獲取數(shù)據(jù)流之前，所述方法還包括：

獲取第一資源配置文件，所述第一資源配置文件存儲(chǔ)有開源流處理平臺(tái)的地址以及第一類型標(biāo)識(shí)，所述第一類型標(biāo)識(shí)用于指示數(shù)據(jù)類型；

解析所述第一資源配置文件，得到所述開源流處理平臺(tái)的地址以及類型標(biāo)識(shí)；

根據(jù)所述開源流處理平臺(tái)的地址，與所述開源流處理平臺(tái)建立連接；

當(dāng)與所述開源流處理平臺(tái)連接成功時(shí)，啟動(dòng)數(shù)據(jù)拉取線程，將所述數(shù)據(jù)拉取線程的狀態(tài)設(shè)置為阻塞狀態(tài)。