什么是事件流处理？

事件流处理 是对连续事件流的处理或分析。事件流处理平台在传入数据时处理入站数据。它针对高速流数据执行超快、连续的计算，并使用连续查询引擎来驱动实时警报、操作以及用户配置的 可视化 。

事件被定义为如交易或浏览您网站的情景等状态的变化。事件本质上是企业系统中捕获的数据点。事件流是按时间排序的一系列业务事件。在任何企业中，客户不断购买、致电帮助台或在在源源不断的日常事件中填满自己的购物车。

事件流处理主动跟踪和处理企业中的事件流，以便主动识别机会和风险并优化业务成果。存储分析法的传统数据处理方法引入了决策延迟的根本挑战。信息一旦被捕获，通常是最具相关性的，并且事件处理帮助组织更及时地处理这些信息。它帮助解决许多问题：在发生欺诈时识别欺诈、在客户仍在商店中时提供情境优惠，或预测中断以最大限度地减少延迟。由于需要实时处理数据，事件处理变得越来越重要。

事件流 vs 事件流处理 vs 事件处理

事件流处理常常与 “事件流” 这个术语混淆。但是，事件流只是指有效地将事件数据从一个地方移动到另一个地方的过程，以便其他系统可以轻松访问和分析它。Apache Kafka 是事件流工具的一个很好的例子。因此，事件流是事件流处理操作的一部分。事件处理和事件流处理之间也有区别。事件处理一次查看单个事件，而事件流处理一起处理许多相关事件。事件处理就像看单独的一滴水一样。事件流处理就像把手指放在流动的水龙头下查看水的温度。

为什么选择事件流处理？

在新兴的数字世界中，数十亿人、物体和设备实时互动，组织必须创造新的颠覆性竞争优势，以提高收入和效率。这是新的数字业务。

实时数据智能是确保企业成功的最佳方法之一。企业希望能够对关键的业务时刻做出实时反应，并且在当今实时启用系统的世界中，传统的数据处理已不再可行。因为收集信息、将其存储在关系数据库或 Hadoop 集群中，然后每天、每周或按选定的时间间隔进行分析为时已晚。企业需要对流式数据运行查询，以发现有意义的事件，让他们有机会自动执行决策和行动，从而实时响应。企业需要实时反应，甚至需要主动的方法来保持竞争力。

当我们谈论响应事件的操作时，该事件可能意味着调用应用程序、启动流程、将数据存储在持久性账本中或将数据流式传输到仪表板。这将带来更高程度的自动化，并能够在事件发生时利用这些事件。此外，利用机器学习作为选项，您不仅可以确定下一个最佳行动，还可以不断学习和改进业务规则。

为了使当今的业务信息具有真正意义，您需要通过实时处理这些事件来识别隐藏在这些事件中的机会和威胁，从而获得见解并采取适当的行动。为了从日常业务交易中获得竞争优势，您可以将组织转变为启用事件的企业。使用事件流处理应用程序，您可以识别业务事件中隐藏的机会和威胁，并积极主动地采取行动。它提供了连接性、可扩展性和速度，从大量快速移动的数据中提取可操作的实时情报–使您能够快速捕获、分析和应对对您的企业具有重要意义的趋势、机遇和风险，并采取行动。

事件流处理如何运作？

事件流处理可以使大量数据以极快的速度进入您的业务，从而帮助确定重要内容，以便您可以自动化流程并实时响应重要事件。事件处理程序实时聚合来自分布式系统的信息，应用揭示关键模式、关系或趋势的规则。通过事件流处理，您可以连接到所有数据源，并对数据进行规范化、丰富和筛选。然后，您可以开始关联事件，随着时间的推移，您会看到描述您关注事件的模式出现。

成功事件流处理的关键是实时处理事件以确定下一个最佳行动。在持续循环中学习和改进。

事件流处理平台可满足数字业务的需求，允许您：

• 从各种来源收集数据
• 了解这些数据的含义及其上下文
• 识别关键业务时刻并采取行动

事件流处理的能力

在事件发生之前进行预测

集中式收集：事件流传送到事件分发环境中，并立即进行分析和记录（如有必要）。

噪音过滤：适配器过滤应处理的内容，而不是相反，并可以监听来自某些域或渠道的消息。他们还可能在整个环境中标准化事件格式。

内存中处理：事件不是在数据到达数据库后进行分析，而是使用内存中的数据网格实时处理事件。这不仅使您能够关联关系并从更多的数据中检测有意义的模式，还可以更快、更高效地执行此操作。

扩展缓存：事件历史可以在内存中存放任意长时间（对于长时间运行的事件序列至关重要），也可以记录为存储数据库中的交易。

行动

高级测试：通过将事件与已在内存中循环的事件进行比较，预定义参数设置术语来衡量事件的重要性和含义，并在需要时查询历史数据集。支持所有主要的比较技术，包括事件是否在预计时间范围内发生。

业务规则：如果检测到匹配，业务规则将确定是否需要执行行动，并在需要时触发适当的响应。

复合事件：如果分层组合是其他规则正在搜索的内容，则还可以创建一个新事件，并将其作为消息发布回事件分发环境以供发现。

了解历史模式

通过事件流处理，您可以了解历史模式。过去的机会和风险可能会在一段时间内重复（负面的客户体验、车队到达延迟、欺诈性交易）。通过识别造成事件的模式，您可以跟踪和预测接下来何时会发生这些事件。

动态序列

通过事件流处理，您还可以监控意外模式。考虑到情况变化的速度–以及随着业务速度的加快这种频率将增加的可能性–您可以获得对正在发展的事物有价值的见解，并解读其上下文意义。

事件流处理提供了一个分布式、有状态的、基于规则的事件处理系统，其支持即时决策和即时操作。通过事件流处理，您可以关联和查找大量数据中的重要事件，最大限度地减少决策延迟，并立即做出响应以带来良好的业务成果。为了保持竞争力，企业必须考虑利用实时情报来增强传统商业智能或大数据战略。如今，企业需要快速处理已定义的事件并快速更新流程，以创造收入机会、削减成本并最大限度地降低风险。