CSharpFlink 实时计算引擎,增加 RPC 服务端和客户端,供业务系统调用
更新内容: 1.增加RPC(远程过程调用)的服务端和客户端,供业务系统调用,例如:WEB业务系统。 2.增加计算结果的数据ID设置,在Sink的时候,保存到存储空间,作为计算结果的唯 一标识。 CSharpFlink a real-time computing framework 官方网址 http://www.ineuos.net/ 技术博客 https://www.cnblogs.com/lsjwq/ gitee地址:https://gitee.com/wxzz/CSharpFlink 1 项目背景 我们有一个全国性质的面向工业的公有云平台,通过专线或4G的链路方式实时向平台传输数据,每天处理1亿条左右的数据量,为现场用户提供实时的在线服务和离线数据分析服务。现在已经上线稳定运行有将近3年的时间。同时也为工业企业提供私有云建设服务。 我们计划使用Flink作为云平台后台的实时计算部分,基本实现数据点的聚合计算、表达式规则计算等业务,进一步实现机器学习或自定义复杂算法的需求。 我们经过将近一年左右时间的研究及开发,已经基本实现了聚合和逻辑等业务,但是感觉Flink比较重,并且应用和运...