|
@@ -20,7 +20,7 @@ var (
|
|
|
saveLogsLock = &sync.Mutex{}
|
|
saveLogsLock = &sync.Mutex{}
|
|
|
)
|
|
)
|
|
|
|
|
|
|
|
-func AddMgoLogs(mgoLog mongodb.MongodbSim, r *http.Request, tableName string, ExcludeUrl []*regexp.Regexp) {
|
|
|
|
|
|
|
+func AddMgoLogs(mgoLog mongodb.MongodbSim, r *http.Request, tableName string, ExcludeUrl []*regexp.Regexp, c int) {
|
|
|
for _, v := range ExcludeUrl {
|
|
for _, v := range ExcludeUrl {
|
|
|
// 过滤无意义路由日志
|
|
// 过滤无意义路由日志
|
|
|
if v.MatchString(r.URL.Path) {
|
|
if v.MatchString(r.URL.Path) {
|
|
@@ -52,7 +52,7 @@ func AddMgoLogs(mgoLog mongodb.MongodbSim, r *http.Request, tableName string, Ex
|
|
|
}
|
|
}
|
|
|
saveLogsLock.Lock()
|
|
saveLogsLock.Lock()
|
|
|
arr[tableName] = append(arr[tableName], logs)
|
|
arr[tableName] = append(arr[tableName], logs)
|
|
|
- if len(arr[tableName]) >= 500 {
|
|
|
|
|
|
|
+ if len(arr[tableName]) >= c {
|
|
|
tmp := arr[tableName]
|
|
tmp := arr[tableName]
|
|
|
arr[tableName] = make([]map[string]interface{}, 0)
|
|
arr[tableName] = make([]map[string]interface{}, 0)
|
|
|
go func() {
|
|
go func() {
|
