?

AbutionGraph是一款端到端的流式數(shù)據(jù)實(shí)時(shí)分析的圖譜數(shù)據(jù)庫(kù)，實(shí)時(shí)（流式寫入實(shí)時(shí)、高QPS決策分析實(shí)時(shí)、流式預(yù)處理實(shí)時(shí)）表現(xiàn)在：

1. 構(gòu)建實(shí)時(shí)查詢QPS響應(yīng)時(shí)長(zhǎng)與歷史數(shù)據(jù)量無(wú)關(guān)的圖模型；
2. 接入流式數(shù)據(jù)并實(shí)時(shí)更新圖計(jì)算指標(biāo)；
3. 實(shí)時(shí)查詢歷史和時(shí)序窗口聚合的數(shù)據(jù)。

AbutionGraph具有多種數(shù)據(jù)庫(kù)的特性，除傳統(tǒng)圖譜數(shù)據(jù)存儲(chǔ)模型外，Abution的目標(biāo)是以足夠低的延遲（亞秒級(jí)）來(lái)服務(wù)大規(guī)模圖譜數(shù)據(jù)（達(dá)BP級(jí)）的實(shí)時(shí)決策分析。 AbutionGraph特別適用于業(yè)務(wù)指標(biāo)系統(tǒng)建設(shè)、實(shí)時(shí)交互式數(shù)據(jù)分析、可視化大屏展現(xiàn)、IOT流式數(shù)據(jù)監(jiān)測(cè)、拓?fù)鋽?shù)據(jù)動(dòng)態(tài)行為計(jì)算、相同點(diǎn)邊id的數(shù)據(jù)根據(jù)標(biāo)簽分類管理等等。 AbutionGraph使用Java/C++開(kāi)發(fā)，支持Aremlin、Gremlin、GraphQL查詢語(yǔ)法，并支持與Java進(jìn)行混合編程開(kāi)發(fā)和Python API。

AbutionGraph特性：

分布式企業(yè)級(jí)圖數(shù)據(jù)庫(kù)，提供圖數(shù)據(jù)的實(shí)時(shí)-存儲(chǔ)、查詢和OLAP分析能力，主要面向?qū)?strong>局部數(shù)據(jù)的海量并發(fā)查詢和全量數(shù)據(jù)的實(shí)時(shí)在線計(jì)算/更新/監(jiān)控。
用于大數(shù)據(jù)量高吞吐率和低延遲的同時(shí)，實(shí)時(shí)反饋數(shù)據(jù)態(tài)勢(shì)變化（異常）情況，保障決策分析業(yè)務(wù)7*24小時(shí)在線運(yùn)行。

支持功能	AbutionGraph	Neo4j	TigerGraph
分布式	√	X	√
RDF圖模型	√	X	X
屬性圖模型	√	√	√
實(shí)時(shí)增刪查改	√	√	√
TB級(jí)大容量	√	√	√
高性能批量導(dǎo)入	√	√	√
點(diǎn)邊檢索、全文檢索	√	√	√
千萬(wàn)頂點(diǎn)/秒的高吞吐率	√	√	√
對(duì)接流式數(shù)據(jù)源、關(guān)系型數(shù)據(jù)源	√	√	√
圖分析算法	√	√	√
高可用性支持	√	√	√
圖譜可視化工具	√	√	√
讀寫任務(wù)內(nèi)高效并行存儲(chǔ)）	√	√	√
在線/離線、全量/增量的備份恢復(fù)	√	√	√
多圖（大圖與多個(gè)子圖）	√	√	√
豐富的離線圖算法	√	√	√
	-	-	-
