[發明專利]針對大規模數據庫集群的安全態勢感知分析技術及系統

在審

• 申請號: 202010713576.8
• 申請日: 2020-07-22
• 公開（公告）號: CN112035828A
• 公開（公告）日: 2020-12-04
• 發明（設計）人: 唐更新;張洪林;趙衛國;宋輝
• 申請（專利權）人: 北京中安星云軟件技術有限公司
• 主分類號: G06F21/55
• 分類號: G06F21/55;G06F21/62
• 代理公司: 北京魚爪知識產權代理有限公司 11754
• 代理人: 曹治麗

1.一種針對大規模數據庫集群的安全態勢感知分析技術，其特征在于，包括如下步驟：

對數據庫通信數據包進行抓包；

對抓取的數據包進行數據流量解析；

將解析結果發送到實時流處理引擎進行處理和特征提取得到實時信息；

消息隊列緩沖及轉發實時信息；

接收實時信息并存儲在分布式數倉；

對實時信息進行分布式計算；

將計算結果分發到主題數據庫存儲；

拉取主題數據庫的計算結果進行BI分析展示。

2.如權利要求1所述的一種針對大規模數據庫集群的安全態勢感知分析技術，其特征在于，所述對數據庫通信數據包進行抓包包括：

通過網卡接收到數據流對數據包進行重組，重組后對TCP/IP報文進行解析提取數據庫通訊協議信息，解析數據庫通訊協議提取SQL語句，將所述SQL語句轉發。

3.如權利要求1所述的一種針對大規模數據庫集群的安全態勢感知分析技術，其特征在于，所述對抓取的數據包進行數據流量解析包括：

接收數據之后對SQL進行流處理，對流數據進行清洗和轉換；

對特征進行數據預處理，對信息進行打標簽。

4.如權利要求1所述的一種針對大規模數據庫集群的安全態勢感知分析技術，其特征在于，所述將解析結果發送到實時流處理引擎進行處理和特征提取出實時信息包括：

接收到標簽數據之后提取特征。

5.如權利要求1所述的一種針對大規模數據庫集群的安全態勢感知分析技術，其特征在于，所述消息隊列緩沖及轉發實時信息包括：

通過kafka接收實時信息并通過內存緩沖機制將所述實時信息進行定時轉發。

6.如權利要求1所述的一種針對大規模數據庫集群的安全態勢感知分析技術，其特征在于，所述接收實時信息并存儲在分布式數倉包括:

由ArgoDB分布式數據庫來承擔數據存儲任務，將Kafka轉發過來的信息以二維表的方式進行固化存儲。

7.如權利要求1所述的一種針對大規模數據庫集群的安全態勢感知分析技術，其特征在于，所述進行分布式計算包括：

通過Spark分布式計算引擎承擔計算任務，由內置策略引擎調度算法交由Spark來進行計算并將計算結果進行轉發。

8.如權利要求1所述的一種針對大規模數據庫集群的安全態勢感知分析技術，其特征在于，所述將計算結果分發到主題數據庫存儲包括：

將計算結果存儲在內存中，并按照設定好的條件生成多維度表。

9.如權利要求1所述的一種針對大規模數據庫集群的安全態勢感知分析技術，其特征在于，所述拉取主題數據庫的計算結果進行BI分析展示包括：

通過Pilot引擎可以將計算LOAP數據庫中的多維表進行快速檢索和可視化展示。

10.一種針對大規模數據庫集群的安全態勢感知分析系統，其特征在于，包括：日志采集模塊和安全態勢分析模塊；

所述日志采集模塊實現數據庫安全日志的采集和轉發，包括如下子模塊：

數據包抓解析子模塊，用于對數據庫通信數據包進行抓包；

實時流處理子模塊，用于對抓取的數據包進行數據流量解析；

特征提取子模塊，用于將解析結果發送到實時流處理引擎進行處理和特征提取得到實時信息；

消息隊列緩沖及轉發子模塊，用于通過消息隊列緩沖及轉發實時信息；

所述安全態勢分析模塊實現日志的分析和展示，包括如下子模塊：

分布式數據倉庫子模塊，用于接收實時信息并存儲在分布式數倉；

分布式計算子模塊，用于對實時信息進行分布式計算；

LOAP數據庫子模塊，用于將計算結果分發到主題數據庫存儲；

BI分析子模塊，用于通過拉取主題數據庫的計算結果進行BI分析展示。