使用变更源进行实时处理

面向 Azure Storage 的开发

Shahzad Mian

Content developer, Datacamp

Cosmos DB 变更源

• 即时记录数据变更。

什么是变更源？

• 连续的变更流（"事件"）
• 按顺序跟踪插入和更新以供处理

未读邮件

开发者如何使用变更源

拉取模型

• 应用从变更源拉取数据。
• 定期检查是否有新变更。
• 拉取模型＝您控制何时获取与处理变更。

推送模型

• 系统自动推送变更
• 示例：
  • 发生新变更时运行的 CosmosDB 触发器。
• 事件驱动流程。
• 无需轮询更新。
• 推送模型＝系统在变更发生时自动响应。

示例：Azure Function 触发器

变更源架构

租约（Leases）——进度记录。

• 追踪应用已处理的更改。
• 知道下一次从哪里继续。
• 使用方不会遗漏或重复处理事件。

为何使用变更源？

• 适用于系统需对数据变更做出反应。
• 无需人工干预即可运行。
• 连续的数据流。
• 应用即时响应。

使用场景

事件驱动的管道

实时分析

数据同步

下游集成

实时事件源

• 变更源将 Cosmos DB 从被动存储变为实时事件源。
• 构建对数据事件即时响应的应用。
• 无需管理基础设施。

¡Vamos a practicar!

面向 Azure Storage 的开发