GIS云套件

流数据处理

GIS云套件支持流数据处理,流数据有实时、大量、多源、持续等特点。基于Spark Streaming分布式实时计算框架,GIS云套件流数据服务支持通过WebSocket协议、TCP协议、HTTP协议以及Kafka专用通讯协议接入实时数据(数据格式包括CSV、JSON、GeoJSON),并对接入的实时数据进行过滤、分析、处理,再将处理后的实时数据以CSV、JSON、GeoJSON格式输出或存储。

操作流程如下图所示。第一步,制作流处理模型。流处理模型由接收器、过滤器、转换器、发送器组成,接收器用于业务数据接入,过滤器与转换器用于GIS分析,发送器用于结果数据输出。流处理模型制作完成后可保存至列表中,支持查看模型配置,对已有模型再次编辑并发布,或删除模型。第二步,发布流处理模型。开启内置(或外接)Spark,将流处理模型发布为流数据服务。

streamingProcess