Performance Cluster Management

Added basic models and updated sql scripts.

Working on #11

Author: OpenDataAlex

dbscripts/mysql_process_tracker.sql

@@ -272,3 +272,31 @@ create index process_run_actor_id
 create index process_status_id
 	on process_tracking (process_status_id);
 
+create table process_tracker.cluster_tracking
+(
+	cluster_id int auto_increment
+		primary key,
+	cluster_name varchar(250) not null,
+	cluster_max_memory int not null,
+	cluster_max_memory_unit char(2) null,
+	cluster_max_processing int not null,
+	cluster_max_processing_unit varchar(3) not null,
+	cluster_current_memory_usage int null,
+	cluster_current_process_usage int null,
+	constraint cluster_tracking_cluster_name_uindex
+		unique (cluster_name)
+)
+comment 'Capacity cluster tracking';
+
+create table process_tracker.cluster_process
+(
+	cluster_id int not null,
+	process_id int not null,
+	primary key (cluster_id, process_id),
+	constraint cluster_process_fk01
+		foreign key (cluster_id) references process_tracker.cluster_tracking (cluster_id),
+	constraint cluster_process_fk02
+		foreign key (process_id) references process_tracker.process (process_id)
+)
+comment 'Relationship tracking between processes and performance clusters.';
+

dbscripts/postgresql_process_tracker.sql

@@ -417,3 +417,40 @@ comment on table extract_dependency is 'Table tracking interdependencies between
 
 alter table extract_dependency owner to pt_admin;
 
+create table cluster_tracking
+(
+	cluster_id serial not null
+		constraint cluster_tracking_pk
+			primary key,
+	cluster_name varchar(250) not null,
+	cluster_max_memory integer not null,
+	cluster_max_memory_unit char(2) not null,
+	cluster_max_processing integer not null,
+	cluster_max_processing_unit varchar(3) not null,
+	cluster_current_memory_usage integer,
+	cluster_current_process_usage integer
+);
+
+comment on table cluster_tracking is 'Capacity cluster tracking';
+
+alter table cluster_tracking owner to pt_admin;
+
+create unique index cluster_tracking_cluster_name_uindex
+	on cluster_tracking (cluster_name);
+
+create table cluster_process
+(
+	cluster_id integer not null
+		constraint cluster_process_fk01
+			references cluster_tracking,
+	process_id integer not null
+		constraint cluster_process_fk02
+			references process,
+	constraint cluster_process_pk
+		primary key (cluster_id, process_id)
+);
+
+comment on table cluster_process is 'Relationship tracking between processes and performance clusters.';
+
+alter table cluster_process owner to pt_admin;
+

process_tracker/models/capacity.py

@@ -0,0 +1,54 @@
+# SQLAlchemy Models
+# Models for Process entities
+
+
+from sqlalchemy import Boolean, Column, DateTime, ForeignKey, Integer, Sequence, String
+from sqlalchemy.orm import relationship
+
+from process_tracker.models.model_base import default_date, Base
+
+
+class Cluster(Base):
+
+    __tablename__ = "cluster_tracking"
+    __table_args__ = {"schema": "process_tracker"}
+
+    cluster_id = Column(
+        Integer,
+        Sequence("cluster_tracking_cluster_id_seq", schema="process_tracker"),
+        primary_key=True,
+    )
+    cluster_name = Column(String(250), unique=True, nullable=False)
+    cluster_max_memory = Column(Integer, nullable=False)
+    cluster_max_memory_unit = Column(String(2), nullable=False)
+    cluster_max_processing = Column(Integer, nullable=False)
+    cluster_max_processing_unit = Column(String(3), nullable=False)
+    cluster_current_memory_usage = Column(Integer)
+    cluster_current_process_usage = Column(Integer)
+
+    def __repr__(self):
+
+        return "<Cluster (name=%s)>" % self.cluster_name
+
+
+class ClusterProcess(Base):
+
+    __tablename__ = "cluster_process"
+    __table_args__ = {"schema": "process_tracker"}
+
+    cluster_id = Column(
+        Integer,
+        ForeignKey("process_tracker.cluster_tracking.cluster_id"),
+        primary_key=True,
+    )
+    process_id = Column(Integer, ForeignKey("process_tracker.process.process_id"))
+
+    cluster_processes = relationship("Process", foreign_key=[process_id])
+    process_clusters = relationship("Cluster", foreign_key=[cluster_id])
+
+    def __repr__(self):
+
+        return (
+            "<ClusterProcess (cluster_id=%s, process_id=%s)" % self.cluster_id,
+            self.process_id,
+        )