7x31
/
sniffer-agent
mirror of https://github.com/zr-hebo/sniffer-agent.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

change begin time to timestamp

This commit is contained in:
hebo 2019-08-23 15:36:57 +08:00
parent 29abb4a212
commit 18845f8278
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
README.md
View File

@ -21,9 +21,9 @@ sniffer-agent采用模块化结构，支持用户添加自己的解析模块，
目前输出的内容都是解析结果组成的json。 目前输出的内容都是解析结果组成的json。
MySQL协议的解析结果示例如下： MySQL协议的解析结果示例如下：
``` ```
{"cip":"192.168.XXX.XXX","cport":63888,"sip":"192.168.XX.XX","sport":3306,"user":"root","db":"sniffer","sql":"show tables","bt":"2019-08-05 18:23:09","cms":15} {"cip":"192.168.XXX.XXX","cport":63888,"sip":"192.168.XX.XX","sport":3306,"user":"root","db":"sniffer","sql":"show tables","bt":"1566545734147","cms":15}
``` ```
其中cip代表客户端ip，cport代表客户端port(客户端ip：port组成session标识)，sip代表server ip，sport代表server port，user代表查询用户，db代表当前连接的库名，sql代表查询语句，bt代表查询开始时间，cms代表查询消耗的时间，单位是毫秒 其中cip代表客户端ip，cport代表客户端port(客户端ip：port组成session标识)，sip代表server ip，sport代表server port，user代表查询用户，db代表当前连接的库名，sql代表查询语句，bt代表查询开始时间戳，cms代表查询消耗的时间，单位是毫秒
### Exporter ### Exporter

4
model/query_piece.go
View File

@ -27,7 +27,7 @@ type MysqlQueryPiece struct {
VisitUser *string `json:"user"` VisitUser *string `json:"user"`
VisitDB *string `json:"db"` VisitDB *string `json:"db"`
QuerySQL *string `json:"sql"` QuerySQL *string `json:"sql"`
BeginTime string `json:"bt"` BeginTime int64 `json:"bt"`
CostTimeInMS int64 `json:"cms"` CostTimeInMS int64 `json:"cms"`
} }
@ -66,7 +66,7 @@ func NewPooledMysqlQueryPiece(
mqp.VisitUser = visitUser mqp.VisitUser = visitUser
mqp.VisitDB = visitDB mqp.VisitDB = visitDB
mqp.SyncSend = false mqp.SyncSend = false
mqp.BeginTime = time.Unix(stmtBeginTime/1000, 0).Format(datetimeFormat) mqp.BeginTime = stmtBeginTime
mqp.CostTimeInMS = nowInMS - stmtBeginTime mqp.CostTimeInMS = nowInMS - stmtBeginTime
mqp.recoverPool = mqpp mqp.recoverPool = mqpp