From 417dc38e38f3fc6de07433d6384659ce28755035 Mon Sep 17 00:00:00 2001 From: "Alexie (Boyong) Madolid" Date: Thu, 31 Aug 2023 07:59:37 +0800 Subject: [PATCH] [ELASTIC]: Add dynamic LogHandler index --- jaseci_core/jaseci/extens/svc/elastic_svc.py | 8 ++++++-- jaseci_core/jaseci/jsorc/jsorc_settings.py | 2 ++ 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/jaseci_core/jaseci/extens/svc/elastic_svc.py b/jaseci_core/jaseci/extens/svc/elastic_svc.py index 4748bf9bd2..019ac10e25 100644 --- a/jaseci_core/jaseci/extens/svc/elastic_svc.py +++ b/jaseci_core/jaseci/extens/svc/elastic_svc.py @@ -81,8 +81,12 @@ def post_run(self): under_test = self.config.get("under_test", False) if not under_test: self.configure_elastic() - LOG_QUEUES["core"] = self.add_elastic_log_handler(logger, "core", under_test) - LOG_QUEUES["app"] = self.add_elastic_log_handler(app_logger, "app", under_test) + LOG_QUEUES["core"] = self.add_elastic_log_handler( + logger, self.config.get("core_log_index") or "core", under_test + ) + LOG_QUEUES["app"] = self.add_elastic_log_handler( + app_logger, self.config.get("app_log_index") or "app", under_test + ) def configure_elastic(self): """ diff --git a/jaseci_core/jaseci/jsorc/jsorc_settings.py b/jaseci_core/jaseci/jsorc/jsorc_settings.py index e2491c39a3..8fc9791e11 100644 --- a/jaseci_core/jaseci/jsorc/jsorc_settings.py +++ b/jaseci_core/jaseci/jsorc/jsorc_settings.py @@ -172,6 +172,8 @@ class JsOrcSettings: "auth": os.getenv("ELASTIC_AUTH"), "common_index": f"{KUBE_NAMESPACE}-common", "activity_index": f"{KUBE_NAMESPACE}-activity", + "core_log_index": "core", + "app_log_index": "app", "ilm_policy_name": ELASTIC_ILM_POLICY_NAME, "ilm_policy": ELASTIC_ILM_POLICY, "index_template_name": ELASTIC_INDEX_TEMPLATE_NAME,