From b62f9dad83ae57d59719354183d32d2463361f64 Mon Sep 17 00:00:00 2001 From: inspurericzhang Date: Thu, 4 Jan 2024 01:48:13 +0000 Subject: [PATCH] improve delete_es_index_task log Change-Id: Ic47c8abf2760896f57a2a388633a7cafe24e5296 --- venus/task/core/delete_es_index_task.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/venus/task/core/delete_es_index_task.py b/venus/task/core/delete_es_index_task.py index 1d0e92a..0d2297a 100644 --- a/venus/task/core/delete_es_index_task.py +++ b/venus/task/core/delete_es_index_task.py @@ -42,7 +42,7 @@ class DeleteESIndexTask(object): LOG.error(_LE("failed to delete es index: %s"), name) return except Exception as e: - LOG.error(_LE("delete es inidex:%s, catch exception:%s"), + LOG.error(_LE("delete es index:%s, catch exception:%s"), name, str(e)) def delete_es_outdated_index(self): @@ -51,27 +51,27 @@ class DeleteESIndexTask(object): LOG.error(_LE("the config of log_save_days do not exist")) return - LOG.info(_LI("elasticsearch indexes(log) save days: %s"), len_d) + LOG.info(_LI("es indexes(log) save days: %s"), len_d) today = time.strftime('%Y-%m-%d') try: indexes_array = self.search_lib.get_all_index() for index in indexes_array: index_name = index["index"] - index_day = index_name.split('-')[1] today_start = datetime.datetime.strptime(today, "%Y-%m-%d") index_start = datetime.datetime.strptime(index_day, '%Y.%m.%d') diff_day = today_start - index_start + if diff_day.days >= int(len_d): - LOG.info(_LI("delete index %s, diff day %d"), + LOG.info(_LI("deleted index %s, diff day %d"), index_name, diff_day.days) self.delete_index(index_name) else: - LOG.debug(_LI("not delete index %s, diff day %d"), + LOG.debug(_LI("reserved index %s, diff day %d"), index_name, diff_day.days) except Exception as e: - LOG.error(_LE("delete es inidex, catch exception:%s"), str(e)) + LOG.error(_LE("delete es index, catch exception:%s"), str(e)) def start_task(self): try: