ip report

app/backend/views.py

 exfo = Exfo("administrator", "exf0w0rxC@t4dm!n")
 exfo.login()
 
+from datetime import datetime
+from dateutil import tz
+
 mkt = Mikrotik()
 
 def index(request):
 def dump_fixed_results(request):
     from bson.json_util import dumps
     from bson.json_util import loads
+
+    from_zone = tz.gettz('UTC')
+    to_zone = tz.gettz('Asia/Bangkok')
+
     col  = db['fixed_results']
     col.delete_many({})
     tt = exfo.call_remote_api("/API/REST/Test/v1/TypeByName?list_all=false&size=0")
             return n
     except:
         return r['results']
+
 def gen_report_notebook():
-    from datetime import datetime
+
     import pandas as pd
 
+    from_zone = tz.gettz('UTC')
+    to_zone = tz.gettz('Asia/Bangkok')
+    
     c = db['fixed_results'].find()
     data = []
     for i in c:
         #pprint(i['header'])
         res = dict(zip(i['header'], i['results']))
+        utc = datetime.fromtimestamp(int(i['ids']['time_stamp'])/1000000000)
+        utc = utc.replace(tzinfo=from_zone)
+        dt = utc.astimezone(to_zone)
+
         d = {'header': i['header'], 'results': i['results'], 'output': res, 'params': i['parameters'], 'ts': i['ids']['time_stamp'], 
-             'dt': datetime.fromtimestamp(int(i['ids']['time_stamp'])/1000000000), 'test_type_name': i['ids']['fixed_results_url']}
+             'dt': str(dt), 'test_type_name': i['ids']['fixed_results_url']}
         d.update(i['names'])
         #res.update(i['ids'])
         #res.update(i[])
         import time
         ts = int(time.time())
         fn = f"report_{ts}.xlsx"
+
         table.to_excel(f'/code/media/{fn}')
         report_link = f'/media/{fn}'
 
     return render(request, 'backend/gen_report.html', {'tbl': table.head(50).to_html(\
         classes=["table", "table-striped", "table-bordered", "align-middle"],\
         table_id="report_tbl"), 'slas': slas, 'report_link': report_link, 'mk_ips': mk_ips, 'mk_address': mk_address, 'vrs': vrs, 'sla_name': sla_name, 'vr_name': vr_name})
+
+
+@shared_task
+def mikro_dump_task():
+
+    col  = db['ip_address']
+    mk_address = mkt.call_remote("ip/address") 
+    for i in mk_address:
+        temp = {'ts': datetime.utcnow()}
+        temp = temp | i
+        col.insert_one(temp)
+    pprint("dump ip complete")
+

app/network_report/settings.py

         # # "schedule": crontab(hour="17", minute="15"),
         # "schedule": crontab(minute="*/3", hour="17-21"),
     # },
+    "mikro_dump": {
+        "task": "backend.views.mikro_dump_task",
+        "schedule": crontab(minute="*/3"),
+    },
 }