I would prefer that we store for each stream ID its own last value with last timestamp (then you can use MongoEngine as well).