單獨(dú)刪除點(diǎn)邊（支持獨(dú)立點(diǎn)/邊存儲(chǔ)）	√	X	X
動(dòng)態(tài)新增/隱藏字段	√	X	X
時(shí)間窗口計(jì)算（流式數(shù)據(jù)庫(kù)的標(biāo)志特性）	√	X	X
實(shí)時(shí)大數(shù)據(jù)流式圖 存儲(chǔ)/計(jì)算/更新	√	X	X
多重/多維圖關(guān)系（每對(duì)點(diǎn)間都允許多種不同標(biāo)簽的邊共存）	√	X	X
多重/多維圖實(shí)體（每個(gè)點(diǎn)上都允許多種不同標(biāo)簽的點(diǎn)共存）	√	X	X
動(dòng)圖-時(shí)序關(guān)系聚合（根據(jù)年月日等時(shí)間窗口-自動(dòng)合并邊屬性）	√	X	X
動(dòng)圖-時(shí)序?qū)嶓w聚合（根據(jù)年月日等時(shí)間窗口-自動(dòng)合并點(diǎn)屬性）	√	X	X
導(dǎo)出圖數(shù)據(jù)到大數(shù)據(jù)平臺(tái)繼續(xù)計(jì)算（Spark/Flink/Hadoop等。 對(duì)接AI算法作為特征工程庫(kù)，實(shí)時(shí)更新模型指標(biāo)，實(shí)時(shí)取用）	√	X	X
子圖隔離（原子級(jí)用戶權(quán)限管理）	√	X	X
分布式圖實(shí)例	√	X	X
節(jié)點(diǎn)模糊查詢	√	X	X
自定義節(jié)點(diǎn)類型	√	X	X
圖數(shù)據(jù)庫(kù)專家支持服務(wù)	√	X	X

AbutionGraph適用：

1. 交互式數(shù)據(jù)分析
   希望快速?gòu)拇笠?guī)模歷史數(shù)據(jù)中得出統(tǒng)計(jì)分析報(bào)告用于決策，數(shù)據(jù)探索-秒內(nèi)響應(yīng)、年月日時(shí)間窗口分析-秒內(nèi)響應(yīng)等。
2. 流式數(shù)據(jù)監(jiān)控
   希望從實(shí)時(shí)源源不斷產(chǎn)生數(shù)據(jù)的iot/應(yīng)用程序中立即反映趨勢(shì)，態(tài)勢(shì)感知、實(shí)時(shí)聚合計(jì)算、時(shí)序指標(biāo)變化規(guī)律等。
3. 多維數(shù)據(jù)管理
   希望將同一個(gè)id-人身份證等，綁定上工商/稅務(wù)/車房產(chǎn)/銀行/通話等不同結(jié)構(gòu)的數(shù)據(jù)，并通過(guò)設(shè)定標(biāo)簽識(shí)別類別數(shù)據(jù)，實(shí)現(xiàn)高效管理與查詢。
4. 圖譜關(guān)聯(lián)計(jì)算
   希望導(dǎo)入的實(shí)體與關(guān)系自動(dòng)實(shí)現(xiàn)關(guān)聯(lián)，而不是明確“點(diǎn)表/邊表”必須一一具備，允許孤立點(diǎn)。此外，希望自動(dòng)匯總一跳鄰居節(jié)點(diǎn)信息如：出度入度、基數(shù)統(tǒng)計(jì)、百分位數(shù)等，實(shí)現(xiàn)復(fù)雜關(guān)聯(lián)指標(biāo)的即席查詢。
5. 子圖隔離
   希望在一個(gè)圖譜中實(shí)現(xiàn)不同用戶導(dǎo)入的數(shù)據(jù)僅自己可見(jiàn)，或授權(quán)可見(jiàn)，很適用于公安、政府、跨部門、多用戶協(xié)作等場(chǎng)景。

及一切希望在亞秒實(shí)現(xiàn)關(guān)聯(lián)數(shù)據(jù)分析的場(chǎng)景 - 執(zhí)行查詢即所得、數(shù)據(jù)寫入即見(jiàn)變化，類似于Kafka、Flink、Kylin等系統(tǒng)，不過(guò)Abuion旨在關(guān)聯(lián)計(jì)算上彌補(bǔ)缺陷，所以它更擅長(zhǎng)處理關(guān)聯(lián)分析問(wèn)題，且比傳統(tǒng)圖數(shù)據(jù)庫(kù)更節(jié)省計(jì)算資源和響應(yīng)時(shí)間。?視頻介紹

Abution GraphInstance?

GraphInstance是連接到一個(gè)AbutionGraph的操作，是執(zhí)行查詢語(yǔ)句的入口。相當(dāng)于傳統(tǒng)數(shù)據(jù)庫(kù)連接，您可以使用g.*.exec(user)去執(zhí)行一系列的圖查詢。

