[發(fā)明專(zhuān)利]一種物聯(lián)網(wǎng)多租戶(hù)數(shù)據(jù)的管理系統(tǒng)及方法

有效

• 申請(qǐng)?zhí)枺?/td>: 202110039358.5
• 申請(qǐng)日: 2021-01-13
• 公開(kāi)（公告）號(hào): CN112367408B
• 公開(kāi)（公告）日: 2021-08-03
• 發(fā)明（設(shè)計(jì)）人: 鄒磊;潘永高
• 申請(qǐng)（專(zhuān)利權(quán)）人: 樹(shù)根互聯(lián)技術(shù)有限公司
• 主分類(lèi)號(hào): H04L29/08
• 分類(lèi)號(hào): H04L29/08
• 代理公司: 北京超凡宏宇專(zhuān)利代理事務(wù)所(特殊普通合伙) 11463
• 代理人: 李莎

1.一種物聯(lián)網(wǎng)多租戶(hù)數(shù)據(jù)的管理系統(tǒng)，其特征在于，所述管理系統(tǒng)包括預(yù)處理模塊和分布式存儲(chǔ)模塊，所述分布式存儲(chǔ)模塊包括至少兩個(gè)存儲(chǔ)片區(qū)，所述存儲(chǔ)片區(qū)與所述預(yù)處理模塊通信連接，所述預(yù)處理模塊還與租戶(hù)設(shè)備通信連接；

所述預(yù)處理模塊用于提取租戶(hù)數(shù)據(jù)中的租戶(hù)標(biāo)識(shí)，其中，所述租戶(hù)數(shù)據(jù)為所述租戶(hù)設(shè)備上傳至所述預(yù)處理模塊的數(shù)據(jù)；

所述預(yù)處理模塊還用于將所述租戶(hù)數(shù)據(jù)存儲(chǔ)至與所述租戶(hù)標(biāo)識(shí)匹配的存儲(chǔ)片區(qū)；

所述管理系統(tǒng)還包括調(diào)度模塊和統(tǒng)計(jì)存儲(chǔ)模塊，每一個(gè)存儲(chǔ)片區(qū)均與所述調(diào)度模塊通信連接，所述調(diào)度模塊還與所述統(tǒng)計(jì)存儲(chǔ)模塊通信連接，所述統(tǒng)計(jì)存儲(chǔ)模塊與客戶(hù)端通信連接；

所述調(diào)度模塊用于對(duì)每一個(gè)租戶(hù)標(biāo)識(shí)匹配的存儲(chǔ)片區(qū)進(jìn)行業(yè)務(wù)統(tǒng)計(jì)，并將業(yè)務(wù)統(tǒng)計(jì)結(jié)果傳輸至所述統(tǒng)計(jì)存儲(chǔ)模塊，其中，不同的業(yè)務(wù)統(tǒng)計(jì)結(jié)果分別對(duì)應(yīng)不同的租戶(hù)標(biāo)識(shí)；

所述統(tǒng)計(jì)存儲(chǔ)模塊用于存儲(chǔ)所述業(yè)務(wù)統(tǒng)計(jì)結(jié)果，當(dāng)接收到所述客戶(hù)端發(fā)起的統(tǒng)計(jì)查詢(xún)請(qǐng)求時(shí)，向所述客戶(hù)端反饋目標(biāo)查詢(xún)結(jié)果，其中，所述目標(biāo)查詢(xún)結(jié)果為與所述統(tǒng)計(jì)查詢(xún)請(qǐng)求所包含的租戶(hù)標(biāo)識(shí)匹配的業(yè)務(wù)統(tǒng)計(jì)結(jié)果；

所述統(tǒng)計(jì)存儲(chǔ)模塊還用于當(dāng)接收到所述客戶(hù)端發(fā)起的統(tǒng)計(jì)查詢(xún)請(qǐng)求時(shí)，將與所述統(tǒng)計(jì)查詢(xún)請(qǐng)求所包含的租戶(hù)標(biāo)識(shí)匹配的業(yè)務(wù)統(tǒng)計(jì)結(jié)果確定為目標(biāo)查詢(xún)結(jié)果；獲取所述客戶(hù)端的用戶(hù)等級(jí)，依據(jù)所述用戶(hù)等級(jí)過(guò)濾目標(biāo)查詢(xún)結(jié)果；將過(guò)濾后的目標(biāo)查詢(xún)結(jié)果反饋至所述客戶(hù)端；

