monitor/database/infovacuum/actionrecord.py

   1 from elixir import Entity, Field, OneToMany, ManyToOne, ManyToMany
   2 from elixir import options_defaults, using_options, setup_all, has_one
   3 from elixir import String, Integer, DateTime, PickleType, Boolean
   4 from datetime import datetime,timedelta
   5 import elixir
   6 import traceback
   7
   8 from monitor.database.dborm import mon_metadata, mon_session
   9 __metadata__ = mon_metadata
  10 __session__  = mon_session
  11
  12 class IssueType(Entity):
  13         shortname = Field(String, default=None)
  14         description = Field(String, default=None)
  15         issue_record = ManyToMany('IssueRecord')
  16
  17 class IssueRecord(Entity):
  18         date_created = Field(DateTime,default=datetime.now)
  19         date_last_updated = Field(DateTime,default=datetime.now)
  20         date_action_taken = Field(DateTime,default=datetime.now)
  21
  22         hostname = Field(String,default=None)
  23         loginbase = Field(String)
  24
  25         ticket_id = Field(Integer, default=0)
  26         rt = Field(PickleType, default=None)
  27
  28         # open, paused, closed
  29         status = Field(String, default="open")
  30
  31         take_action = Field(Boolean, default=False)
  32         send_email = Field(Boolean, default=True)
  33
  34         message_series =  Field(String, default="nodedown")
  35         message_index = Field(Integer, default=0)
  36         penalty_level = Field(Integer, default=0)
  37
  38         issue_type = ManyToMany('IssueType')
  39         actions = OneToMany('ActionRecord', order_by='-date_created')
  40
  41
  42 class ActionRecord(Entity):
  43         @classmethod
  44         def get_latest_by(cls, **kwargs):
  45                 # TODO: need to sort on 'round' since actions will not be globally sync'd.
  46                 return cls.query.filter_by(**kwargs).order_by(ActionRecord.id.desc()).first()
  47
  48 # ACCOUNTING
  49         date_created = Field(DateTime,default=datetime.now)
  50         hostname = Field(String,default=None)
  51         loginbase = Field(String)
  52
  53         issue = ManyToOne('IssueRecord')
  54         # NOTE: this is the parent relation to fb records.  first create the
  55         # action record, then append to this value all of the findbad records we
  56         # want to have in our set.
  57         # Model:
  58         #    - create action record
  59         #    - find fbnode records
  60         #    - append fbnode records to action record
  61         #  OR
  62         #    - find fbnode records
  63         #    - create action record with fbnodes as argument
  64         findbad_records = OneToMany('FindbadNodeRecord', order_by='-date_checked')
  65
  66         # NOTE: can I move 'message_index, escellation_level, and penalty_level'
  67         #    into the same value?  Maybe not penalty level, since there are only two;
  68         #    and, there may be additional message and escellation levels.
  69         send_email_to = Field(PickleType, default=None)
  70         action_description = Field(PickleType, default=None)
  71         message_arguments = Field(PickleType, default=None)
  72
  73         # NOTE: not sure this needs to be in the db.
  74         escellation_level = Field(Integer, default=0)
  75         stage = Field(String, default=None)