github/skywalking-booster-ui
2
0
Fork 1
mirror of https://github.com/apache/skywalking-booster-ui.git synced 2025-06-30 06:27:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

split query

Browse Source
This commit is contained in:
Fine 2024-11-12 17:34:01 +08:00
parent 64d4a2b59b
commit c05f415139
2 changed files with 27 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/hooks/data.ts
View File

@ -112,3 +112,5 @@ export const LightChartColors = [
"#546570", "#546570",
"#c4ccd3", "#c4ccd3",
]; ];
export const MaxQueryLength = 3000;

36
src/hooks/useExpressionsProcessor.ts
View File

@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and * See the License for the specific language governing permissions and
* limitations under the License. * limitations under the License.
*/ */
import { RespFields, MaximumEntities } from "./data"; import { RespFields, MaximumEntities, MaxQueryLength } from "./data";
import { EntityType, ExpressionResultType } from "@/views/dashboard/data"; import { EntityType, ExpressionResultType } from "@/views/dashboard/data";
import { ElMessage } from "element-plus"; import { ElMessage } from "element-plus";
import { useDashboardStore } from "@/store/modules/dashboard"; import { useDashboardStore } from "@/store/modules/dashboard";
@ -24,6 +24,14 @@ 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";
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;
}
export async function useDashboardQueryProcessor(configList: 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])) {
@ -181,13 +189,6 @@ export async function useDashboardQueryProcessor(configList: Indexable[]) {
return { 0: { source: {}, tips: [], typesOfMQE: [] } }; 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 partArr = chunkArray(configList, 6);
const promiseArr = partArr.map((d: Array<Indexable>) => fetchMetrics(d)); const promiseArr = partArr.map((d: Array<Indexable>) => fetchMetrics(d));
@ -390,11 +391,11 @@ export async function useExpressionsQueryPodsMetrics(
return resp; return resp;
} }
export function useQueryTopologyExpressionsProcessor(metrics: string[], instances: (Call | Node)[]) { export async function useQueryTopologyExpressionsProcessor(metrics: string[], instances: (Call | Node)[]) {
const appStore = useAppStoreWithOut(); const appStore = useAppStoreWithOut();
const dashboardStore = useDashboardStore(); const dashboardStore = useDashboardStore();
function getExpressionQuery() { function getExpressionQuery(partMetrics: string[]) {
const conditions: { [key: string]: unknown } = { const conditions: { [key: string]: unknown } = {
duration: appStore.durationTime, duration: appStore.durationTime,
}; };
@ -448,7 +449,7 @@ export function useQueryTopologyExpressionsProcessor(metrics: string[], instance
}; };
variables.push(`$entity${index}: Entity!`); variables.push(`$entity${index}: Entity!`);
conditions[`entity${index}`] = entity; conditions[`entity${index}`] = entity;
const f = metrics.map((name: string, idx: number) => { const f = partMetrics.map((name: string, idx: number) => {
if (index === 0) { if (index === 0) {
variables.push(`$expression${idx}: String!`); variables.push(`$expression${idx}: String!`);
conditions[`expression${idx}`] = name; conditions[`expression${idx}`] = name;
@ -483,5 +484,18 @@ export function useQueryTopologyExpressionsProcessor(metrics: string[], instance
return obj; return obj;
} }
const count = Math.floor(MaxQueryLength / instances.length);
const metricsArr = chunkArray(metrics, count);
const promiseArr = metricsArr.map((d: Array<string>) => getExpressionQuery(d));
const responseList = await Promise.all(promiseArr);
let resp = {};
for (const item of responseList) {
resp = {
...resp,
...item,
};
}
return { getExpressionQuery, handleExpressionValues }; return { getExpressionQuery, handleExpressionValues };
} }