diff --git a/README.md b/README.md index 0f560bd..49479ed 100644 --- a/README.md +++ b/README.md @@ -21,9 +21,9 @@ sniffer-agent采用模块化结构,支持用户添加自己的解析模块, 目前输出的内容都是解析结果组成的json。 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 diff --git a/model/query_piece.go b/model/query_piece.go index b25fadb..10eb1b6 100644 --- a/model/query_piece.go +++ b/model/query_piece.go @@ -27,7 +27,7 @@ type MysqlQueryPiece struct { VisitUser *string `json:"user"` VisitDB *string `json:"db"` QuerySQL *string `json:"sql"` - BeginTime string `json:"bt"` + BeginTime int64 `json:"bt"` CostTimeInMS int64 `json:"cms"` } @@ -66,7 +66,7 @@ func NewPooledMysqlQueryPiece( mqp.VisitUser = visitUser mqp.VisitDB = visitDB mqp.SyncSend = false - mqp.BeginTime = time.Unix(stmtBeginTime/1000, 0).Format(datetimeFormat) + mqp.BeginTime = stmtBeginTime mqp.CostTimeInMS = nowInMS - stmtBeginTime mqp.recoverPool = mqpp