monitor/database/info/findbad.py

   1 from elixir import Entity, Field, OneToMany, ManyToOne, ManyToMany
   2 from elixir import options_defaults, using_options, setup_all, belongs_to
   3 from elixir import String, Integer as Int, DateTime, PickleType, Boolean
   4 from datetime import datetime,timedelta
   5 import elixir
   6 import traceback
   7 from elixir.ext.versioned import *
   8
   9 from monitor.database.dborm import mon_metadata, mon_session
  10 __metadata__ = mon_metadata
  11 __session__  = mon_session
  12
  13
  14 class FindbadNodeRecord(Entity):
  15         @classmethod
  16         def get_all_latest(cls):
  17                 return cls.query.all()
  18
  19         @classmethod
  20         def get_latest_by(cls, **kwargs):
  21                 return cls.query.filter_by(**kwargs).first()
  22
  23         @classmethod
  24         def get_latest_n_by(cls, n=3, **kwargs):
  25                 return cls.query.filter_by(**kwargs)
  26
  27 # ACCOUNTING
  28         date_checked = Field(DateTime,default=datetime.now)
  29         round = Field(Int,default=0)
  30         hostname = Field(String,primary_key=True,default=None)
  31         loginbase = Field(String)
  32
  33 # INTERNAL
  34         kernel_version = Field(String,default=None)
  35         bootcd_version = Field(String,default=None)
  36         nm_status = Field(String,default=None)
  37         fs_status = Field(String,default=None)
  38         dns_status = Field(String,default=None)
  39         princeton_comon_dir = Field(Boolean,default=False)
  40         princeton_comon_running = Field(Boolean,default=False)
  41         princeton_comon_procs = Field(Int,default=None)
  42
  43 # EXTERNAL
  44         plc_node_stats = Field(PickleType,default=None)
  45         plc_site_stats = Field(PickleType,default=None)
  46         plc_pcuid      = Field(Int,default=None)
  47         comon_stats    = Field(PickleType,default=None)
  48         port_status    = Field(PickleType,default=None)
  49         ssh_portused = Field(Int,default=22)
  50         ssh_status = Field(Boolean,default=False)
  51         ssh_error = Field(String,default=None)  # set if ssh_access == False
  52         ping_status = Field(Boolean,default=False)
  53
  54 # INFERRED
  55         observed_category = Field(String,default=None)
  56         observed_status = Field(String,default=None)
  57
  58         acts_as_versioned(ignore=['date_checked'])
  59         # NOTE: this is the child relation
  60         #action = ManyToOne('ActionRecord', required=False)
  61
  62 class FindbadPCURecord(Entity):
  63         @classmethod
  64         def get_all_latest(cls):
  65                 return cls.query.all()
  66
  67         @classmethod
  68         def get_latest_by(cls, **kwargs):
  69                 return cls.query.filter_by(**kwargs).first()
  70
  71 # ACCOUNTING
  72         date_checked = Field(DateTime)
  73         round = Field(Int,default=0)
  74         plc_pcuid = Field(Int)
  75
  76 # EXTERNAL
  77         plc_pcu_stats = Field(PickleType,default=None)
  78         dns_status = Field(String)
  79         port_status = Field(PickleType)
  80         entry_complete = Field(String)
  81
  82 # INTERNAL
  83 # INFERRED
  84         reboot_trial_status = Field(String)
  85
  86         acts_as_versioned(ignore=['date_checked'])