Updating timestamps in the site machine platform

update_ts.py

# coding: utf-8

# In[12]:

import pymongo
from datetime import timedelta


# In[4]:

client = pymongo.MongoClient()


# In[9]:
t = 'tenant'
db = client[t]


# In[10]:

sslog = db.sslog


# In[11]:

sslog.count()


# In[13]:

def sslog_timestamp_fix(rs, collection, offset):
    slogs = []
    for a in rs:
        a['data']['timestamp'] = a['data']['timestamp'] + timedelta(hours=offset)
        slogs.append(a)
    collection.remove({})
    for r in slogs:
        collection.insert_one(r)


# In[14]:

sslogs = sslog.find({})


# In[15]:

sslog_timestamp_fix(sslogs, sslog, 14)


# In[ ]:

sslog.count()