随着网络技术及传感设备的发展,物联网技术日趋成熟,其蕴含的巨大潜力逐渐显现出来,各个行业开始尝试结合物联网技术进行产业升级。由于不同行业在业务流程上存在较大差异,业务本身也必然伴随行业的发展而快速增长,而传统物联网开发模式对于代码的变更通常需要把完整的软件包重新发布至物联网服务器,灵活性和开发效率较低,因此难以满足日益增长的应用需求。为了解决上述问题,本文设计并实现了星环科技物联网平台Sophon Edge的时序处理系统。该系统的主要目的是辅助用户对业务流程进行建模,抽象出数据处理规则对输入平台的时序数据进行处理,并将处理结果输出到平台数据服务子系统进行存储、展示或转发到外部系统。系统提供通用的基础算子库以减少重复工作,保证场景应用的快速开发;允许用户自定义函数,在一定程度上保证系统的灵活性和扩展性;支持以容器为载体管理应用和函数服务,降低系统的部署难度。本系统使用Go语言作为开发语言,基于go-micro框架实现微服务架构,使用Docker容器作为微服务载体,使用Kapacitor框架作为时序处理引擎,基于FaaS技术实现服务定制化功能。系统主要分为三个模块:负责轻量级部署、提供请求分发负载功能的服务治理模块;负责支持用户自定义函数的函数管理模块;负责制定数据处理规则及执行处理任务的规则管理模块。目前平台凭借易用、可扩展的特性获得了客户的一致好评,成功助推了多个智慧工地、智慧监狱、智慧加油站项目的落地。