如何在Cosmos DB中将自定义字段设置为服务器当前时间？

Cosmos DB没有SQL里直接用NOW()赋值的语法，但可以通过预触发器或者存储过程实现服务器端自动设置自定义字段的当前时间，完全不依赖客户端时间。

核心思路 #

用服务器端执行的脚本（触发器/存储过程）在插入文档时，自动给指定字段赋值服务器当前时间，彻底规避客户端时间同步不准的问题。

C# 实现示例 #

1. 创建预触发器 #

先在容器里创建一个预触发脚本，插入文档前自动给started字段赋值：

using Microsoft.Azure.Cosmos;

// 初始化Cosmos客户端
var cosmosClient = new CosmosClient("你的Cosmos连接字符串");
var database = await cosmosClient.CreateDatabaseIfNotExistsAsync("你的数据库名称");
var container = await database.CreateContainerIfNotExistsAsync("你的容器名称", "/你的分区键");

// 预触发器脚本：插入前给started字段设服务器当前时间
var preTriggerScript = @"
function() {
    const context = getContext();
    const request = context.getRequest();
    const doc = request.getBody();
    
    // 赋值ISO格式的服务器当前时间
    doc.started = new Date().toISOString();
    
    request.setBody(doc);
}";

// 创建触发器
var triggerProps = new TriggerProperties
{
    Id = "SetServerTimePreTrigger",
    Body = preTriggerScript,
    TriggerType = TriggerType.Pre,
    TriggerOperation = TriggerOperation.Create // 只在创建时触发，如需更新也触发可改为All
};

await container.Scripts.CreateTriggerAsync(triggerProps);

2. 插入文档（自动触发赋值） #

插入时指定使用这个触发器，不用在客户端设置started字段：

// 待插入的文档（无需包含started字段）
var taskItem = new {
    id = Guid.NewGuid().ToString(),
    taskName = "用户注册任务",
    status = "待执行"
};

// 请求选项：指定要使用的预触发器
var requestOpts = new ItemRequestOptions
{
    PreTriggers = new List<string> { "SetServerTimePreTrigger" }
};

// 插入文档，触发器会自动给started字段赋值
await container.CreateItemAsync(taskItem, new PartitionKey(taskItem.id), requestOpts);

Python 实现示例 #

1. 创建预触发器 #

import azure.cosmos.cosmos_client as cosmos_client
import uuid

# 初始化客户端
client = cosmos_client.CosmosClient("你的Cosmos连接字符串", {'enableEndpointDiscovery': False})
database = client.create_database_if_not_exists(id='你的数据库名称')
container = database.create_container_if_not_exists(id='你的容器名称', partition_key='/你的分区键')

# 预触发器脚本
pre_trigger_script = """
function() {
    const context = getContext();
    const request = context.getRequest();
    const doc = request.getBody();
    
    doc.started = new Date().toISOString();
    
    request.setBody(doc);
}
"""

# 定义触发器并创建
trigger_def = {
    'id': 'SetServerTimePreTrigger',
    'body': pre_trigger_script,
    'triggerType': 'Pre',
    'triggerOperation': 'Create'
}

container.scripts.create_trigger(trigger_def)

2. 插入文档（自动触发赋值） #

# 待插入的文档
task_item = {
    'id': str(uuid.uuid4()),
    'taskName': '数据同步任务',
    'status': '初始化'
}

# 指定预触发器插入，自动生成started字段
container.create_item(
    body=task_item,
    pre_trigger_include=['SetServerTimePreTrigger']
)

如果需要在更新文档时也刷新该时间字段，只需要把触发器的TriggerOperation改成All或者Update即可。

内容的提问来源于stack exchange，提问作者Eli Finkel