[ELASTIC]: Add dynamic LogHandler index

amadolid · Aug 30, 2023 · 417dc38 · 417dc38
1 parent e568a92
commit 417dc38
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git 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
@@ -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,