mirror of
https://github.com/grafana/grafana.git
synced 2025-07-28 06:52:08 +08:00
69 lines
1.6 KiB
Go
69 lines
1.6 KiB
Go
package api
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/grafana/grafana/pkg/api/pluginproxy"
|
|
"github.com/grafana/grafana/pkg/bus"
|
|
"github.com/grafana/grafana/pkg/metrics"
|
|
m "github.com/grafana/grafana/pkg/models"
|
|
"github.com/grafana/grafana/pkg/plugins"
|
|
)
|
|
|
|
const HeaderNameNoBackendCache = "X-Grafana-NoCache"
|
|
|
|
func (hs *HTTPServer) getDatasourceByID(id int64, orgID int64, nocache bool) (*m.DataSource, error) {
|
|
cacheKey := fmt.Sprintf("ds-%d", id)
|
|
|
|
if !nocache {
|
|
if cached, found := hs.cache.Get(cacheKey); found {
|
|
ds := cached.(*m.DataSource)
|
|
if ds.OrgId == orgID {
|
|
return ds, nil
|
|
}
|
|
}
|
|
}
|
|
|
|
query := m.GetDataSourceByIdQuery{Id: id, OrgId: orgID}
|
|
if err := bus.Dispatch(&query); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
hs.cache.Set(cacheKey, query.Result, time.Second*5)
|
|
return query.Result, nil
|
|
}
|
|
|
|
func (hs *HTTPServer) ProxyDataSourceRequest(c *m.ReqContext) {
|
|
c.TimeRequest(metrics.M_DataSource_ProxyReq_Timer)
|
|
|
|
nocache := c.Req.Header.Get(HeaderNameNoBackendCache) == "true"
|
|
|
|
ds, err := hs.getDatasourceByID(c.ParamsInt64(":id"), c.OrgId, nocache)
|
|
|
|
if err != nil {
|
|
c.JsonApiErr(500, "Unable to load datasource meta data", err)
|
|
return
|
|
}
|
|
|
|
// find plugin
|
|
plugin, ok := plugins.DataSources[ds.Type]
|
|
if !ok {
|
|
c.JsonApiErr(500, "Unable to find datasource plugin", err)
|
|
return
|
|
}
|
|
|
|
proxyPath := c.Params("*")
|
|
|
|
// Check for a trailing slash
|
|
if len(proxyPath) > 1 {
|
|
path := c.Req.URL.Path
|
|
if path[len(path)-1] == '/' && path[len(path)-2] != '/' {
|
|
proxyPath += "/"
|
|
}
|
|
}
|
|
|
|
proxy := pluginproxy.NewDataSourceProxy(ds, plugin, c, proxyPath)
|
|
proxy.HandleRequest()
|
|
}
|