Python操作MongoDB时间流集合时BSON Timestamp生成异常

问题场景 #

在Python脚本中向MongoDB时间流集合插入文档时，触发错误：

"'timestamp' must be present and contain a valid BSON UTC datetime value"

插入代码片段：

newdata = {"metadata": { "ser": "129031", "type": "data" }, "timestamp": {"$date" : timestamp}, "val": value}
            
result = cur_collection.insert_one(newdata)

尝试过多种方式生成时间戳（如time.time()转整数、datetime.now()、Timestamp类实例等），但均无法生成符合要求的64位BSON UTC时间戳（包含32位纪元秒+32位毫秒），要么得到浮点数，要么格式不被MongoDB识别。

正确解决方案 #

方法1：直接使用带UTC时区的datetime对象 #

pymongo会自动将带UTC时区的datetime对象转换为标准BSON UTC时间戳，无需手动构造格式：

from datetime import datetime, timezone

# 生成当前UTC时间的datetime对象
timestamp = datetime.now(timezone.utc)

# 直接传入datetime对象，无需{"$date": ...}包装
newdata = {"metadata": { "ser": "129031", "type": "data" }, "timestamp": timestamp, "val": value}
result = cur_collection.insert_one(newdata)

方法2：使用bson库的DatetimeMS类（精确到毫秒） #

如果需要手动控制毫秒级精度，可使用bson库的DatetimeMS类：

import time
from bson import datetime_ms

# 生成当前时间的毫秒级整数时间戳
ms_timestamp = int(time.time() * 1000)
# 转换为BSON DatetimeMS对象
timestamp = datetime_ms.DatetimeMS(ms_timestamp)

newdata = {"metadata": { "ser": "129031", "type": "data" }, "timestamp": timestamp, "val": value}
result = cur_collection.insert_one(newdata)

错误原因解析 #

1. 格式错误：之前使用{"$date": timestamp}包装时，timestamp的类型或格式不符合MongoDB要求，手动构造极易出错。
2. 时区缺失：不带时区的datetime对象会被MongoDB判定为本地时间，不符合时间流集合强制要求的UTC时间标准。
3. 类型不匹配：直接传入整数或浮点数无法被识别为有效的BSON datetime类型，必须使用pymongo/bson库提供的标准时间对象。

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