Azure Cosmos DB 中的更改源模式

最新版本模式提供了一种简单的方法来处理对容器中的项的实时更改和历史更改，能够返回到在容器开头进行的更改。

下面是非常适合此模式的方案：

• 将整个容器迁移到辅助位置。

• 能够重新处理在容器开头进行的更改。

• 实时处理创建和更新操作中发生的对容器中项的更改。

• 工作负荷不需要捕获删除操作或读取期间的中途更改。

所有版本和删除更改源模式启用适用于更改源的新方案，并简化其他方案。 可以读取对项做出的每个更改（即使读取更改源期间发生了多次更改），确定正在处理的更改的操作类型，并获取因删除而发生的更改。

此模式启用和增强的一些常见方案包括：

• 在两个位置之间实时传输数据，而无需实现软删除。

• 如果在更改源轮询之间需要对给定项执行多个更改操作，则基于增量更改触发逻辑。

• 触发有关删除操作的警报，例如在审核场景中。

• 能够根据操作类型以不同的方式处理项的创建、更新和删除操作。

• 更改源包括针对容器中的项所执行的插入和更新操作。

• 此更改源模式不会记录删除操作。 可通过在项中设置“软删除”标志来捕获删除操作，而不是直接删除它们。 例如，可以在项中添加名为“deleted”、值为 true 的属性，然后对项设置生存时间 (TTL)。 更改源将其捕获为更新，并在 TTL 过期时自动删除该项。 此外，也可以使用 TTL 功能为项设置有限的过期时段。 使用此解决方案时，处理更改的时间间隔必须比 TTL 过期时段要短。

• 更改源中仅包含最近对特定项所做的更改。 中间更改可能不可用。

• 删除某个项后，更改源中不再提供该项。

• 可从任意时间点同步更改，并且可用的更改没有固定的数据保持期。

• 无法为特定类型的操作筛选更改源。 一种可能的替代方法是在更新项上添加“软标记”，并在处理更改源中的项时根据该标记进行筛选。

• 读取更改源的起点可以是容器的开头、某个时间点、“现在”或某个特定检查点。 开始时间的精度约为 5 秒。

• 更改源包括针对容器中的项所执行的插入、更新和删除操作。 还会捕获因 TTL 过期而发生的删除操作。

• 可提供元数据来确定更改类型，包括删除操作是否是因 TTL 过期而发生的。

• 更改源项按其修改时间排序。 无法确保项过期后因 TTL 过期而发生的删除操作会立即显示在源中。 从容器中清除项后，会显示这些删除操作。

• 可以读取为帐户上的连续备份的保留时段内发生的所有更改。 尝试读取在保留时段外发生的更改会导致错误。 例如，如果容器是 8 天前创建的，而连续备份保持期为 7 天，则只能读取过去 7 天的更改。

• 更改源的起点可以是“现在”或保持期内的某个特定检查点。 无法使用此模式读取在容器的开头或某个特定时间点进行的更改。

可以使用以下方法在最新版本模式下使用更改源中的更改：

分析响应对象

在最新版本模式下，默认响应对象是已更改的项的数组。 每个项都包含任何 Azure Cosmos DB 项的标准元数据，包括 _etag 和 _ts，并添加了一个新属性 _lsn。

_etag 格式是内部格式，请不要依赖它，因为它随时可能更改。 _ts 是修改或创建时间戳。 可以使用 _ts 进行时间顺序比较。 _lsn 是仅为更改源添加的批 ID，它表示事务 ID。 许多项可能具有相同的 _lsn。

FeedResponse 上的 ETag 不同于项上显示的 _etag。 _etag 是内部标识符，用于并发控制。 _etag 属性表示项的版本，而 ETag 属性用于对源进行排序。

在预览期间，以下用于读取更改源的方法适用于每个客户端 SDK：

入门

若要开始使用所有版本和删除更改源模式，请通过 Azure 订阅概述页面中的预览功能页注册预览版。 搜索“AllVersionsAndDeletesChangeFeed”功能，然后选择“注册”。

提交请求后，请确保订阅中至少有 1 个 Azure Cosmos DB 帐户。 此帐户可能是现有帐户，也可能是你为了试用预览功能而创建的新帐户。 如果收到请求时你在订阅中没有帐户，则会拒绝请求，因为没有可应用功能的帐户。

Azure Cosmos DB 团队将审核你的请求并通过电子邮件与你联系，以确认订阅中要注册预览版的 Azure Cosmos DB 帐户。 若要使用预览版，必须为 Azure Cosmos DB 帐户配置连续备份。 连续备份可以在允许进入预览版之前或之后启用，但尝试在所有版本和删除模式下读取更改源中的内容之前，必须启用连续备份。

分析响应对象

响应对象是表示每项更改的项数组。 将根据更改类型填充不同的属性。 目前无法获取用于替换或删除操作的以前版本的项。

• 创建操作

  {
    "current": {
      <The current version of the item that changed. All the properties of your item will appear here.>
    },
    "metadata": {
      "operationType": "create",
      "lsn": <A number that represents the batch ID. Many items can have the same lsn.>,
      "crts": <A number that represents the Conflict Resolved Timestamp. It has the same format as _ts.>
    }
  }
  

• 替换操作

  {
    "current": {
      <The current version of the item that changed. All the properties of your item will appear here.>
    },
    "metadata": {
      "operationType": "replace",
      "lsn": <A number that represents the batch ID. Many items can have the same lsn.>,
      "crts": <A number that represents the Conflict Resolved Timestamp. It has the same format as _ts.>,
      "previousImageLSN" : <A number that represents the batch ID of the change prior to this one.>,
    }
  }
  

• 删除操作

  {
    "metadata": {
      "operationType": "delete",
      "lsn": <A number that represents the batch ID. Many items can have the same lsn.>,
      "crts": <A number that represents the Conflict Resolved Timestamp. It has the same format as _ts.>,
      "previousImageLSN" : <A number that represents the batch ID of the change prior to this one.>,
      "id": "<Id of the deleted item.>",
      "partitionKey": {
        "<Partition key property name>": "<Partition key property value>"
      }
    }
  }
  

限制

• 支持 Azure Cosmos DB for NoSQL 帐户。 不支持其他 Azure Cosmos DB 帐户类型。

• 需要连续备份才能使用此更改源模式。 有关使用连续备份的限制，请参阅文档。

• 不支持读取在帐户上启用连续备份之前存在的对容器的更改。

• 目前不支持从头开始读取更改源或根据过去的时间戳选择开始时间。 可以从“现在”开始读取，也可以从之前的租用时间或延续令牌开始读取。

• 当前无法接收已删除或更新的项的以前版本。

• 不支持已启用合并分区的帐户。