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_by(cls, **kwargs):
  25                 return cls.query.filter_by(**kwargs).first()
  26
  27         @classmethod
  28         def get_latest_n_by(cls, n=3, **kwargs):
  29                 return cls.query.filter_by(**kwargs)
  30
  31 # ACCOUNTING
  32         date_checked = Field(DateTime,default=datetime.now)
  33         round = Field(Int,default=0)
  34         hostname = Field(String,primary_key=True,default=None)
  35         loginbase = Field(String)
  36
  37 # INTERNAL
  38         kernel_version = Field(String,default=None)
  39         bootcd_version = Field(String,default=None)
  40         nm_status = Field(String,default=None)
  41         fs_status = Field(String,default=None)
  42         dns_status = Field(String,default=None)
  43         princeton_comon_dir = Field(Boolean,default=False)
  44         princeton_comon_running = Field(Boolean,default=False)
  45         princeton_comon_procs = Field(Int,default=None)
  46
  47 # EXTERNAL
  48         plc_node_stats = Field(PickleType,default=None)
  49         plc_site_stats = Field(PickleType,default=None)
  50         plc_pcuid      = Field(Int,default=None)
  51         comon_stats    = Field(PickleType,default=None)
  52         port_status    = Field(PickleType,default=None)
  53         ssh_portused = Field(Int,default=22)
  54         ssh_status = Field(Boolean,default=False)
  55         ssh_error = Field(String,default=None)  # set if ssh_access == False
  56         ping_status = Field(Boolean,default=False)
  57
  58 # INFERRED
  59         observed_category = Field(String,default=None)
  60         observed_status = Field(String,default=None)
  61
  62         acts_as_versioned(ignore=['date_checked'])
  63         # NOTE: this is the child relation
  64         #action = ManyToOne('ActionRecord', required=False)
  65
  66 class FindbadPCURecord(Entity):
  67         @classmethod
  68         def get_all_latest(cls):
  69                 return cls.query.all()
  70
  71         @classmethod
  72         def get_latest_by(cls, **kwargs):
  73                 return cls.query.filter_by(**kwargs).first()
  74
  75 # ACCOUNTING
  76         date_checked = Field(DateTime)
  77         round = Field(Int,default=0)
  78         plc_pcuid = Field(Int)
  79
  80 # EXTERNAL
  81         plc_pcu_stats = Field(PickleType,default=None)
  82         dns_status = Field(String)
  83         port_status = Field(PickleType)
  84         entry_complete = Field(String)
  85
  86 # INTERNAL
  87 # INFERRED
  88         reboot_trial_status = Field(String)
  89
  90         acts_as_versioned(ignore=['date_checked'])