Apache Flink - 使用案例



本章我们将了解 Apache Flink 中的一些测试用例。

Apache Flink − 布依格电信

布依格电信是法国最大的电信公司之一。它拥有超过1100万移动用户和超过250万固定用户。布依格电信在巴黎举行的 Hadoop 集团会议上第一次听说 Apache Flink。从那时起,他们就开始将 Flink 用于多种用例。他们每天通过 Apache Flink 实时处理数十亿条消息。

以下是布依格电信对 Apache Flink 的评价:“我们最终选择 Flink 是因为该系统支持真正的流处理——无论是在 API 级别还是在运行时级别,都为我们提供了我们正在寻找的可编程性和低延迟。此外,与其他解决方案相比,我们能够在很短的时间内让我们的系统运行 Flink,这使得我们可以将更多可用的开发资源用于扩展系统中的业务逻辑。”

在布依格电信,客户体验是最高优先级。他们实时分析数据,以便能够为他们的工程师提供以下见解:

  • 通过其网络的实时客户体验

  • 网络上的全球事件

  • 网络评估和运营

他们创建了一个名为 LUX(Logged User Experience,登录用户体验)的系统,该系统处理来自网络设备的大量日志数据以及内部数据引用,以提供体验质量指标,这些指标将记录其客户体验并构建警报功能,以便在 60 秒内检测数据使用中的任何故障。

为了实现这一点,他们需要一个能够实时处理海量数据、易于设置并提供丰富的 API 来处理流数据的框架。Apache Flink 非常适合布依格电信。

Apache Flink − 阿里巴巴

阿里巴巴是全球最大的电子商务零售公司,2015 年营收达 3940 亿美元。阿里巴巴搜索是所有客户的入口点,它显示所有搜索结果并相应地推荐。

阿里巴巴在其搜索引擎中使用 Apache Flink,以便为每个用户实时显示具有最高准确性和相关性的结果。

阿里巴巴正在寻找一个具有以下特点的框架:

  • 在维护其整个搜索基础设施流程的单个代码库方面非常敏捷。

  • 为网站上产品的可用性变化提供低延迟。

  • 一致且经济高效。

Apache Flink 满足了上述所有要求。他们需要一个具有单个处理引擎的框架,并且可以使用相同的引擎处理批处理和流数据,而这就是 Apache Flink 所做的。

他们还使用 Blink(Flink 的一个分支版本)来满足其搜索的一些独特需求。他们还在使用 Apache Flink 的 Table API,并对其进行了一些改进以用于搜索。

以下是阿里巴巴对 Apache Flink 的评价:“回想起来,对于阿里巴巴的 Blink 和 Flink 来说,这无疑是巨大的一年。没有人认为我们会在一年内取得如此大的进展,我们非常感谢社区中所有帮助我们的人。Flink 已被证明可以在非常大规模的应用中工作。我们比以往任何时候都更加致力于继续与社区合作,推动 Flink 的发展!”

广告
© . All rights reserved.