近期,Apache Flink开源项目背后的公司Ververica发布了一个新的框架——Stateful Functions,旨在将Flink扩展到分布式的有状态应用程序中。

Stateful Functions是一组工具,旨在让开发人员能够创建以现代无服务器方式运行的有状态应用程序。该软件为开发人员提供了一组有状态函数(以此得名),而该软件运行在Flink的分布式数据处理引擎之上。

Apache Flink已经成为一个领先的流处理框架,它为开发人员提供了丰富的功能,以构建分布式、事件驱动的应用程序。希望对事件做出响应的组织,例如一个人进行购买或一个传感器在登录尝试检测峰值时,最好选择Flink或类似的框架来构建应用程序。

然而,这些Flink应用程序在大多数情况下以无状态的方式运行。虽然Flink确实提供了一些允许开发人员使用状态的功能,但是开发人员使用它们可以实现的功能是有限制的。

Ververica公司表示,旨在克服这些限制的Stateful Functions“使用户能够使用少量资源定义松耦合的、独立的功能, 在一个共享资源池中可以持续交互而且是可靠的。”Ververica联合创始人兼首席技术官Stephan Ewen和该公司产品营销经理Marta Paes在博客上写道。

该公司表示,Stateful Functions背后的API是基于“封装业务逻辑的小函数性片段,有点类似于actors”。每个实体通常有一个函数(例如一个用户或一个库存项)。“每个函数在局部变量中都有持久的用户定义状态,并且可以任意地向其他函数(包括它自己。)发送严格的一次保证消息。”Ewen和Paes写道。

当开发人员需要维护到实体的有状态连接,但又不想放弃事件驱动的体系结构的好处或脱离函数即服务(function as a service, FaaS)的开发风格时,这个新库是一个不错的选择。新的Stateful Functions方法并非为了替代无状态计算,而是在需要这两种方法时提供了新的前进路径。

Ververica表示,Stateful Functions都是在状态之上计算,而不是从状态之中计算。“这个模型的主要优点是状态和计算共存于网络的同一侧,这意味着您不需要往返每个记录去从外部存储系统获取状态(例如Cassandra,DynamoDB),也不是为了一致性的具体状态管理模式 (例如事件溯源、CQRS)。” Ewen和Paes写道。

00900

Stateful Functions扩展了Flink,能够将有状态计算概念与Flink分布式的、无服务器的范例合并在一起

该公司表示,另外一个优势在于无需管理动态消息和维护复杂的复制或重分区策略。其中,持久性是通过为快照保持与对象存储的连接来实现的。新的方法还为实时流处理和离线批处理提供了高吞吐量,“允许您对事件驱动的应用程序和通用数据处理之间的界限进行模糊。”该公司表示。

Ververica在于德国柏林举行的Flink Forward大会上宣布了这一消息。今年早些时候,这家公司被阿里巴巴收购,目前正在以Apache 2.0的许可协议发布这款软件。

“在Kubernetes和FaaS等技术的推动下,无状态计算的编配已经取得了长足的进步,但大多数产品仍然无法满足有状态分布式应用的需求。始终如一地处理状态并在服务之间可靠地交互,这对整体开发的易用性构成了重大挑战。” Ewen 在一篇新闻稿中指出,“Stateful Functions是解决这些缺点的重要一步,提供了无缝的状态管理和一致性。”

【凡本网注明来源非中国IDC圈的作品,均转载自其它媒体,目的在于传递更多信息,并不代表本网赞同其观点和对其真实性负责。】

关注中国IDC圈官方微信:idc-quan 我们将定期推送IDC产业最新资讯

查看心情排行你看到此篇文章的感受是:


  • 支持

  • 高兴

  • 震惊

  • 愤怒

  • 无聊

  • 无奈

  • 谎言

  • 枪稿

  • 不解

  • 标题党
2019-07-04 18:22:04
大数据技术 从单体到Flink:一文读懂数据架构的演变
大数据技术的兴起,让企业能够更加灵活高效地使用自己的业务数据,从数据中提取出更多重要的价值,并将数据分析和挖掘出来的结果应用在企业的决策、营销、管理等应用领域。 <详情>
2019-07-03 17:10:46
云资讯 2019云计算开源产业大会丨刘天栋:Apache之道 从孵化器到顶级项目之路
大家下午好!我是开源社理事长,现在是Apache的成员、孵化器项目委员会成员/项目导师。今天介绍三方面的内容: <详情>
2019-06-05 12:19:06
国内资讯 2019大数据产业峰会|阿里云郭华:从Flink看大数据实时变化
从两个角度看,流处理具有延迟比较低,实施计算的能力。综合这两方面,流处理能够做到秒级亚秒级的延迟,所以叫做大数据实时化的引擎。 <详情>
2019-01-09 12:01:41
云资讯 开年第一单!阿里花7亿收购了一家怎样的公司?
中国IDC圈讯 1月8日,彭博社消息称,阿里巴巴收购了位于德国柏林的数据处理公司Data Artisans。另据外媒报道,此次交易金额为1.033亿美元(9000万欧元),Data Artisans <详情>
2019-01-08 11:48:00
国内资讯 阿里携手data Artisans推动Flink开源生态
中国IDC圈讯 1月8日,彭博社消息称,阿里巴巴收购了位于德国柏林的数据处理公司Data Artisans。另据外媒报道,此次交易金额为1.033亿美元(9000万欧元),Data Artisans <详情>