如何获取Azure Cosmos DB触发器事件的原生递增时间戳

可以直接获取Cosmos DB侧生成的原生保序时间戳/序列号，完全不需要在函数内自行取DateTime.Now，也不会出现执行延迟导致的时序错乱问题。

核心逻辑 #

Cosmos DB变更源本身携带两类服务端原生生成的保序标识，值在文档写入完成时就已固定，和函数执行时机、调度延迟、重试逻辑完全无关：

• 文档自带_ts系统属性：文档写入/更新时服务端生成的Unix秒级时间戳，同分区内单调递增
• 逻辑序列号（LSN）：分区内严格单调递增的数字标识，保序精度高于时间戳，不会出现同一秒多个写入的顺序混淆问题

具体实现 #

不需要给CosmosDBTrigger特性加任何额外配置，只需要调整函数入参的类型定义，就能拿到这些原生元数据。

方案1：获取原生服务端时间戳 #

给你的DbModel类增加_ts字段的映射，触发器不需要改其他配置，直接就能拿到每个变更项的服务端时间：

public class DbModel
{
    // 原有业务字段
    public string Id { get; set; }
    // ... 其余你的自定义业务字段

    // 映射Cosmos DB内置_ts系统字段
    [JsonProperty("_ts")]
    public long ServerUnixTimestamp { get; set; }
}

拿到时间戳后可以直接转成DateTime格式使用：

DateTime eventOccurTime = DateTimeOffset.FromUnixTimeSeconds(model.ServerUnixTimestamp).UtcDateTime;

这个值是Cosmos DB服务端写入时生成的，不会因为函数执行排队、延迟出现后触发的事件时间戳更小的问题。

方案2：获取严格保序的LSN（推荐用于高精度排序场景） #

如果你需要100%严格的分区内事件顺序，避免同一秒多个写入导致时间戳重复无法排序的问题，可以把入参类型替换为IReadOnlyList<ChangeFeedItem<DbModel>>，直接从变更项头信息里拿到原生LSN：

[FunctionName("CosmosTrigger")]
public static void Run([CosmosDBTrigger(
    databaseName: "DbTesting",
    containerName: "test",
    Connection  = "CosmosDBConnection",
    LeaseContainerName  = "test_leases",
    CreateLeaseContainerIfNotExists  = true,
    FeedPollDelay = 1000)]
    IReadOnlyList<ChangeFeedItem<DbModel>> modifiedItems,
    ILogger log) 
{
    foreach (var item in modifiedItems)
    {
        // 分区内严格单调递增的LSN，保序精度最高
        var partitionLsn = item.Headers.GetValue("lsn");
        // 同时也能拿到服务端时间戳
        var eventTime = DateTimeOffset.FromUnixTimeSeconds(item.Current.ServerUnixTimestamp).UtcDateTime;
        
        // 将LSN/时间戳随业务消息一起推送到Storage Queue即可
    }
}

注意：上述两个保序标识都是单个分区内单调递增，如果你的容器配置了多个分区，跨分区的事件不存在全局绝对顺序，排序时需要结合分区ID+LSN/时间戳判断，这是Cosmos DB分布式架构的固有特性，不存在全局统一顺序。

内容的提问来源于stack exchange，提问作者Miloš Selečéni