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。

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

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

开始

要开始使用所有版本和删除变更源模式，请导航到 Azure Cosmos DB 帐户中的“功能”页面。 选择并启用“所有版本和删除变更源模式（预览）”功能。 在启用该功能之前，必须为 Azure Cosmos DB 帐户配置 连续备份 。 启用过程最长可能需要 30 分钟才能完成，在此期间无法对帐户进行其他更改。

或者，通过使用 REST API 在现有账户上启用所有版本和删除模式的方法是，将"enableAllVersionsAndDeletesChangeFeed" : true添加到properties账户的相关部分。 此属性在预览版 API 或更高版本 2024-12-01-preview 中可用。 不支持在创建帐户期间启用此功能。

分析响应对象

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

• 创建操作

  {
    "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.>,
      "timeToLiveExpired" : <'true' if it was deleted due to a TTL expiration.>,
      "id": "<Id of the deleted item.>",
      "partitionKey": {
        "<Partition key property name>": "<Partition key property value>"
      }
    }
  }
  

局限性

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

• 需要连续备份才可使用此更改源模式。 请参阅 使用连续备份的限制。

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

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

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