[發(fā)明專(zhuān)利]一種基于分布式集群的數(shù)據(jù)采集系統(tǒng)及方法

在審

• 申請(qǐng)?zhí)枺?/td>: 201710373026.4
• 申請(qǐng)日: 2017-05-24
• 公開(kāi)（公告）號(hào): CN107222360A
• 公開(kāi)（公告）日: 2017-09-29
• 發(fā)明（設(shè)計(jì)）人: 吳蜀魏
• 申請(qǐng)（專(zhuān)利權(quán)）人: 鄭州云海信息技術(shù)有限公司
• 主分類(lèi)號(hào): H04L12/26
• 分類(lèi)號(hào): H04L12/26;H04L29/08
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司11227
• 代理人: 羅滿(mǎn)

1.一種基于分布式集群的數(shù)據(jù)采集系統(tǒng)，其特征在于，所述系統(tǒng)包括主采集節(jié)點(diǎn)、數(shù)據(jù)解析模塊和多個(gè)子采集節(jié)點(diǎn)；

所述主采集節(jié)點(diǎn)連接多個(gè)所述子采集節(jié)點(diǎn)，所述子采集節(jié)點(diǎn)用于采集數(shù)據(jù)，所述主采集節(jié)點(diǎn)用于接收各個(gè)所述子采集節(jié)點(diǎn)采集的數(shù)據(jù)；

所述數(shù)據(jù)解析模塊用于分別計(jì)算各個(gè)所述子采集節(jié)點(diǎn)采集的數(shù)據(jù)的變化速率；所述數(shù)據(jù)解析模塊根據(jù)所述變化速率調(diào)節(jié)各個(gè)所述子采集節(jié)點(diǎn)的數(shù)據(jù)采集頻率。

2.根據(jù)權(quán)利要求1所述系統(tǒng)，其特征在于，所述數(shù)據(jù)解析模塊為多個(gè)，所述數(shù)據(jù)解析模塊與所述子采集節(jié)點(diǎn)一一對(duì)應(yīng)連接。

3.根據(jù)權(quán)利要求1所述系統(tǒng)，其特征在于，所述數(shù)據(jù)解析模塊為一個(gè)，所述數(shù)據(jù)解析模塊連接每個(gè)所述子采集節(jié)點(diǎn)。

4.根據(jù)權(quán)利要求3所述系統(tǒng)，其特征在于，所述子采集節(jié)點(diǎn)還用于存儲(chǔ)自身當(dāng)前采集數(shù)據(jù)的頻率。

5.根據(jù)權(quán)利要求1至4任一項(xiàng)權(quán)利要求所述系統(tǒng)，其特征在于，所述系統(tǒng)進(jìn)一步包括數(shù)據(jù)庫(kù)配置同步模塊；

所述數(shù)據(jù)庫(kù)配置同步模塊用于向各個(gè)所述子采集節(jié)點(diǎn)采集的數(shù)據(jù)添加統(tǒng)一的時(shí)間坐標(biāo)。

6.一種基于分布式集群的數(shù)據(jù)采集方法，其特征在于，所述方法包括：

數(shù)據(jù)解析模塊獲取子采集節(jié)點(diǎn)采集的數(shù)據(jù)；

所述數(shù)據(jù)解析模塊計(jì)算各個(gè)所述子采集節(jié)點(diǎn)所采集的各組數(shù)據(jù)的變化速率；

所述數(shù)據(jù)解析模塊根據(jù)所述變化速率調(diào)節(jié)各個(gè)所述子采集節(jié)點(diǎn)的數(shù)據(jù)采集頻率，所述子采集節(jié)點(diǎn)將采集的數(shù)據(jù)發(fā)送至主采集節(jié)點(diǎn)。

7.根據(jù)權(quán)利要求6所述方法，其特征在于，所述數(shù)據(jù)解析模塊根據(jù)所述變化速率調(diào)節(jié)所述子采集節(jié)點(diǎn)的數(shù)據(jù)采集頻率包括：

所述數(shù)據(jù)解析模塊根據(jù)所述變化速率和預(yù)先設(shè)定的對(duì)應(yīng)關(guān)系得到所述子采集節(jié)點(diǎn)的理論數(shù)據(jù)采集頻率；

所述數(shù)據(jù)解析模塊將所述數(shù)據(jù)采集頻率調(diào)節(jié)至所述理論數(shù)據(jù)采集頻率。

8.根據(jù)權(quán)利要求6所述方法，其特征在于，所述數(shù)據(jù)解析模塊根據(jù)所述變化速率調(diào)節(jié)所述子采集節(jié)點(diǎn)的數(shù)據(jù)采集頻率包括：

所述數(shù)據(jù)解析模塊判斷所述變化速率是否大于預(yù)先設(shè)定的第一閾值，若是，則降低所述數(shù)據(jù)采集頻率；

所述數(shù)據(jù)解析模塊判斷所述變化速率是否小于預(yù)先設(shè)定的第二閾值，若是，則提高所述數(shù)據(jù)采集頻率。

9.根據(jù)權(quán)利要求6至8任一項(xiàng)權(quán)利要求所述方法，其特征在于，所述方法進(jìn)一步包括：

采用數(shù)據(jù)庫(kù)配置同步模塊向各個(gè)所述子采集節(jié)點(diǎn)采集的數(shù)據(jù)添加統(tǒng)一的時(shí)間坐標(biāo)。