1、易智瑞地理信息系统实时大数据平台：GeoEvent Server1、实时大数据应用场景2、实时大数据接入和输出3、实时大数据分析和展示4、实时大数据平台部署方案主要内容：1、实时大数据应用场景易智瑞地理信息系统实时大数据平台实时GIS的研究对象移动的移动的固定的固定的突发事件突发事件 飞机飞机 车辆车辆 卫星卫星 台风台风 动物动物 水位监测站水位监测站 气象站气象站 流量传感器流量传感器 空气质量传感器空气质量传感器 犯罪事件犯罪事件 雷击事件雷击事件 意外事故意外事故实时大数据典型应用场景Apps桌面APIs分析存储可视化接入分发&响应易智瑞地理信息系统：开启实时能力2、实时大数据的接入和

2、输出将实时大数据引入易智瑞地理信息系统实时大数据接入GeoEvent ServerObservations实时数据处理GeoEventServerGIS Server接入输出GeoEventsFeature等输入实时数据GeoEvent Gallery示例连接器NMEA 0183 海事标准协议Apache Kafka 事件中心Waze 社区化导航ActiveMQ 消息队列开箱即用的输入连接器轮询地图或要素服务轮询一个外部的服务器或REST地址通过HTTP/POST接收数据记录通过TCP/UDP socket接收数据记录订阅一个外部的web socket读取文件系统中改变的文件合作伙伴Galle

3、ry连接器exactEarth 实时卫星AIS服务Valarm 工业物联网传感器CompassLDE 位置数据引擎enviroCar 车辆与环境科学社区通过GeoEvent ManagerGeoEvent Manager或SDKSDK(Java)创建自定义的输入成果:上海巴士通(天津生态城)JT808协议(川大物流)组合 传输&适配器 以配置新的输入连接器InputsOutputsGeoEvent Services自定义连接器Receive Feature-JSON from Kafka连接器接器Receive GeoJSON on a REST endpointKafkaHTTP传输Feat

4、ure-JSONGeoJSON适配器适配器Feature Services传输FileHTTPHTTP+BasicAuthHTTP+OAuthTCPUDPWazeWebSocketEsri GalleryAmazon IoTAzure IoTKafkaIRCMQTTRabbitMQTwitterFeature-JSON适配器适配器GeoJSONJSONRSSTextXMLEsri GalleryCAPCursor-on-TargetGeoMessageInstagramNMEAVMFSierra Wireless(RAP)Trimble(TAIP)TwitterWaze配置输出开箱即用的输出连

5、接器添加或更新要素服务添加或更新时空大数据存储发送要素到流服务推送数据记录到外部网站推送数据记录到外部的websocket通过TCP/UDP socket发送数据记录发送文本、email或即时消息写入本地文件(CSV,JSON,GeoJSON)Gallery组件Amazon IoT 物联网HadoopKafkaMQTT ActiveMQRabbitMQMongoDBTwitter 使用GeoEvent Manager或Java SDK创建自己的自定义输出示例：快速搭建城市犯罪事件实时监控服务3、实时大数据的分析和展示运用实时分析一、GeoEvent Service输入流过滤器和处理器输出流二、

6、实时大数据聚合分析空间、时间、属性 聚合阈值设定详细程度位置监控和警报GeoEventService实时分析实时分析设计位置追踪模拟服务仅在条件表达式评估为TRUE时才允许事件记录通过该表达式可以使用属性或已建立为地理围栏的几何实时分析组件-过滤器您可以使用布尔逻辑（AND，OR，NOT）组合表达式实时分析组件-过滤器-多条件判断 只处理几何 只处理属性 一些响应条件并生成新消息 处理器通常以某种方式转换正在处理的事件记录，如修饰，添加，减去，替换实时分析组件-处理器几何几何缓冲区分析缓冲区分析相交分析相交分析投影转换投影转换字段字段字段计算器字段计算器字段富集器字段富集器字段映射字段映射条件

7、条件连接事件连接事件事件检测事件检测最终间隔检测最终间隔检测输入事件处理器转换后事件-修饰-添加-减去-替换配置过滤器&处理器开箱即用的输出地理处理属性&空间过滤地理标记创建缓冲区事件检测器创建几何凸包相交分析创建空间差异几何投影转换创建多边形边界简化几何字段计算器求对称差字段富集检测事件缺失字段映射合并字段缩减示例附加处理器添加XYZ事件量控制运动计算器范围扇反地理编码服务区创建器跟踪空闲检测器使用GeoEvent Manager或Java SDK创建自己的自定义处理器地理围栏和空间运算符的范围不要将“any”和“all”与用于选择一组地理围栏的规则表达模式混淆空间运算符利用地理围栏进行空间

8、运算 地理围栏Intersectdisjointtouchescontainscrossesequalsoverlapswithininsideoutsideenterexit示例：跟踪与资产追回监控外业人员和资产移动情况实时态势感知遭遇通知跟踪与资产追回实时分析设计实时大数据的展示大数据噪声聚合视图Q:我要在一副地图上看到一百万的地理要素A:没问题，你看吧实时大数据聚合分析时空大数据存储允许你实时聚合动态的数据 用于实时数据的聚合 可以通过空间、时间和属性查询的任意组合进行探索性分析 从聚合视图切换到原始要素视图 不同比例尺下显示不同详细程度实时大数据可视化：动态聚合北京出租车 北美气象站

9、芝加哥犯罪事件Demo 实时大数据动态聚合实时大数据平台部署方案部署性能提升可靠性易智瑞实时大数据平台基本部署EnterpriseGeoEventServer输入输入,分析分析时空大数据data store可视化可视化10K e/s10.6.1+存储存储GeoAnalyticsServer分析分析大数据物联网最低环境每一台服务器和时空大数据存储都必须位于独立的机器上1234易智瑞实时大数据平台优化部署EnterpriseGeoEventServer输入输入,分析分析时空大数据data store可视化可视化10K e/s10.6.1+存储存储GeoAnalyticsServer分析分析大数据物

10、联网优化环境每一台服务器和时空大数据存储都必须位于独立的机器上17652348易智瑞实时大数据平台弹性部署&性能提升EnterpriseGeoEventServer输入输入,分析分析时空大数据data store可视化可视化18K e/s10.6+存储存储GeoAnalyticsServer分析分析大数据物联网弹性架构版本版本10.310.310.410.410.510.510.610.610.6.110.6.110.710.7最大速度2000e/s3000e/s4000e/s6000/s10000e/s10000e/s多机部署自定义X XX X时空大数据存储可靠性节点数=5 分片数=3 副本数=1时空大数据存储可靠性节点数=5 分片数=3 副本数=1从时空大数据存储导出数据到云存储-10.7新增实时数据源和分析 GeoEvent官方文档https:/ Server Galleryhttps:/