Compare commits

..

No commits in common. "c83bbd41498b8a73b3f7941209772bd4f1f1e43f" and "f4feb6349f2c726241deeb072a2bdbfd6bc715ea" have entirely different histories.

9 changed files with 31 additions and 94 deletions

1
.env
View File

@ -1 +0,0 @@
#PROMETHEUS_API=http://192.168.2.34:9090/api/v1

View File

@ -8,6 +8,4 @@ RUN npm install
COPY . . COPY . .
ENV NODE_ENV=development
CMD ["npm", "run", "start:dev"] CMD ["npm", "run", "start:dev"]

3
Jenkinsfile vendored
View File

@ -41,6 +41,7 @@ pipeline {
always { always {
script { script {
echo "Cleaning up workspace..." echo "Cleaning up workspace..."
sh "rm -rf ${env.WORKSPACE}/package/ || true"
sh "rm -rf ${env.WORKSPACE}/rc/ || true" sh "rm -rf ${env.WORKSPACE}/rc/ || true"
} }
} }
@ -55,7 +56,7 @@ pipeline {
-u "${GITEA_USER}:${GITEA_PASS}" \ -u "${GITEA_USER}:${GITEA_PASS}" \
-H "Content-Type: application/json" \ -H "Content-Type: application/json" \
-d '{"do":"merge"}' \ -d '{"do":"merge"}' \
http://git.entcor/api/v1/repos/deployer3000/trust-module-backend/pulls/${prId}/merge http://git.entcor/api/v1/repos/DmitriyA/trust-module-backend/pulls/${prId}/merge
""" """
echo "PR ${prId} merged successfully into master!" echo "PR ${prId} merged successfully into master!"
} }

View File

