@@ -11,6 +11,7 @@ import (
11
11
"net/http"
12
12
"net/url"
13
13
"path"
14
+ "strings"
14
15
"sync"
15
16
"time"
16
17
@@ -23,6 +24,8 @@ import (
23
24
"github.com/weaveworks/common/httpgrpc"
24
25
"github.com/weaveworks/common/httpgrpc/server"
25
26
"github.com/weaveworks/common/user"
27
+
28
+ "github.com/cortexproject/cortex/pkg/util"
26
29
)
27
30
28
31
const (
@@ -152,27 +155,26 @@ func (f *Frontend) Handler() http.Handler {
152
155
}
153
156
154
157
func (f * Frontend ) handle (w http.ResponseWriter , r * http.Request ) {
155
- userID , err := user .ExtractOrgID (r .Context ())
156
- if err != nil {
157
- server .WriteError (w , err )
158
- return
159
- }
160
158
161
159
startTime := time .Now ()
162
160
resp , err := f .roundTripper .RoundTrip (r )
163
161
queryResponseTime := time .Since (startTime )
164
162
165
163
if f .cfg .LogQueriesLongerThan > 0 && queryResponseTime > f .cfg .LogQueriesLongerThan {
166
- logMessage := []interface {}{"msg" , "slow query" ,
167
- "org_id" , userID ,
168
- "url" , fmt .Sprintf ("http://%s" , r .Host + r .RequestURI ),
164
+ logMessage := []interface {}{
165
+ "msg" , "slow query" ,
166
+ "host" , r .Host ,
167
+ "path" , r .URL .Path ,
169
168
"time_taken" , queryResponseTime .String (),
170
169
}
170
+ for k , v := range r .URL .Query () {
171
+ append (logMessage , fmt .Sprintf ("qs_%s" , k ), strings .Join (v , "," ))
172
+ }
171
173
pf := r .PostForm .Encode ()
172
174
if pf != "" {
173
175
logMessage = append (logMessage , "body" , pf )
174
176
}
175
- level .Info (f . log ).Log (logMessage ... )
177
+ level .Info (util . WithContext ( r . Context (), util . Logger ) ).Log (logMessage ... )
176
178
}
177
179
178
180
if err != nil {
0 commit comments