remove excess debug logging
This commit is contained in:
@@ -81,7 +81,6 @@ func (ds *ZabbixDatasource) QueryData(ctx context.Context, req *backend.QueryDat
|
|||||||
res := backend.DataResponse{}
|
res := backend.DataResponse{}
|
||||||
query, err := ReadQuery(q)
|
query, err := ReadQuery(q)
|
||||||
ds.logger.Debug("DS query", "query", q)
|
ds.logger.Debug("DS query", "query", q)
|
||||||
ds.logger.Debug("DS query parsed", "query", query)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
res.Error = err
|
res.Error = err
|
||||||
} else if len(query.Functions) > 0 {
|
} else if len(query.Functions) > 0 {
|
||||||
@@ -90,7 +89,6 @@ func (ds *ZabbixDatasource) QueryData(ctx context.Context, req *backend.QueryDat
|
|||||||
res.Error = errors.New("Non-metrics queries are not supported")
|
res.Error = errors.New("Non-metrics queries are not supported")
|
||||||
} else {
|
} else {
|
||||||
frame, err := zabbixDS.queryNumericItems(ctx, &query)
|
frame, err := zabbixDS.queryNumericItems(ctx, &query)
|
||||||
ds.logger.Debug("DS got frame", "frame", frame)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
res.Error = err
|
res.Error = err
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
@@ -16,8 +16,6 @@ func (ds *ZabbixDatasource) rootHandler(rw http.ResponseWriter, req *http.Reques
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (ds *ZabbixDatasource) zabbixAPIHandler(rw http.ResponseWriter, req *http.Request) {
|
func (ds *ZabbixDatasource) zabbixAPIHandler(rw http.ResponseWriter, req *http.Request) {
|
||||||
ds.logger.Debug("Received resource call", "url", req.URL.String(), "method", req.Method)
|
|
||||||
|
|
||||||
if req.Method != http.MethodPost {
|
if req.Method != http.MethodPost {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@@ -38,14 +36,14 @@ func (ds *ZabbixDatasource) zabbixAPIHandler(rw http.ResponseWriter, req *http.R
|
|||||||
}
|
}
|
||||||
|
|
||||||
pluginCxt := httpadapter.PluginConfigFromContext(req.Context())
|
pluginCxt := httpadapter.PluginConfigFromContext(req.Context())
|
||||||
|
|
||||||
dsInstance, err := ds.GetDatasource(pluginCxt)
|
dsInstance, err := ds.GetDatasource(pluginCxt)
|
||||||
ds.logger.Debug("Data source found", "ds", dsInstance.dsInfo.Name)
|
|
||||||
|
|
||||||
ds.logger.Debug("Invoke Zabbix API call", "ds", pluginCxt.DataSourceInstanceSettings.Name, "method", reqData.Method)
|
ds.logger.Debug("Invoke Zabbix API call", "ds", pluginCxt.DataSourceInstanceSettings.Name, "method", reqData.Method)
|
||||||
apiReq := &ZabbixAPIRequest{Method: reqData.Method, Params: reqData.Params}
|
apiReq := &ZabbixAPIRequest{Method: reqData.Method, Params: reqData.Params}
|
||||||
|
|
||||||
result, err := dsInstance.ZabbixAPIQuery(req.Context(), apiReq)
|
result, err := dsInstance.ZabbixAPIQuery(req.Context(), apiReq)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
ds.logger.Error("Zabbix API request error", "error", err)
|
||||||
WriteError(rw, http.StatusInternalServerError, err)
|
WriteError(rw, http.StatusInternalServerError, err)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -14,18 +14,16 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
// ZabbixAPIQuery handles query requests to Zabbix
|
// ZabbixAPIQuery handles query requests to Zabbix
|
||||||
func (dsInstance *ZabbixDatasourceInstance) ZabbixAPIQuery(ctx context.Context, apiReq *ZabbixAPIRequest) (*ZabbixAPIResourceResponse, error) {
|
func (ds *ZabbixDatasourceInstance) ZabbixAPIQuery(ctx context.Context, apiReq *ZabbixAPIRequest) (*ZabbixAPIResourceResponse, error) {
|
||||||
var result interface{}
|
var result interface{}
|
||||||
var err error
|
var err error
|
||||||
var queryExistInCache bool
|
var queryExistInCache bool
|
||||||
result, queryExistInCache = dsInstance.queryCache.Get(HashString(apiReq.String()))
|
result, queryExistInCache = ds.queryCache.Get(HashString(apiReq.String()))
|
||||||
|
|
||||||
if !queryExistInCache {
|
if !queryExistInCache {
|
||||||
result, err = dsInstance.ZabbixRequest(ctx, apiReq.Method, apiReq.Params)
|
result, err = ds.ZabbixRequest(ctx, apiReq.Method, apiReq.Params)
|
||||||
// dsInstance.logger.Debug("ZabbixAPIQuery", "result", result)
|
ds.queryCache.Set(HashString(apiReq.String()), result)
|
||||||
dsInstance.queryCache.Set(HashString(apiReq.String()), result)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
dsInstance.logger.Debug("ZabbixAPIQuery", "error", err)
|
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -52,37 +50,25 @@ func (ds *ZabbixDatasourceInstance) TestConnection(ctx context.Context) (string,
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (ds *ZabbixDatasourceInstance) queryNumericItems(ctx context.Context, query *QueryModel) (*data.Frame, error) {
|
func (ds *ZabbixDatasourceInstance) queryNumericItems(ctx context.Context, query *QueryModel) (*data.Frame, error) {
|
||||||
tStart := time.Now()
|
|
||||||
|
|
||||||
groupFilter := query.Group.Filter
|
groupFilter := query.Group.Filter
|
||||||
hostFilter := query.Host.Filter
|
hostFilter := query.Host.Filter
|
||||||
appFilter := query.Application.Filter
|
appFilter := query.Application.Filter
|
||||||
itemFilter := query.Item.Filter
|
itemFilter := query.Item.Filter
|
||||||
|
|
||||||
ds.logger.Debug("queryNumericItems",
|
|
||||||
"func", "ds.getItems",
|
|
||||||
"groupFilter", groupFilter,
|
|
||||||
"hostFilter", hostFilter,
|
|
||||||
"appFilter", appFilter,
|
|
||||||
"itemFilter", itemFilter)
|
|
||||||
items, err := ds.getItems(ctx, groupFilter, hostFilter, appFilter, itemFilter, "num")
|
items, err := ds.getItems(ctx, groupFilter, hostFilter, appFilter, itemFilter, "num")
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
ds.logger.Debug("queryNumericItems", "finished", "ds.getItems", "timeElapsed", time.Now().Sub(tStart))
|
|
||||||
|
|
||||||
frames, err := ds.queryNumericDataForItems(ctx, query, items)
|
frames, err := ds.queryNumericDataForItems(ctx, query, items)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
ds.logger.Debug("queryNumericItems", "finished", "queryNumericDataForItems", "timeElapsed", time.Now().Sub(tStart))
|
|
||||||
|
|
||||||
return frames, nil
|
return frames, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func (ds *ZabbixDatasourceInstance) getItems(ctx context.Context, groupFilter string, hostFilter string, appFilter string, itemFilter string, itemType string) (zabbix.Items, error) {
|
func (ds *ZabbixDatasourceInstance) getItems(ctx context.Context, groupFilter string, hostFilter string, appFilter string, itemFilter string, itemType string) (zabbix.Items, error) {
|
||||||
tStart := time.Now()
|
|
||||||
|
|
||||||
hosts, err := ds.getHosts(ctx, groupFilter, hostFilter)
|
hosts, err := ds.getHosts(ctx, groupFilter, hostFilter)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -91,7 +77,6 @@ func (ds *ZabbixDatasourceInstance) getItems(ctx context.Context, groupFilter st
|
|||||||
for _, k := range hosts {
|
for _, k := range hosts {
|
||||||
hostids = append(hostids, k["hostid"].(string))
|
hostids = append(hostids, k["hostid"].(string))
|
||||||
}
|
}
|
||||||
ds.logger.Debug("getItems", "finished", "getHosts", "timeElapsed", time.Now().Sub(tStart))
|
|
||||||
|
|
||||||
apps, err := ds.getApps(ctx, groupFilter, hostFilter, appFilter)
|
apps, err := ds.getApps(ctx, groupFilter, hostFilter, appFilter)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -101,17 +86,13 @@ func (ds *ZabbixDatasourceInstance) getItems(ctx context.Context, groupFilter st
|
|||||||
for _, l := range apps {
|
for _, l := range apps {
|
||||||
appids = append(appids, l["applicationid"].(string))
|
appids = append(appids, l["applicationid"].(string))
|
||||||
}
|
}
|
||||||
ds.logger.Debug("getItems", "finished", "getApps", "timeElapsed", time.Now().Sub(tStart))
|
|
||||||
|
|
||||||
var allItems *simplejson.Json
|
var allItems *simplejson.Json
|
||||||
if len(hostids) > 0 {
|
if len(hostids) > 0 {
|
||||||
ds.logger.Debug("getAllItems", "with", "hostFilter")
|
|
||||||
allItems, err = ds.getAllItems(ctx, hostids, nil, itemType)
|
allItems, err = ds.getAllItems(ctx, hostids, nil, itemType)
|
||||||
} else if len(appids) > 0 {
|
} else if len(appids) > 0 {
|
||||||
ds.logger.Debug("getAllItems", "with", "appFilter")
|
|
||||||
allItems, err = ds.getAllItems(ctx, nil, appids, itemType)
|
allItems, err = ds.getAllItems(ctx, nil, appids, itemType)
|
||||||
}
|
}
|
||||||
ds.logger.Debug("getItems", "finished", "getAllItems", "timeElapsed", time.Now().Sub(tStart))
|
|
||||||
|
|
||||||
var items zabbix.Items
|
var items zabbix.Items
|
||||||
|
|
||||||
@@ -147,8 +128,6 @@ func (ds *ZabbixDatasourceInstance) getItems(ctx context.Context, groupFilter st
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
ds.logger.Debug("getItems", "found", len(items), "matches", len(filteredItems))
|
|
||||||
ds.logger.Debug("getItems", "totalTimeTaken", time.Now().Sub(tStart))
|
|
||||||
return filteredItems, nil
|
return filteredItems, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -182,7 +161,6 @@ func (ds *ZabbixDatasourceInstance) getApps(ctx context.Context, groupFilter str
|
|||||||
apps = append(apps, i.(map[string]interface{}))
|
apps = append(apps, i.(map[string]interface{}))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
ds.logger.Debug("getapps", "found", len(allApps.MustArray()), "matches", len(apps))
|
|
||||||
return apps, nil
|
return apps, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -217,7 +195,7 @@ func (ds *ZabbixDatasourceInstance) getHosts(ctx context.Context, groupFilter st
|
|||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
ds.logger.Debug("getHosts", "found", len(allHosts.MustArray()), "matches", len(hosts))
|
|
||||||
return hosts, nil
|
return hosts, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -308,7 +286,6 @@ func (ds *ZabbixDatasourceInstance) queryNumericDataForItems(ctx context.Context
|
|||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
ds.logger.Debug("Got history", "len", len(history), "items", len(items))
|
|
||||||
return convertHistory(history, items), nil
|
return convertHistory(history, items), nil
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -338,7 +315,6 @@ func (ds *ZabbixDatasourceInstance) getConsolidateBy(query *QueryModel) string {
|
|||||||
func (ds *ZabbixDatasourceInstance) getHistotyOrTrend(ctx context.Context, query *QueryModel, items zabbix.Items) (zabbix.History, error) {
|
func (ds *ZabbixDatasourceInstance) getHistotyOrTrend(ctx context.Context, query *QueryModel, items zabbix.Items) (zabbix.History, error) {
|
||||||
timeRange := query.TimeRange
|
timeRange := query.TimeRange
|
||||||
useTrend := ds.isUseTrend(timeRange)
|
useTrend := ds.isUseTrend(timeRange)
|
||||||
ds.logger.Debug("Use trends", "use", useTrend)
|
|
||||||
allHistory := zabbix.History{}
|
allHistory := zabbix.History{}
|
||||||
|
|
||||||
groupedItems := map[int]zabbix.Items{}
|
groupedItems := map[int]zabbix.Items{}
|
||||||
|
|||||||
@@ -9,7 +9,6 @@ import (
|
|||||||
"io"
|
"io"
|
||||||
"io/ioutil"
|
"io/ioutil"
|
||||||
"net/http"
|
"net/http"
|
||||||
"time"
|
|
||||||
|
|
||||||
simplejson "github.com/bitly/go-simplejson"
|
simplejson "github.com/bitly/go-simplejson"
|
||||||
"golang.org/x/net/context/ctxhttp"
|
"golang.org/x/net/context/ctxhttp"
|
||||||
@@ -116,15 +115,11 @@ func (ds *ZabbixDatasourceInstance) ZabbixAPIRequest(ctx context.Context, method
|
|||||||
Body: rc,
|
Body: rc,
|
||||||
}
|
}
|
||||||
|
|
||||||
tStart := time.Now()
|
|
||||||
response, err := makeHTTPRequest(ctx, ds.httpClient, req)
|
response, err := makeHTTPRequest(ctx, ds.httpClient, req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
|
|
||||||
requestTime := time.Now().Sub(tStart)
|
|
||||||
ds.logger.Debug("Response from Zabbix Request", "method", method, "params", params, "duration", requestTime)
|
|
||||||
|
|
||||||
return handleAPIResult(response)
|
return handleAPIResult(response)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user