From 59e8c493e5dc15624de517b8a5d35efddc2b93d0 Mon Sep 17 00:00:00 2001
From: Kenneth Kehl <@kkehl@flexion.us>
Date: Fri, 12 Jan 2024 07:30:19 -0800
Subject: [PATCH] add stats for cache hits/misses and remove debug message

---
 app/aws/s3.py                            | 28 ++++++++++++++++++++++++
 app/clients/cloudwatch/aws_cloudwatch.py |  1 -
 2 files changed, 28 insertions(+), 1 deletion(-)

diff --git a/app/aws/s3.py b/app/aws/s3.py
index 2a631c326..86676f3fc 100644
--- a/app/aws/s3.py
+++ b/app/aws/s3.py
@@ -5,6 +5,7 @@ from boto3 import Session
 from expiringdict import ExpiringDict
 from flask import current_app
 
+from app import redis_store
 from app.clients import AWS_CLIENT_CONFIG
 
 FILE_LOCATION_STRUCTURE = "service-{}-notify/{}.csv"
@@ -12,6 +13,9 @@ FILE_LOCATION_STRUCTURE = "service-{}-notify/{}.csv"
 
 JOBS = ExpiringDict(max_len=100, max_age_seconds=3600 * 4)
 
+JOBS_CACHE_HITS = "JOBS_CACHE_HITS"
+JOBS_CACHE_MISSES = "JOBS_CACHE_MISSES"
+
 
 def get_s3_file(bucket_name, file_location, access_key, secret_key, region):
     s3_file = get_s3_object(bucket_name, file_location, access_key, secret_key, region)
@@ -72,6 +76,26 @@ def get_job_from_s3(service_id, job_id):
     return obj.get()["Body"].read().decode("utf-8")
 
 
+def incr_jobs_cache_misses():
+    if not redis_store.get(JOBS_CACHE_MISSES):
+        redis_store.set(JOBS_CACHE_MISSES, 1)
+    else:
+        redis_store.incr(JOBS_CACHE_MISSES)
+    hits = redis_store.get(JOBS_CACHE_HITS).decode("utf-8")
+    misses = redis_store.get(JOBS_CACHE_MISSES).decode("utf-8")
+    current_app.logger.info(f"JOBS CACHE MISS hits {hits} misses {misses}")
+
+
+def incr_jobs_cache_hits():
+    if not redis_store.get(JOBS_CACHE_HITS):
+        redis_store.set(JOBS_CACHE_HITS, 1)
+    else:
+        redis_store.incr(JOBS_CACHE_HITS)
+    hits = redis_store.get(JOBS_CACHE_HITS).decode("utf-8")
+    misses = redis_store.get(JOBS_CACHE_MISSES).decode("utf-8")
+    current_app.logger.info(f"JOBS CACHE MISS hits {hits} misses {misses}")
+
+
 def get_phone_number_from_s3(service_id, job_id, job_row_number):
     # We don't want to constantly pull down a job from s3 every time we need a phone number.
     # At the same time we don't want to store it in redis or the db
@@ -80,6 +104,10 @@ def get_phone_number_from_s3(service_id, job_id, job_row_number):
     if job is None:
         job = get_job_from_s3(service_id, job_id)
         JOBS[job_id] = job
+        incr_jobs_cache_misses()
+    else:
+        incr_jobs_cache_hits()
+
     job = job.split("\r\n")
     first_row = job[0]
     job.pop(0)
diff --git a/app/clients/cloudwatch/aws_cloudwatch.py b/app/clients/cloudwatch/aws_cloudwatch.py
index b4c468581..4fac575a3 100644
--- a/app/clients/cloudwatch/aws_cloudwatch.py
+++ b/app/clients/cloudwatch/aws_cloudwatch.py
@@ -107,7 +107,6 @@ class AwsCloudwatchClient(Client):
         if all_log_events and len(all_log_events) > 0:
             event = all_log_events[0]
             message = json.loads(event["message"])
-            current_app.logger.info(f"MESSAGE {message}")
             return (
                 "success",
                 message["delivery"]["providerResponse"],