@ -23,11 +23,9 @@
"@nestjs/axios": "^4.0.0", "@nestjs/axios": "^4.0.0",
"@nestjs/common": "^11.0.1", "@nestjs/common": "^11.0.1",
"@nestjs/core": "^11.0.1", "@nestjs/core": "^11.0.1",
"@nestjs/config": "^4.0.0",
"@nestjs/platform-express": "^11.0.1", "@nestjs/platform-express": "^11.0.1",
"axios": "^1.7.9", "axios": "^1.7.9",
"reflect-metadata": "^0.2.2", "reflect-metadata": "^0.2.2",
"dotenv": "^16.3.1",
"rxjs": "^7.8.1" "rxjs": "^7.8.1"
}, },
"devDependencies": { "devDependencies": {

View File

@ -2,15 +2,9 @@ import { Module } from '@nestjs/common';
import { HttpModule } from '@nestjs/axios'; import { HttpModule } from '@nestjs/axios';
import { PrometheusService } from './prometheus.service'; import { PrometheusService } from './prometheus.service';
import { MetricsController } from './metrics.controller'; import { MetricsController } from './metrics.controller';
import { ConfigModule } from '@nestjs/config';
@Module({ @Module({
imports: [ imports: [HttpModule], // Используем новый HttpModule
ConfigModule.forRoot({
isGlobal: true,
envFilePath: '.env',
}),
HttpModule],
controllers: [MetricsController], controllers: [MetricsController],
providers: [PrometheusService], providers: [PrometheusService],
}) })

View File

@ -1,7 +1,6 @@
import { NestFactory } from '@nestjs/core'; import { NestFactory } from '@nestjs/core';
import { AppModule } from './app.module'; import { AppModule } from './app.module';
async function bootstrap() { async function bootstrap() {
const app = await NestFactory.create(AppModule); const app = await NestFactory.create(AppModule);

View File

@ -4,25 +4,18 @@ import { PrometheusService } from './prometheus.service';
@Controller('metrics') @Controller('metrics')
export class MetricsController { export class MetricsController {
constructor(private readonly prometheusService: PrometheusService) { } constructor(private readonly prometheusService: PrometheusService) { }
//Получение конкретной метрики
@Get() @Get()
async getMetrics( async getMetrics(@Query('metric') metric: string) {
@Query('metric') metric: string,
@Query('start') start: number,
@Query('end') end: number,
@Query('step') step: number,
) {
if (start && end && step) {
return this.prometheusService.fetchMetricsRange(metric, start, end, step);
}
return this.prometheusService.fetchMetrics(metric); return this.prometheusService.fetchMetrics(metric);
} }
// Получить список всех метрик
@Get('/all') @Get('/all')
async getAllMetrics() { async getAllMetrics() {
return this.prometheusService.fetchAllMetrics(); return this.prometheusService.fetchAllMetrics();
} }
// Получить ВСЕ метрики со значениями
@Get('/all-values') @Get('/all-values')
async getAllMetricsWithValues() { async getAllMetricsWithValues() {
return this.prometheusService.fetchAllMetricsWithValues(); return this.prometheusService.fetchAllMetricsWithValues();

View File

@ -4,5 +4,4 @@ export interface PrometheusMetric {
timestamp: number; timestamp: number;
value: number; value: number;
type: string; // Тип метрики ("gauge", "counter", и т. д.) type: string; // Тип метрики ("gauge", "counter", и т. д.)
description?: string; // Описание метрики
} }

View File

@ -1,22 +1,16 @@
import { Injectable } from '@nestjs/common'; import { Injectable } from '@nestjs/common';
import { HttpService } from '@nestjs/axios'; import { HttpService } from '@nestjs/axios';
import { ConfigService } from '@nestjs/config';
import { lastValueFrom } from 'rxjs'; import { lastValueFrom } from 'rxjs';
import { PrometheusMetric } from './prometheus-metric.interface'; import { PrometheusMetric } from './prometheus-metric.interface';
@Injectable() @Injectable()
export class PrometheusService { export class PrometheusService {
private readonly prometheusUrl: string; private readonly prometheusUrl = 'http://192.168.2.37:9090/api/v1';
constructor( constructor(private readonly httpService: HttpService) { }
private readonly httpService: HttpService,
private readonly configService: ConfigService
) {
this.prometheusUrl = this.configService.get<string>('PROMETHEUS_API', 'http://localhost:9090');
console.log('Prometheus API URL:', this.prometheusUrl);
}
//Получаем тип метрики //Получаем тип метрики
async fetchMetricType(metric: string): Promise<string | null> { async fetchMetricType(metric: string): Promise<string | null> {
try { try {
const response = await lastValueFrom( const response = await lastValueFrom(
@ -26,31 +20,20 @@ export class PrometheusService {
); );
const metadata = response.data.data[metric]; const metadata = response.data.data[metric];
return metadata?.length ? metadata[0].type : null;
if (metadata && metadata.length > 0) {
return metadata[0].type; // Возвращаем тип метрики
}
return null;
} catch (error) { } catch (error) {
console.error(`Ошибка при получении типа метрики ${metric}:`, error); console.error(`Ошибка при получении типа метрики ${metric}:`, error);
return null; return null;
} }
} }
// Получаем описание метрики //Данные конкретной метрики, включая ее тип
async fetchMetricDescription(metric: string): Promise<string | undefined> {
try {
const response = await lastValueFrom(
this.httpService.get(`${this.prometheusUrl}/metadata`, {
params: { metric },
})
);
const metadata = response.data.data[metric];
return metadata?.length ? metadata[0].help : undefined;
} catch (error) {
console.error(`Ошибка при получении описания метрики ${metric}:`, error);
return undefined;
}
}
// Получаем данные метрики (текущие значения)
async fetchMetrics(metric: string): Promise<PrometheusMetric[]> { async fetchMetrics(metric: string): Promise<PrometheusMetric[]> {
const response = await lastValueFrom( const response = await lastValueFrom(
this.httpService.get(`${this.prometheusUrl}/query`, { this.httpService.get(`${this.prometheusUrl}/query`, {
@ -58,54 +41,27 @@ export class PrometheusService {
}) })
); );
const metricType = await this.fetchMetricType(metric); const metricType = await this.fetchMetricType(metric); // Получаем тип
const metricDescription = await this.fetchMetricDescription(metric);
return response.data.data.result.map((entry): PrometheusMetric => ({ return response.data.data.result.map((entry): PrometheusMetric => ({
...entry.metric, ...entry.metric,
timestamp: entry.value[0] * 1000, timestamp: entry.value[0] * 1000, // Преобразуем в миллисекунды
value: parseFloat(entry.value[1]), value: parseFloat(entry.value[1]), // Преобразуем в число
type: metricType || 'unknown', type: metricType || 'unknown', // Добавляем тип метрики
description: metricDescription, // Добавляем описание
})); }));
} }
// Получаем данные метрики за интервал //Получаем данные всех метрик
async fetchMetricsRange(metric: string, start: number, end: number, step: number): Promise<PrometheusMetric[]> {
const response = await lastValueFrom(
this.httpService.get(`${this.prometheusUrl}/query_range`, {
params: {
query: metric,
start,
end,
step,
},
})
);
const metricType = await this.fetchMetricType(metric);
const metricDescription = await this.fetchMetricDescription(metric);
return response.data.data.result.flatMap((entry) =>
entry.values.map((value): PrometheusMetric => ({
...entry.metric,
timestamp: value[0] * 1000,
value: parseFloat(value[1]),
type: metricType || 'unknown',
description: metricDescription, // Добавляем описание
}))
);
}
// Получаем список всех метрик
async fetchAllMetrics(): Promise<string[]> { async fetchAllMetrics(): Promise<string[]> {
const response = await lastValueFrom( const response = await lastValueFrom(
this.httpService.get(`${this.prometheusUrl}/label/__name__/values`) this.httpService.get(`${this.prometheusUrl}/label/__name__/values`)
); );
return response.data.data; return response.data.data; // Это массив с именами метрик
} }
// Получаем все метрики с их значениями // Получаем список всех метрик
async fetchAllMetricsWithValues(): Promise<any[]> { async fetchAllMetricsWithValues(): Promise<any[]> {
const metricNames = await this.fetchAllMetrics(); const metricNames = await this.fetchAllMetrics();
const promises = metricNames.map(async (metric) => { const promises = metricNames.map(async (metric) => {