• 圖實(shí)例有3種使用方式：
  1. Graph - 本地圖實(shí)例連接，用于生產(chǎn)環(huán)境，只能在裝有Abution的節(jié)點(diǎn)運(yùn)行，可運(yùn)行所有功能；
  2. TmpGraph - 臨時(shí)圖實(shí)例連接，用于代碼測(cè)試，無(wú)需部署Abution，數(shù)據(jù)即存即刪，是一個(gè)臨時(shí)內(nèi)存圖，算法功能不可用；
  3. MemoryGraph- 分布式緩存圖實(shí)例連接，該階段還是實(shí)驗(yàn)性的，未經(jīng)大規(guī)模項(xiàng)目驗(yàn)證；
  4. RemoteGraph - 遠(yuǎn)程圖實(shí)例連接，用于遠(yuǎn)程代碼調(diào)試，IDEA中提交代碼至服務(wù)器運(yùn)行，UDF能力請(qǐng)使用Graph實(shí)例運(yùn)行。

1）Graph實(shí)例

Graph graph = G.Graph("graphId").schema(schema).build();g.addOrUpdate(); //保存元數(shù)據(jù)Graph graph = G.GetGraph("graphId"); //從已有圖譜中快速初始化圖實(shí)例

注意：
graphId、schema是必須提交的參數(shù)。
addOrUpdate為更新和保存元數(shù)據(jù)。

2）TmpGraph實(shí)例

TmpGraph實(shí)例采用java緩存保存數(shù)據(jù)，并不會(huì)持久化數(shù)據(jù)，當(dāng)程序運(yùn)行結(jié)束，數(shù)據(jù)將在內(nèi)存中被清空，占用內(nèi)存也隨之釋放。此實(shí)例本意是方便開(kāi)發(fā)調(diào)試，并不適用于大規(guī)模數(shù)據(jù)。

  Graph graph = G.TmpGraph(schema);

Ps：臨時(shí)初始化實(shí)例無(wú)需數(shù)據(jù)庫(kù)配置參數(shù)，只需schema定義，不走數(shù)據(jù)庫(kù)，只使用緩存，程序停止數(shù)據(jù)即清空。因?yàn)槭桥R時(shí)圖存儲(chǔ)，復(fù)雜的生產(chǎn)場(chǎng)景一般不用，所以一些算法功能沒(méi)有單獨(dú)開(kāi)發(fā)出來(lái)。

3）MemoryGraph實(shí)例

MemoryGraph實(shí)例采用分布式緩存作為數(shù)據(jù)持久化層，開(kāi)啟集群后將使用聯(lián)邦集群的可用內(nèi)存作為圖數(shù)據(jù)存儲(chǔ)，您可以在集群本地運(yùn)行測(cè)試程序，也可以通過(guò)ip端口遠(yuǎn)程驗(yàn)證您的邏輯代碼。當(dāng)您關(guān)閉AbutionGraph集群后，數(shù)據(jù)將在內(nèi)存中被清空，占用內(nèi)存也隨之釋放。

3個(gè)必填參數(shù)（圖譜名稱、Schema、遠(yuǎn)程服務(wù)器端口）

Graph g = G.MemoryGraph("tgMemory1", schema, "127.0.0.1:5701");
// 保存元數(shù)據(jù)，以便可視化實(shí)時(shí)可見(jiàn)
g.addOrUpdate();

4）遠(yuǎn)程/跨集群連接圖實(shí)例

此功能允許在任何網(wǎng)絡(luò)連通的機(jī)器使用AbutionGDB中的數(shù)據(jù)，無(wú)需在開(kāi)發(fā)者本地部署AbutionGraph，前提是已開(kāi)啟AbutionGRS數(shù)據(jù)中臺(tái)服務(wù)，你可以直接在IDEA中編寫代碼，讀取本地?cái)?shù)據(jù)，使用遠(yuǎn)程服務(wù)器運(yùn)行你的代碼，返回的結(jié)果數(shù)據(jù)就像是本地的Java對(duì)象一樣。

Graph graph = G.GraphProxy.Builder()//.graphId("testGraph")  //可選參數(shù),不填寫則做多圖知識(shí)融合查詢.host("thutmose-aliyun") //改成數(shù)據(jù)庫(kù)服務(wù)器ip.port(9090).contextRoot("rest").build();

GraphProxy在數(shù)據(jù)整合、數(shù)據(jù)遷移和項(xiàng)目開(kāi)發(fā)調(diào)試階段非常有用，如在IDEA中即可連接到云端服務(wù)并調(diào)試，它使大數(shù)據(jù)工程師的本地代碼得以在云端運(yùn)行，我們?cè)谖磥?lái)的版本中會(huì)不斷升級(jí)它，使圖數(shù)據(jù)庫(kù)更具有云服務(wù)的特性。 注意：此功能為定制化業(yè)務(wù)平臺(tái)專用，為方便代碼調(diào)試，算法功能不可用。