Newer
Older
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
from pattern_ranker import *
import argparse
log_path = dirname(__file__) + '/log/' + str(datetime.datetime.now().strftime(
'%Y-%m-%d')) + '_nezha.log'
logger = Logger(log_path, logging.DEBUG, __name__).getlog()
def get_miner(ns):
template_indir = dirname(__file__) + '/log_template'
config = TemplateMinerConfig()
config.load(dirname(__file__) + "/log_template/drain3_" + ns + ".ini")
config.profiling_enabled = False
path = dirname(__file__) + '/log_template/' + ns + ".bin"
persistence = FilePersistence(path)
template_miner = TemplateMiner(persistence, config=config)
return template_miner
if __name__ == '__main__':
parser = argparse.ArgumentParser(description='Nezha')
parser.add_argument('--ns', default="hipster", help='namespace')
parser.add_argument('--level', default="service", help='service-level or inner-service level')
args = parser.parse_args()
ns = args.ns
level = args.level
if ns == "hipster":
normal_time1 = "2022-08-22 03:51"
path1 = dirname(__file__) + "/rca_data/2022-08-22/2022-08-22-fault_list.json"
normal_time2 = "2022-08-23 17:00"
path2 = dirname(__file__) + "/rca_data/2022-08-23/2022-08-23-fault_list.json"
log_template_miner = get_miner(ns)
inject_list = [path1, path2]
normal_time_list = [normal_time1, normal_time2]
if level=="service":
logger.info("------- OnlineBoutique Result at service level -------")
evaluation_pod(normal_time_list, inject_list, ns,log_template_miner)
else:
logger.info("------- OnlineBoutique Result at inner service level -------")
evaluation(normal_time_list, inject_list, ns,log_template_miner)
elif ns == "ts":
normal_time1 = "2023-01-29 08:50"
path1 = dirname(__file__) + "/rca_data/2023-01-29/2023-01-29-fault_list.json"
normal_time2 = "2023-01-30 11:39"
path2 = dirname(__file__) + "/rca_data/2023-01-30/2023-01-30-fault_list.json"
log_template_miner = get_miner(ns)
inject_list = [path1, path2]
normal_time_list = [normal_time1, normal_time2]
if level=="service":
logger.info("------- Trainticket Result at service level -------")
evaluation_pod(normal_time_list, inject_list, ns,log_template_miner)
else:
logger.info("------- Trainticket Result at inner service level -------")
evaluation(normal_time_list, inject_list, ns,log_template_miner)
else:
logger.info("Unknown namespace")