import React from 'react'; import { hot } from 'react-hot-loader'; import Select from 'react-select'; import kbn from 'app/core/utils/kbn'; import colors from 'app/core/utils/colors'; import store from 'app/core/store'; import TimeSeries from 'app/core/time_series2'; import { decodePathComponent } from 'app/core/utils/location_util'; import { parse as parseDate } from 'app/core/utils/datemath'; import ElapsedTime from './ElapsedTime'; import QueryRows from './QueryRows'; import Graph from './Graph'; import Logs from './Logs'; import Table from './Table'; import TimePicker, { DEFAULT_RANGE } from './TimePicker'; import { ensureQueries, generateQueryKey, hasQuery } from './utils/query'; const MAX_HISTORY_ITEMS = 100; function makeTimeSeriesList(dataList, options) { return dataList.map((seriesData, index) => { const datapoints = seriesData.datapoints || []; const alias = seriesData.target; const colorIndex = index % colors.length; const color = colors[colorIndex]; const series = new TimeSeries({ datapoints, alias, color, unit: seriesData.unit, }); return series; }); } function parseInitialState(initial: string | undefined) { if (initial) { try { const parsed = JSON.parse(decodePathComponent(initial)); return { datasource: parsed.datasource, queries: parsed.queries.map(q => q.query), range: parsed.range, }; } catch (e) { console.error(e); } } return { datasource: null, queries: [], range: DEFAULT_RANGE }; } interface IExploreState { datasource: any; datasourceError: any; datasourceLoading: boolean | null; datasourceMissing: boolean; graphResult: any; history: any[]; initialDatasource?: string; latency: number; loading: any; logsResult: any; queries: any; queryError: any; range: any; requestOptions: any; showingGraph: boolean; showingLogs: boolean; showingTable: boolean; supportsGraph: boolean | null; supportsLogs: boolean | null; supportsTable: boolean | null; tableResult: any; } export class Explore extends React.Component { el: any; constructor(props) { super(props); const { datasource, queries, range } = parseInitialState(props.routeParams.state); this.state = { datasource: null, datasourceError: null, datasourceLoading: null, datasourceMissing: false, graphResult: null, initialDatasource: datasource, history: [], latency: 0, loading: false, logsResult: null, queries: ensureQueries(queries), queryError: null, range: range || { ...DEFAULT_RANGE }, requestOptions: null, showingGraph: true, showingLogs: true, showingTable: true, supportsGraph: null, supportsLogs: null, supportsTable: null, tableResult: null, ...props.initialState, }; } async componentDidMount() { const { datasourceSrv } = this.props; const { initialDatasource } = this.state; if (!datasourceSrv) { throw new Error('No datasource service passed as props.'); } const datasources = datasourceSrv.getExploreSources(); if (datasources.length > 0) { this.setState({ datasourceLoading: true }); // Priority: datasource in url, default datasource, first explore datasource let datasource; if (initialDatasource) { datasource = await datasourceSrv.get(initialDatasource); } else { datasource = await datasourceSrv.get(); } if (!datasource.meta.explore) { datasource = await datasourceSrv.get(datasources[0].name); } this.setDatasource(datasource); } else { this.setState({ datasourceMissing: true }); } } componentDidCatch(error) { this.setState({ datasourceError: error }); console.error(error); } async setDatasource(datasource) { const supportsGraph = datasource.meta.metrics; const supportsLogs = datasource.meta.logs; const supportsTable = datasource.meta.metrics; const datasourceId = datasource.meta.id; let datasourceError = null; try { const testResult = await datasource.testDatasource(); datasourceError = testResult.status === 'success' ? null : testResult.message; } catch (error) { datasourceError = (error && error.statusText) || error; } const historyKey = `grafana.explore.history.${datasourceId}`; const history = store.getObject(historyKey, []); this.setState( { datasource, datasourceError, history, supportsGraph, supportsLogs, supportsTable, datasourceLoading: false, }, () => datasourceError === null && this.handleSubmit() ); } getRef = el => { this.el = el; }; handleAddQueryRow = index => { const { queries } = this.state; const nextQueries = [ ...queries.slice(0, index + 1), { query: '', key: generateQueryKey() }, ...queries.slice(index + 1), ]; this.setState({ queries: nextQueries }); }; handleChangeDatasource = async option => { this.setState({ datasource: null, datasourceError: null, datasourceLoading: true, graphResult: null, logsResult: null, tableResult: null, }); const datasource = await this.props.datasourceSrv.get(option.value); this.setDatasource(datasource); }; handleChangeQuery = (value, index) => { const { queries } = this.state; const prevQuery = queries[index]; const edited = prevQuery.query !== value; const nextQuery = { ...queries[index], edited, query: value, }; const nextQueries = [...queries]; nextQueries[index] = nextQuery; this.setState({ queries: nextQueries }); }; handleChangeTime = nextRange => { const range = { from: nextRange.from, to: nextRange.to, }; this.setState({ range }, () => this.handleSubmit()); }; handleClickCloseSplit = () => { const { onChangeSplit } = this.props; if (onChangeSplit) { onChangeSplit(false); } }; handleClickGraphButton = () => { this.setState(state => ({ showingGraph: !state.showingGraph })); }; handleClickLogsButton = () => { this.setState(state => ({ showingLogs: !state.showingLogs })); }; handleClickSplit = () => { const { onChangeSplit } = this.props; if (onChangeSplit) { onChangeSplit(true, this.state); } }; handleClickTableButton = () => { this.setState(state => ({ showingTable: !state.showingTable })); }; handleRemoveQueryRow = index => { const { queries } = this.state; if (queries.length <= 1) { return; } const nextQueries = [...queries.slice(0, index), ...queries.slice(index + 1)]; this.setState({ queries: nextQueries }, () => this.handleSubmit()); }; handleSubmit = () => { const { showingLogs, showingGraph, showingTable, supportsGraph, supportsLogs, supportsTable } = this.state; if (showingTable && supportsTable) { this.runTableQuery(); } if (showingGraph && supportsGraph) { this.runGraphQuery(); } if (showingLogs && supportsLogs) { this.runLogsQuery(); } }; onClickClear = () => { this.setState({ graphResult: null, logsResult: null, queries: ensureQueries(), tableResult: null, }); }; onClickTableCell = (columnKey: string, rowValue: string) => { const { datasource, queries } = this.state; if (datasource && datasource.modifyQuery) { const nextQueries = queries.map(q => ({ ...q, edited: false, query: datasource.modifyQuery(q.query, { addFilter: { key: columnKey, value: rowValue } }), })); this.setState({ queries: nextQueries }, () => this.handleSubmit()); } }; onQuerySuccess(datasourceId: string, queries: any[]): void { // save queries to history let { datasource, history } = this.state; if (datasource.meta.id !== datasourceId) { // Navigated away, queries did not matter return; } const ts = Date.now(); queries.forEach(q => { const { query } = q; history = [{ query, ts }, ...history]; }); if (history.length > MAX_HISTORY_ITEMS) { history = history.slice(0, MAX_HISTORY_ITEMS); } // Combine all queries of a datasource type into one history const historyKey = `grafana.explore.history.${datasourceId}`; store.setObject(historyKey, history); this.setState({ history }); } buildQueryOptions(targetOptions: { format: string; instant?: boolean }) { const { datasource, queries, range } = this.state; const resolution = this.el.offsetWidth; const absoluteRange = { from: parseDate(range.from, false), to: parseDate(range.to, true), }; const { interval } = kbn.calculateInterval(absoluteRange, resolution, datasource.interval); const targets = queries.map(q => ({ ...targetOptions, expr: q.query, })); return { interval, range, targets, }; } async runGraphQuery() { const { datasource, queries } = this.state; if (!hasQuery(queries)) { return; } this.setState({ latency: 0, loading: true, graphResult: null, queryError: null }); const now = Date.now(); const options = this.buildQueryOptions({ format: 'time_series', instant: false }); try { const res = await datasource.query(options); const result = makeTimeSeriesList(res.data, options); const latency = Date.now() - now; this.setState({ latency, loading: false, graphResult: result, requestOptions: options }); this.onQuerySuccess(datasource.meta.id, queries); } catch (response) { console.error(response); const queryError = response.data ? response.data.error : response; this.setState({ loading: false, queryError }); } } async runTableQuery() { const { datasource, queries } = this.state; if (!hasQuery(queries)) { return; } this.setState({ latency: 0, loading: true, queryError: null, tableResult: null }); const now = Date.now(); const options = this.buildQueryOptions({ format: 'table', instant: true, }); try { const res = await datasource.query(options); const tableModel = res.data[0]; const latency = Date.now() - now; this.setState({ latency, loading: false, tableResult: tableModel, requestOptions: options }); this.onQuerySuccess(datasource.meta.id, queries); } catch (response) { console.error(response); const queryError = response.data ? response.data.error : response; this.setState({ loading: false, queryError }); } } async runLogsQuery() { const { datasource, queries } = this.state; if (!hasQuery(queries)) { return; } this.setState({ latency: 0, loading: true, queryError: null, logsResult: null }); const now = Date.now(); const options = this.buildQueryOptions({ format: 'logs', }); try { const res = await datasource.query(options); const logsData = res.data; const latency = Date.now() - now; this.setState({ latency, loading: false, logsResult: logsData, requestOptions: options }); this.onQuerySuccess(datasource.meta.id, queries); } catch (response) { console.error(response); const queryError = response.data ? response.data.error : response; this.setState({ loading: false, queryError }); } } request = url => { const { datasource } = this.state; return datasource.metadataRequest(url); }; render() { const { datasourceSrv, position, split } = this.props; const { datasource, datasourceError, datasourceLoading, datasourceMissing, graphResult, history, latency, loading, logsResult, queries, queryError, range, requestOptions, showingGraph, showingLogs, showingTable, supportsGraph, supportsLogs, supportsTable, tableResult, } = this.state; const showingBoth = showingGraph && showingTable; const graphHeight = showingBoth ? '200px' : '400px'; const graphButtonActive = showingBoth || showingGraph ? 'active' : ''; const logsButtonActive = showingLogs ? 'active' : ''; const tableButtonActive = showingBoth || showingTable ? 'active' : ''; const exploreClass = split ? 'explore explore-split' : 'explore'; const datasources = datasourceSrv.getExploreSources().map(ds => ({ value: ds.name, label: ds.name, })); const selectedDatasource = datasource ? datasource.name : undefined; return (
{position === 'left' ? (
Explore
) : (
)} {!datasourceMissing ? (