commands/checksync.py

   1 #!/usr/bin/python
   2
   3 from monitor.database.info.model import *
   4 import sys
   5
   6 fbquery = HistoryNodeRecord.query.all()
   7 hostnames = [ n.hostname for n in fbquery ]
   8
   9 if True:
  10         for hn in hostnames:
  11                 fbrec = FindbadNodeRecord.query.filter_by(hostname=hn).order_by(FindbadNodeRecord.version.desc()).first()
  12                 if len(fbrec.versions) >= 2:
  13                         if fbrec.version != fbrec.versions[-2].version + 1:
  14                                 print fbrec.hostname, fbrec.version, fbrec.versions[-2].version
  15                                 fbrec.version = fbrec.versions[-2].version + 1
  16                                 fbrec.flush()
  17
  18         session.flush()
  19
  20 fbquery = HistoryPCURecord.query.all()
  21 pcus = [ n.plc_pcuid for n in fbquery ]
  22
  23 for pcuid in pcus:
  24         fbrec = FindbadPCURecord.query.filter_by(plc_pcuid=pcuid).order_by(FindbadPCURecord.version.desc()).first()
  25         if len(fbrec.versions) >= 2:
  26                 if fbrec.version != fbrec.versions[-2].version + 1:
  27                         print fbrec.plc_pcuid, fbrec.version, fbrec.versions[-2].version
  28                         fbrec.version = fbrec.versions[-2].version + 1
  29                         fbrec.flush()
  30
  31 session.flush()