所述調(diào)度模塊包括數(shù)量大于或等于租戶(hù)標(biāo)識(shí)的總數(shù)的調(diào)度節(jié)點(diǎn)，每一個(gè)調(diào)度節(jié)點(diǎn)分別與至少一個(gè)存儲(chǔ)片區(qū)通信連接；與同一個(gè)調(diào)度節(jié)點(diǎn)通信連接的存儲(chǔ)片區(qū)匹配的租戶(hù)標(biāo)識(shí)相同；每一個(gè)存儲(chǔ)片區(qū)連接N個(gè)調(diào)度節(jié)點(diǎn)，其中，N為大于1的整數(shù)；

所述調(diào)度節(jié)點(diǎn)用于對(duì)連接的存儲(chǔ)片區(qū)進(jìn)行業(yè)務(wù)統(tǒng)計(jì)，并將業(yè)務(wù)統(tǒng)計(jì)結(jié)果傳輸至所述統(tǒng)計(jì)存儲(chǔ)模塊。

2.如權(quán)利要求1所述的物聯(lián)網(wǎng)多租戶(hù)數(shù)據(jù)的管理系統(tǒng)，其特征在于，所述調(diào)度節(jié)點(diǎn)每隔預(yù)設(shè)定時(shí)間從連接的存儲(chǔ)片區(qū)中讀取預(yù)設(shè)定數(shù)量的數(shù)據(jù)。

3.如權(quán)利要求1所述的物聯(lián)網(wǎng)多租戶(hù)數(shù)據(jù)的管理系統(tǒng)，其特征在于，所述調(diào)度節(jié)點(diǎn)與客戶(hù)端通信連接；

所述調(diào)度節(jié)點(diǎn)還用于響應(yīng)客戶(hù)端發(fā)起的調(diào)度指令，并執(zhí)行所述調(diào)度指令。

4.如權(quán)利要求1所述的物聯(lián)網(wǎng)多租戶(hù)數(shù)據(jù)的管理系統(tǒng)，其特征在于，所述預(yù)處理模塊包括：平臺(tái)單元、緩存單元、提取單元以及識(shí)別單元，所述平臺(tái)單元、所述緩存單元、所述提取單元以及所述識(shí)別單元依次通信連接；

所述平臺(tái)單元用于接收所述租戶(hù)設(shè)備上傳租戶(hù)數(shù)據(jù)，并將所述租戶(hù)數(shù)據(jù)異步發(fā)送至所述緩存單元；

所述緩存單元用于對(duì)所述租戶(hù)數(shù)據(jù)進(jìn)行緩存；

所述提取單元用于從所述緩存單元中提取所述租戶(hù)數(shù)據(jù)，并對(duì)所述租戶(hù)數(shù)據(jù)進(jìn)行解析，其中，解析后的租戶(hù)數(shù)據(jù)包含租戶(hù)標(biāo)識(shí)；

所述識(shí)別單元用于提取租戶(hù)數(shù)據(jù)中的租戶(hù)標(biāo)識(shí)；將所述租戶(hù)數(shù)據(jù)存儲(chǔ)至與所述租戶(hù)標(biāo)識(shí)匹配的存儲(chǔ)片區(qū)。

5.如權(quán)利要求1所述的物聯(lián)網(wǎng)多租戶(hù)數(shù)據(jù)的管理系統(tǒng)，其特征在于，所述租戶(hù)標(biāo)識(shí)為租戶(hù)ID。

6.一種物聯(lián)網(wǎng)多租戶(hù)數(shù)據(jù)的管理方法，應(yīng)用于管理系統(tǒng)，其特征在于，所述管理系統(tǒng)包括預(yù)處理模塊和分布式存儲(chǔ)模塊，所述分布式存儲(chǔ)模塊包括至少兩個(gè)存儲(chǔ)片區(qū)，所述存儲(chǔ)片區(qū)與所述預(yù)處理模塊通信連接，所述預(yù)處理模塊還與租戶(hù)設(shè)備通信連接；

