request summary command

Author: mrlockstar

infrastructure/modules/container-apps/jobs.tf

@@ -1,3 +1,16 @@
+locals {
+  scheduled_jobs = {
+    collect_metrics = {
+      cron_expression = "0 */6 * * *"
+      environment_variables = {
+        ENVIRONMENT = var.environment
+      }
+      job_short_name     = "rs"
+      job_container_args = "request_summary"
+    }
+  }
+}
+
 module "db_setup" {
   source = "../dtos-devops-templates/infrastructure/modules/container-app-job"
 
@@ -25,3 +38,54 @@ module "db_setup" {
   ]
 
 }
+
+module "scheduled_jobs" {
+  source = "../dtos-devops-templates/infrastructure/modules/container-app-job"
+
+  for_each = local.scheduled_jobs
+
+  name                         = "${var.app_short_name}-${each.value.job_short_name}-${var.environment}"
+  container_app_environment_id = var.container_app_environment_id
+  resource_group_name          = azurerm_resource_group.main.name
+
+  fetch_secrets_from_app_key_vault = var.fetch_secrets_from_app_key_vault
+  app_key_vault_id                 = var.app_key_vault_id
+
+  container_command = ["/bin/sh", "-c"]
+  container_args = [
+    "python manage.py ${each.value.job_container_args}"
+  ]
+
+  docker_image        = var.docker_image
+  replica_retry_limit = 0
+  user_assigned_identity_ids = flatten([
+    [module.azure_blob_storage_identity.id],
+    var.deploy_database_as_container ? [] : [module.db_connect_identity[0].id]
+  ])
+
+  environment_variables = merge(
+    local.common_env,
+    {
+      "STORAGE_ACCOUNT_NAME" = module.storage.storage_account_name,
+      "BLOB_MI_CLIENT_ID"    = module.azure_blob_storage_identity.client_id,
+    },
+    each.value.environment_variables,
+    var.deploy_database_as_container ? local.container_db_env : local.azure_db_env
+  )
+  secret_variables = merge(
+    # { APPLICATIONINSIGHTS_CONNECTION_STRING = var.app_insights_connection_string },
+    var.deploy_database_as_container ? { DATABASE_PASSWORD = resource.random_password.admin_password[0].result } : {}
+  )
+
+  # alerts
+  action_group_id            = var.action_group_id
+  enable_alerting            = var.enable_alerting
+  log_analytics_workspace_id = var.log_analytics_workspace_audit_id
+
+  # Ensure RBAC role assignments are created before the job definition finalizes
+  depends_on = [
+    module.blob_storage_role_assignment,
+  ]
+
+  cron_expression = each.value.cron_expression
+}

lung_cancer_screening/questions/management/__init__.py

@@ -0,0 +1,21 @@
+import logging
+
+from django.core.management.base import BaseCommand, CommandError
+from lung_cancer_screening.questions.services.request_summary import RequestSummary
+
+logger = logging.getLogger(__name__)
+
+class Command(BaseCommand):
+    help = "Counts the number of submitted requests."
+
+    def handle(self, *args, **options):
+        logger.info("Command: SubmittedCount.")
+        try:
+            rs = RequestSummary()
+            summary = rs.get_summary()
+
+            self.stdout.write(str(summary))
+
+        except Exception as e:
+            logger.error(e, exc_info=True)
+            raise CommandError(e)

lung_cancer_screening/questions/management/commands/__init__.py

@@ -0,0 +1,23 @@
+import logging
+from ..models.response_set import ResponseSet
+
+logger = logging.getLogger(__name__)
+
+class RequestSummary:
+
+    def __init__(self):
+        logger.info("RequestSummary: init")
+
+    def get_submitted_count(self):
+
+        return ResponseSet.objects.submitted().count()
+
+    def get_count(self):
+
+        return ResponseSet.objects.count()
+
+    def get_summary(self):
+        return {
+            "total": self.get_count(),
+            "submitted": self.get_submitted_count(),
+        }