使用python pymongo实现时间序列数据mongodb的存储桶模式

import pymongo
from datetime import datetime

client = pymongo.MongoClient("mongodb://localhost:27017/")
db = client["mydatabase"]

collection = db["timeseries"]

def store_timeseries_data(data):
    # 获取当前时间
    current_time = datetime.now()
    # 获取当前时间所属的存储桶
    bucket = current_time.strftime("%Y-%m-%d %H:%M:%S")
    # 将数据插入到对应的存储桶中
    collection.update_one({"bucket": bucket}, {"$push": {"data": data}}, upsert=True)

data = {"value": 10}
store_timeseries_data(data)

{
  "_id": ObjectId("61f8e8e8e8e8e8e8e8e8e8e8"),
  "bucket": "2022-02-02 12:00:00",
  "data": [
    {"value": 10},
    {"value": 20},
    ...
  ]
}