/opt/dedrads/mysql/__pycache__
Edit: /opt/dedrads/mysql/__pycache__/queryparser.cpython-313.pyc (17352B)
}j1
f S r SSKrSSKrSSKJr SSKrSSKJrJr SSKrSSK J
r
SSK J r
S r " S S 5 r " S
S 5 r " S S
5 rS\S- 4S jrS\
4S jrS\
S\R* S- S\S- S\S\
S\4 S jrS\S\S\
S\S\R* S- S\S- 4 S jrS r\S:X a \" 5 gg) z Parses MySQL general query logs N)Path)datetime timedelta)IO)Parserc [ R " [ S9n U R SSSSSS9 U R SS S
S S 9 U R S
S[ R
SSS9 U R
5 nUR SSSSS 9 UR SSS/ SQSS9 U R S S S S 9 U R 5 nUR S :X a S Ul U$ )!N) descriptionz-qz--quiet store_falseverbosezSuppress non-error output)actiondesthelpz-oz--outputFILEz&Write output to FILE (default: stdout))metavarr z-rz--regexREGEXz#Tally arbitrary REGEX string (slow))typer r z-uz--userUSERz(Output USER's queries instead of summaryz-sz--sorttotal)selectinsertupdatereplaceregexr z Sort summary by a type of query)defaultchoicesr filename?z3file to read from. optional - defaults to try stdin)nargsr -) argparseArgumentParser__doc__ add_argumentrecompile add_mutually_exclusive_group
parse_argsr )parserdisplayargss !/opt/dedrads/mysql/queryparser.pyr' r'
s
$
$
9F
i
I
( j&
5 ibjj'
2 113G h
7 hK
.
#
B
D }}
K c \ rS rSr% Sr\\S' \\S' \\S' \\S' \\S' S r\S \4S
j5 r \
\ R 4S \
S \
4S
jj5 r\ R 4S\S \
4S jjrSrg) MySQLUser1 z/Holds a user name and tracks numbers of queries
num_select
num_insert
num_update num_replace num_regexc J SU l SU l SU l SU l SU l g )Nr )r0 r1 r2 r3 r4 selfs r+ __init__MySQLUser.__init__: s& r, returnc [ U R U R U R U R U R
45 $ N)sumr0 r1 r2 r3 r4 r6 s r+ num_totalMySQLUser.num_totalA s9
r, qpsregc / SQnU( a UR S5 [ SR S5 SUS9 U HH n[ SSU 3R S5 SUS9 U ( d M* [ SU S 3R S5 SUS9 MJ g )
N)SelUpdInsReplRegexUser endfileNum z/s)appendprintrjust)r@ rA rM colscols r+ headerMySQLUser.headerM sx , KK
fll2 BT2C "C5k''* >sbSE***1-2DA r,
total_secsc ( / SQnU( a UR S5 U Hg n[ U SU 35 n[ S[ U5 R S5 SUS9 US:w d M> [ S[ Xa- 5 S3R S5 SUS9 Mi [ US 9 g )
N)r r r r r num_rJ rO rK r r@ rM )rP getattrrQ strrR int)r7 rW rA rM rS rT vals r+ showMySQLUser.showX s 8 KK C ttC5\2C "c#hnnQ'Rd ;Q3+,-S177: 4r, )r1 r4 r3 r0 r2 N)__name__
__module__ __qualname____firstlineno__r" r] __annotations__r8 propertyr> staticmethodsysstdoutboolrU floatr_ __static_attributes__ r, r+ r. r. 1 s 9OOON
3
*-** BD Bt B B 7:jj u 4 r, r. c \ rS rSrS rS S jr\S\S- 4S j5 r\S\S- 4S j5 r \
S\ S\4S j5 r S
r
S rg)
TimeTrackeri c > S U l S U l [ 5 U l g r< )
first_date last_dater
total_timer6 s r+ r8 TimeTracker.__init__j s &*%)#+r, r: Nc U R nU R nU( a U( a U =R X!-
-
sl g g g r< )first_datetime
last_datetimert )r7 firstlasts r+ add_to_totalTimeTracker.add_to_totalo s4 ##!! T OOt| +O 5r, c \ U R ( a U R U R 5 $ g r< )rr stamp_to_datetimer6 s r+ rw TimeTracker.first_datetimeu s! ??))$//: :r, c \ U R ( a U R U R 5 $ g r< )rs r~ r6 s r+ rx TimeTracker.last_datetime{ s! >>))$..9 9r, mysql_stampc 0 [ R " U S5 $ )z*convert mysql timestamp to datetime objectz%y%m%d %H:%M:%S)r strptime)r s r+ r~ TimeTracker.stamp_to_datetime s .?@@r, c D U R =n( a [ R " 5 U-
nUR 5 n[ SU R
3S[
US- 5 S3[
US- S- 5 S3[
US- 5 S3[ R S9 g [ S 5 g )
NzFirst timestamp at (i z hours,< z minutes,z
seconds ago)rZ z No timestamps found in log file) rw r now
total_secondsrQ rr r] rh stderr)r7 ry
time_deltar s r+ print_ageTimeTracker.print_age s '' '5 '! %/J & 4 4 6M %doo%67C
,-.g6}r)B./0 :}r)*+=9ZZ
3 4r, )rr rs rt )r: N)ra rb rc rd r8 r{ rf r rw rx rg r\ r~ r rl rm r, r+ ro ro i su &
, 4
x$
As Ax A A 5r, ro c r \ rS rSrS\4S jrS\S\R SS4S jr S\R SS4S jr
S
r g) StateTracker r c f SU l SU l Xl 0 U l 0 U l [ 5 U l g )N0 NO_SUCH_USER)query_idusernamer id_table
user_tablero times)r7 r s r+ r8 StateTracker.__init__ s,
&
(*
02 ]
r, linematchr: Nc F UR S5 =n( af U R R ( d; X0R l U R ( a U R R 5 X0R l UR S5 S:X Ga UR S5 U l U R U R ; ac SU; d SU; a g U R R 5 U R R 5 S U R l S U R l UR S5 U l
U R U R U R ' U R U R ; a" [ 5 U R U R ' g g UR S5 S; Ga! UR S5 U l U R U R U l
UR S5 R 5 nUS
:X a- U R U R =R S-
sl g US :X a- U R U R =R S-
sl g US :X a- U R U R =R" S-
sl g US
:X a- U R U R =R$ S-
sl g g UR S5 n U R U U l
g ! [ aF S U l
U R U R ; a! [ 5 U R U R ' GNbf = f! [ aG S U l
U R U R ; a# [ 5 U R U R ' g g f = f)N Connect zAccess denied for userz as on )QueryExecuter r r r r )groupr rr r r rs r r r{ clearr r r. KeyErrorlowerr0 r2 r1 r3 )r7 r r parsed_date
query_typer s r+ handle_matchStateTracker.handle_match s ++a. (; (::(((3
%<<JJ((*#.JJ ;;q>Y & !KKNDM}}
- ,t3yD7H
'')
##%'+
$(,
% !KKNDM ,0==DMM$-- (}}DOO3 2;
. 4 [[^ 3
3 !KKNDM
A !%
dmm <
Q --/JX%
.99Q>9x'
.99Q>9x'
.99Q>9y(
.::a?: ) {{1~H
A !%
h 7
'
A .
==75>[DOODMM2
A(
A .
==75>[DOODMM2 8
As& K< 'M
AA> 3
A> >BBc v U R ( d [ R R 5 ( ai [ 5 U l U R c [ R
" S5 U R ( a& [ SU R S3[ R S9 U R ( a [ U R SSS9$ U R ( a [ S [ R S9 [ R $ ! [ a0 n[ R
" S U R S
U 35 SnANnSnAff = f) zFinds/Opens query logNz/Could not get default log file from /etc/my.cnfz$Reading from the default log file, `'rZ utf-8r )encodingerrorszFailed to open log file `z': z9MySQL general query log parser reading from stdin/pipe...) r rh stdinisattyr exitr rQ r openOSError)r* excs r+ open_logr s ==SYY - - / /$
== HHF G << 6t}}oQGZZ
}} J
J J ||
G
99 J HH0 s3%H I I Js 0C> >
D8&D33D8 query_log
user_regexuserstateout_filec [ R " S5 nU R 5 =n( a UR U5 nU( a UR U5 OS nU( d U( d MR U( a UR XgS9 U( a UR
US9 U( a UR U:X a [ USUS9 U R 5 =n( a M U$ ! [ a [ R " S5 N=f = f)Nz`([0-9]{6}[\s]+[0-9:]+)*[\s]+([0-9]+)\s(Connect|Query|Init DB|Prepare|Execute)[\s]+([a-zA-Z0-9]+))r r )r rJ rK r ) r$ r% readliner searchr r r rQ r rh r ) r r r r r search_rer r
user_matchs r+ parse_logr s
FI $$&
&$
&%0:Z&&t,
Z D 6 # #% # 0 ENNd*
d2 $$&
&$
& L
s - C C65C6sort_byr c ^ U( a g U R R ( d [ R " S5 U R R R 5 nUS LnUS:X a
[
SUS9 [ U R R 5 U4S jS9nU( a [ R US:g XrS9 [
US9 U H/ u p[
U R S5 S US
9 U
R XgUS 9 M1 g ) Nz7Not enough data to parse, please try a longer log file.r z+Not enough timestamps logged to display QPSrZ c " > [ U S T5 $ )Nr )r[ )xr s r+ summarize..L s gadG,r, )key)r@ rA rM rI rJ rK )rW rA rM )r rr rh r rt r rQ sortedr itemsr. rU rR r_ ) r r r r r r rW show_regsorted_entriesr countss ` r+ summarizer : s ;; ! ! JK''557J%HQ
;(K
,N Z1_(J
8 *
hnnR bx8 zh G +r, c [ 5 n U R ( a [ U R SSS9nO[ R nU [ U 5 n[
U R 5 n[ X R U R X15 S S S 5 WR R 5 [ USU R 3UU R U R U R 5 S S S 5 g ! , ( d f Nl= f! , ( d f g = f)Nwr )r rY )r' outputr rh ri r r r r r r r r{ r sort)r* r r r s r+ mainr V s 7C-A C>-
C; 7C>>
D __main__)r" r rh pathlibr r$ r r r typingr pymysql.optionfiler r r' r. ro r r\ r r Patternr rj r r ra rm r, r+ r s %
( 6!H5 5p)5 )5XY6 Y6x cDj b 0
T! *
DH H
H H H
T! H *
H8
, zF r,