4-3 GeaFlow：蚂蚁集团自研流式图计算引擎及其应用.pdf

《4-3 GeaFlow：蚂蚁集团自研流式图计算引擎及其应用.pdf》由会员分享，可在线阅读，更多相关《4-3 GeaFlow：蚂蚁集团自研流式图计算引擎及其应用.pdf（30页珍藏版）》请在三个皮匠报告上搜索。

1、GeaFlow:蚂蚁集团流式图计算引擎及其应用周强 技术专家|01GeaFlow简介简介应用实践应用实践02GeaFlow技术架构技术架构总结和展望总结和展望目录目录CONTENT|0304GeaFlow简介01|什么是图|数据结构之图图是由顶点V集和边E集构成，因此图可以表示成G=(V,E)线、树、环、网等一切实体和关系构成现实之图哥尼斯堡-七桥问题从一起点出发走，可否一次性走过七座桥欧拉回路图的优势|维度的提升比起传统用表的方式存储信息和组织模式图能够很清晰揭示复杂的模式尤其在错综复杂的社交，物流，金融风控行业效果更为明显高效的查询、分析根据给定给的条件，无需加载无关数据更方便自然的数据建

2、模宽表（冗余）关系表（很多外联关系）通过任意类型点表示对象，边表示特定关系灵活的schema以及点边修改图的场景|社交网络加速关系查询，传统的关系型数据库基本无法实现3度关系查询协同推荐根据用户兴趣、好友等进行同类产品推荐相似度算法推荐知识图谱关系挖掘、查找共同根节点、最短路径分析等等金融风控用户行为检测、异常群体发现等传统图计算和实时图计算|图数据库离线图计算在线图存储低延迟简单查询离线图计算静态数据大规模数据集复杂计算实时图计算实时图计算实时关系数据时序增量图计算传统实时计算和实时图计算|关系数据流计算实时分析图数据流图计算实时图分析数据结构升维发展历程|流图融合计算17年研发18年支持双

3、11(支持实时反套现等)仿真能力（18年）基于流图的回溯支持黑商户判定等场景图探索能力（20年-）探索分析支持研判、血缘分析等场景动态时序图能力（20年）增量时序实时计算支持风控团伙挖掘等场景GeaFlow技术架构02|GeaFlow：蚂蚁自研的实时图计算系统|核心特性简洁DSL化研发能力融合融合一体化执行、打造实时图计算多模支持流、图等多种计算模态动态支持分布式动态图GeaFlow整体架构|Hybrid DSL(SQL+Gremlin)基于GraphView的核心API统一的执行计划以图为中心、多种计算模态融合云化的状态管理Task-Based的动态图计算框架Ray(分布式执行引擎)Grap

4、h Store(统一图存储)核心特性：动态计算|动态计算1.数据流和控制流相结合2.从静态DAG走向动态DAG优势1.按需计算，弹性扩缩2.扩宽算力，动态计算SPPUSSISSISSPPUSSISSIS核心特性：融合计算|流图融合计算传统解决思路：流计算+图计算组合计算新思路：流计算+图计算融合计算，打破传统计算的边界优势1.一体化开发2.减低运维成本流图融合计算核心特性：分布式Gremlin|Apache Gremlin是图查询领域事实标准支持子图查询、多度遍历和子图匹配简单易用g.V(1).hasLabel(person).out(knows).out(create).count()创新和

5、突破相对于业界主流的Gremlin Server的方案基于GeaFlow，构建了Gremlin分布式执行的语义核心特性：分布式Gremlin|GremlinServerGremlinServerGremlinServer分布式GeaFlow图任务单个语句仅在一个server上执行构建分布式图迭代任务Gremlin Script核心特性：一体化DSL|SQL Plus(Gremlin)优势1.一体化编程（Streaming SQL+Gremlin）2.降低数据开发门槛核心特性：离线实时一体化|图特征定义图特征上线上线观察持续运行下线30天图特征定义探索分析仿真上线持续运行实时&分析仿真一体化架构

6、针对图仿真进行合理抽象，基于图数据和历史请求进行流式回放，一套架构解决在线和分析仿真两种需求性能大幅提升提供驱动式GC策略，大大减少无效存储基于多级缓存策略，降低图分析RT和提升仿真吞吐应用实践03|金融风控：实时团伙挖掘|账户风险识别基于用户的账号网络进行风控分析，有效识别账户风险反作弊场景黑产作案无法简单通过一度关系进行风险判定，通常需要2-3以上才能做到。通过黑产的聚集性，使用社区划分、社区搜索等算法进行群组挖掘金融风控：实时团伙挖掘特点|构建账号网络金融级基于用户的账号和团伙行为，实时增量构建高可靠金融级账