logparser/main.py at master · keysaim/logparser · GitHub

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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
#*********************************************************************************************#
#*********************************************************************************************#
#******************witten by Neil Hao(nbaoping@cisco.com), 2013/05/19*************************#
#*********************************************************************************************#
#*********************************************************************************************#
#*********************************************************************************************#

import logging
import sys
import signal

from parxact import *
from factory import *
import pstats
from userdefined import *
from translog import *
import base

class TestAnalyser( Analyser ):
	def __init__( self, config ):
		super( TestAnalyser, self ).__init__( config )
		pass

	def anly_zero_pace( self, logInfo ):
		#TODO
		return True

	def anly_negative_pace( self, logInfo ):
		#TODO
		return True

	def anly_pace( self, logInfo ):
		#TODO
		return True

	def close( self ):
		#TODO
		return True


class TestFactory( object ):
	def __init__( self ):
		pass

	def register( self ):
		register_anlyser( 'test', TestFactory.__parse, TestFactory.__create, self )

	def __parse( self, node ):
		logging.info( 'parse TestFactory' )

	def __create( self, config ):
		anly = TestAnalyser( config )
		return anly

class TestFieldParser( IFieldParser ):
	def __init__( self ):
		pass

	def parse_field( self, logInfo, field, fmt ):
		#TODO add customized parsing here
		return True

#args.fmt = '%a %A %b %D %h %H %I %m %O %q %r %>s %t %T %U %V %X'
def parse_args():
	args = InputArgs()
	if not args.parse_argv( sys.argv ):
		return None
	return args

def main():
	if not sys.version.startswith( '2.7' ):
		base.NEW_VERSION = False
		#for old version, the funcName may not support
		base.LOGGING_FORMAT = '%(asctime)s %(levelname)5s: %(filename)s:%(lineno)s-> %(message)s'

	args = parse_args()
	if not args:
		return ;
	factory = TestFactory()
	factory.register()
	register_translog()
	userDefinedCtx = UserDefinedCtx()
	userDefinedCtx.register_user_defined()
	#use customized field parser
	args.fieldParser = TestFieldParser()
	parser = XactParser( )

	def signal_handler(signal, frame):
		logging.info( 'You pressed Ctrl+C!' )
		if parser is not None:
			parser.close()
		else:
			logging.error( 'parser none' )
		sys.exit(0)

	signal.signal(signal.SIGINT, signal_handler)
	logging.info( 'begin to parse ...' )
	parser.parse( args )

def profile_main():
	args = InputArgs()
	#args.path = './logs'
	args.path = './logs'
	args.path = '/home/neil/customer/telstra/625703709/datas/SR-625703709_haydc-ca-10_logs_20130513/we_translogs'
	args.configPath = './basic.xml'
	args.customer = 'telstra'
	args.fmt = get_log_fmt( args.customer )
	factory = TestFactory()
	factory.register()
	#use customized field parser
	args.fieldParser = TestFieldParser()
	parser = XactParser( )

	def signal_handler(signal, frame):
		logging.info( 'You pressed Ctrl+C!' )
		if parser is not None:
			parser.close()
		else:
			logging.error( 'parser none' )
		sys.exit(0)

	signal.signal(signal.SIGINT, signal_handler)
	logging.info( 'begin to parse ...' )
	parser.parse( args )

if __name__ == '__main__':
	main()