github/skywalking-booster-ui
2
0
Fork 1
mirror of https://github.com/apache/skywalking-booster-ui.git synced 2025-05-12 15:52:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: chunk queries

Browse Source
This commit is contained in:
Fine 2024-08-22 15:37:05 +08:00
parent 4afd208177
commit 703d98998e
1 changed files with 63 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

104
src/hooks/useExpressionsProcessor.ts
View File

@ -24,7 +24,7 @@ import type { MetricConfigOpt } from "@/types/dashboard";
import type { Instance, Endpoint, Service } from "@/types/selector"; import type { Instance, Endpoint, Service } from "@/types/selector";
import type { Node, Call } from "@/types/topology"; import type { Node, Call } from "@/types/topology";
export async function useDashboardQueryProcessor(configArr: Indexable[]) { export async function useDashboardQueryProcessor(configList: Indexable[]) {
function expressionsGraphql(config: Indexable, idx: number) { function expressionsGraphql(config: Indexable, idx: number) {
if (!(config.metrics && config.metrics[0])) { if (!(config.metrics && config.metrics[0])) {
return; return;
@ -135,50 +135,72 @@ export async function useDashboardQueryProcessor(configArr: Indexable[]) {
return { source, tips, typesOfMQE }; return { source, tips, typesOfMQE };
} }
const appStore = useAppStoreWithOut(); async function fetchMetrics(configArr: any) {
const variables: string[] = [`$duration: Duration!`]; const appStore = useAppStoreWithOut();
let fragments = ""; const variables: string[] = [`$duration: Duration!`];
let conditions: Recordable = { let fragments = "";
duration: appStore.durationTime, let conditions: Recordable = {
}; duration: appStore.durationTime,
for (let i = 0; i < configArr.length; i++) { };
const params = await expressionsGraphql(configArr[i], i);
if (params) {
fragments += params?.fragment;
conditions = { ...conditions, ...params.conditions };
variables.push(...params.variables);
}
}
if (!fragments) {
return { 0: { source: {}, tips: [], typesOfMQE: [] } };
}
const queryStr = `query queryData(${variables}) {${fragments}}`;
const dashboardStore = useDashboardStore();
const json = await dashboardStore.fetchMetricValue({
queryStr,
conditions,
});
if (json.errors) {
ElMessage.error(json.errors);
return { 0: { source: {}, tips: [], typesOfMQE: [] } };
}
try {
const pageData: Recordable = {};
for (let i = 0; i < configArr.length; i++) { for (let i = 0; i < configArr.length; i++) {
const resp: any = {}; const params = await expressionsGraphql(configArr[i], i);
for (let m = 0; m < configArr[i].metrics.length; m++) { if (params) {
resp[`expression${i}${m}`] = json.data[`expression${i}${m}`]; fragments += params?.fragment;
conditions = { ...conditions, ...params.conditions };
variables.push(...params.variables);
} }
const data = expressionsSource(configArr[i], { ...json, data: resp });
const id = configArr[i].id;
pageData[id] = data;
} }
return pageData; if (!fragments) {
} catch (error) { return { 0: { source: {}, tips: [], typesOfMQE: [] } };
console.error(error); }
return { 0: { source: {}, tips: [], typesOfMQE: [] } }; const queryStr = `query queryData(${variables}) {${fragments}}`;
const dashboardStore = useDashboardStore();
const json = await dashboardStore.fetchMetricValue({
queryStr,
conditions,
});
if (json.errors) {
ElMessage.error(json.errors);
return { 0: { source: {}, tips: [], typesOfMQE: [] } };
}
try {
const pageData: Recordable = {};
for (let i = 0; i < configArr.length; i++) {
const resp: any = {};
for (let m = 0; m < configArr[i].metrics.length; m++) {
resp[`expression${i}${m}`] = json.data[`expression${i}${m}`];
}
const data = expressionsSource(configArr[i], { ...json, data: resp });
const id = configArr[i].id;
pageData[id] = data;
}
return pageData;
} catch (error) {
console.error(error);
return { 0: { source: {}, tips: [], typesOfMQE: [] } };
}
} }
function chunkArray(array: any[], chunkSize: number) {
const result = [];
for (let i = 0; i < array.length; i += chunkSize) {
result.push(array.slice(i, i + chunkSize));
}
return result;
}
const partArr = chunkArray(configList, 6);
const promiseArr = partArr.map((d: Array<Indexable>) => fetchMetrics(d));
const responseList = await Promise.all(promiseArr);
let resp = {};
for (const item of responseList) {
resp = {
...resp,
...item,
};
}
return resp;
} }
export async function useExpressionsQueryPodsMetrics( export async function useExpressionsQueryPodsMetrics(