所述預(yù)處理模塊提取租戶(hù)數(shù)據(jù)中的租戶(hù)標(biāo)識(shí)，其中，所述租戶(hù)數(shù)據(jù)為所述租戶(hù)設(shè)備上傳至所述預(yù)處理模塊的數(shù)據(jù)；

所述預(yù)處理模塊將所述租戶(hù)數(shù)據(jù)存儲(chǔ)至與所述租戶(hù)標(biāo)識(shí)匹配的存儲(chǔ)片區(qū)；

所述管理系統(tǒng)還包括調(diào)度模塊和統(tǒng)計(jì)存儲(chǔ)模塊，每一個(gè)存儲(chǔ)片區(qū)均與所述調(diào)度模塊通信連接，所述調(diào)度模塊還與所述統(tǒng)計(jì)存儲(chǔ)模塊通信連接，所述統(tǒng)計(jì)存儲(chǔ)模塊與客戶(hù)端通信連接；

所述調(diào)度模塊對(duì)每一個(gè)租戶(hù)標(biāo)識(shí)匹配的存儲(chǔ)片區(qū)進(jìn)行業(yè)務(wù)統(tǒng)計(jì)，并將業(yè)務(wù)統(tǒng)計(jì)結(jié)果傳輸至所述統(tǒng)計(jì)存儲(chǔ)模塊，其中，不同的業(yè)務(wù)統(tǒng)計(jì)結(jié)果分別對(duì)應(yīng)不同的租戶(hù)標(biāo)識(shí)；

所述統(tǒng)計(jì)存儲(chǔ)模塊存儲(chǔ)所述業(yè)務(wù)統(tǒng)計(jì)結(jié)果，當(dāng)接收到所述客戶(hù)端發(fā)起的統(tǒng)計(jì)查詢(xún)請(qǐng)求時(shí)，向所述客戶(hù)端反饋目標(biāo)查詢(xún)結(jié)果，其中，所述目標(biāo)查詢(xún)結(jié)果為與所述統(tǒng)計(jì)查詢(xún)請(qǐng)求所包含的租戶(hù)標(biāo)識(shí)匹配的業(yè)務(wù)統(tǒng)計(jì)結(jié)果；

所述統(tǒng)計(jì)存儲(chǔ)模塊還用于當(dāng)接收到所述客戶(hù)端發(fā)起的統(tǒng)計(jì)查詢(xún)請(qǐng)求時(shí)，將與所述統(tǒng)計(jì)查詢(xún)請(qǐng)求所包含的租戶(hù)標(biāo)識(shí)匹配的業(yè)務(wù)統(tǒng)計(jì)結(jié)果確定為目標(biāo)查詢(xún)結(jié)果；獲取所述客戶(hù)端的用戶(hù)等級(jí)，依據(jù)所述用戶(hù)等級(jí)過(guò)濾目標(biāo)查詢(xún)結(jié)果；將過(guò)濾后的目標(biāo)查詢(xún)結(jié)果反饋至所述客戶(hù)端；

所述調(diào)度模塊包括數(shù)量大于或等于租戶(hù)標(biāo)識(shí)的總數(shù)的調(diào)度節(jié)點(diǎn)，每一個(gè)調(diào)度節(jié)點(diǎn)分別與至少一個(gè)存儲(chǔ)片區(qū)通信連接；與同一個(gè)調(diào)度節(jié)點(diǎn)通信連接的存儲(chǔ)片區(qū)匹配的租戶(hù)標(biāo)識(shí)相同；每一個(gè)存儲(chǔ)片區(qū)連接N個(gè)調(diào)度節(jié)點(diǎn)，其中，N為大于1的整數(shù)；

所述調(diào)度節(jié)點(diǎn)用于對(duì)連接的存儲(chǔ)片區(qū)進(jìn)行業(yè)務(wù)統(tǒng)計(jì)，并將業(yè)務(wù)統(tǒng)計(jì)結(jié)果傳輸至所述統(tǒng)計(jì)存儲(chǔ)模塊。