8
8
from urllib .parse import urlparse
9
9
10
10
logger = log .get_logger ()
11
+ block_list = application .config .get ("apicoverage.block_list" , [])
11
12
import time
12
13
13
14
def on_request (msg ):
@@ -16,6 +17,9 @@ def on_request(msg):
16
17
logger .debug (req_msg )
17
18
if not msg ['flow' ]['request' ]['url' ]:
18
19
return
20
+
21
+ if msg ['flow' ]['request' ]['host' ] in block_list :
22
+ return
19
23
20
24
# 获取handler_context.id,为前端展开看详情准备
21
25
path_id = msg ['flow' ]['id' ]
@@ -47,7 +51,7 @@ def coverage_judgment(path, path_id, device_ip, req_starttime, msg, category):
47
51
flag = 0
48
52
for item in ulr_list :
49
53
if compare_query (item ['url' ], msg ['flow' ]['request' ]['url' ]):
50
- mergeAlgorithm .merge_handler_new (item ['url_base' ], path_id )
54
+ mergeAlgorithm .merge_handler_new (item ['url_base' ], path_id , category )
51
55
mergeAlgorithm .coverage_handler ()
52
56
report_worker (item ['url_base' ], device_ip , category )
53
57
flag = 1
@@ -60,7 +64,7 @@ def coverage_judgment(path, path_id, device_ip, req_starttime, msg, category):
60
64
# 去重
61
65
for p in list (set (params_list )):
62
66
# Todo 这里在初始化之后看一下
63
- val = msg ['flow' ]['request' ]['query' ][ p ]
67
+ val = msg ['flow' ]['request' ]['query' ]. get ( p )
64
68
if url_pgroup :
65
69
url_pgroup = url_pgroup + '&' + str (p ) + '=' + str (val )
66
70
else :
@@ -72,7 +76,7 @@ def coverage_judgment(path, path_id, device_ip, req_starttime, msg, category):
72
76
emit (req_starttime , path )
73
77
# 如果不在base里,不需要merge到数据中
74
78
else :
75
- # mergeAlgorithm.merge_handler_new(path, path_id)
79
+ # mergeAlgorithm.merge_handler_new(path, path_id, category )
76
80
# 进行上报
77
81
report_worker (path , device_ip , category )
78
82
0 commit comments