Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- device = terminal.upper()
- try:
- st = datetime.now().replace(hour=0, minute=0,second=0, microsecond=0)
- print(st)
- # exit()
- conn = self.cfx.connectMongo()
- db = conn.nms_n5
- col_do = db.data_sdr_module.find(
- {"download": {"$exists": "true"}, "deviceID": device, "date_created": {"$gte": st}}).sort("_id", -1)
- col_up = db.data_sdr_module.find(
- {"upload": {"$exists": "true"}, "deviceID": device, "date_created": {"$gte": st}}).sort("_id", -1)
- # data_dict = []
- data_dict_do = []
- for i in col_do:
- del i["_id"]
- data_dict_do.append(i)
- df_do = pd.DataFrame(data_dict_do)
- # print("Do",len(df_do))
- data_dict_up = []
- for j in col_up:
- del j["_id"]
- data_dict_up.append(j)
- df_up = pd.DataFrame(data_dict_up)
- # print("Up",len(df_up))
- limit = int(len(df_do))-1
- val_delta_do = []
- for k in range(limit):
- val = round((((df_do["download"][k]-df_do["download"][k+1])*8)/314572800), 4)
- val_delta_do.append(val)
- val_delta_up = []
- for l in range(limit):
- val = round((((df_up["upload"][l]-df_up["upload"][l+1])*8)/314572800), 4)
- val_delta_up.append(val)
- # df = pd.DataFrame(val_delta_do)
- # print(df)
- # add new value
- df_do['value_download'] = pd.DataFrame(val_delta_do)
- # print(df_do.count())
- df_up['value_upload'] = pd.DataFrame(val_delta_do)
- # print(df_up.count())
- df_inner = pd.merge(df_do, df_up, how="inner", on="ip_address",indicator=True).fillna(0)
- # print(df_inner)
- df_loc = df_inner.loc[:,('ip_address','value_download','value_upload','date_created_y')]
- # print(df_loc)
- data = df_loc.to_dict('records')
- return data
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement