Ярмошенко ФТ-302, Зайцев ФТ-302, Фурман ФТ-302

Metrics.cs

@@ -0,0 +1,67 @@
+using System.Diagnostics.Metrics;
+
+namespace telemetry;
+
+public class Metrics
+{
+    private readonly Counter<int> indexRequestsCount;
+    private readonly Histogram<double> indexRequestsTime;
+    private readonly Counter<int> errorCount;
+    private readonly Counter<int> slowRequestsCount;
+
+    private int totalRequests;
+    private int errorRequests;
+
+    public Metrics(IMeterFactory meterFactory)
+    {
+        var meter = meterFactory.Create(nameof(Metrics));
+
+        indexRequestsCount = meter.CreateCounter<int>("requests.index.count", "pcs", "Количество запросов");
+        indexRequestsTime = meter.CreateHistogram<double>("requests.index.time", "ms", "Время запроса к index");
+
+        errorCount = meter.CreateCounter<int>(
+            "requests.index.errors", 
+            "errors", 
+            "Количество ошибок при обработке запроса"
+        );
+
+        slowRequestsCount = meter.CreateCounter<int>(
+            "requests.index.slow", 
+            "requests", 
+            "Количество медленных запросов (более 50ms)"
+        );
+
+        meter.CreateObservableGauge(
+            "requests.index.error_rate",
+            CalculateErrorRate,
+            "ratio",
+            "Доля ошибок среди всех запросов (0-1)"
+        );
+    }
+
+    public void RequestToIndex(TimeSpan elapsed)
+    {
+        totalRequests++; 
+        indexRequestsCount.Add(1);
+        indexRequestsTime.Record(elapsed.TotalMilliseconds);
+
+        if (elapsed.TotalMilliseconds > 50)
+        {
+            slowRequestsCount.Add(1);
+        }
+    }
+
+    public void RecordError()
+    {
+        errorRequests++;
+        errorCount.Add(1);
+    }
+
+    private double CalculateErrorRate()
+    {
+        if (totalRequests == 0)
+            return 0;
+
+        return (double)errorRequests / totalRequests;
+    }
+}

Pages/Index.cshtml.cs

@@ -1,19 +1,40 @@
+using System.Diagnostics;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.AspNetCore.Mvc.RazorPages;
 
 namespace telemetry.Pages;
 
-public class IndexModel : PageModel
+public class IndexModel(ILogger<IndexModel> logger, Metrics metrics) : PageModel
 {
-    private readonly ILogger<IndexModel> _logger;
-
-    public IndexModel(ILogger<IndexModel> logger)
-    {
-        _logger = logger;
-    }
+    private readonly ILogger<IndexModel> _logger = logger;
 
     public void OnGet()
     {
-
+        var sw = Stopwatch.StartNew();
+        var random = new Random();
+
+        try
+        {
+            for (var i = 0; i < random.Next(0, 100); i++)
+            {
+                if (random.Next(100) < 5)
+                {
+                    throw new Exception("Simulated processing error");
+                }
+
+                Console.Write("1");
+            }
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(ex, "Ошибка при обработке запроса");
+            metrics.RecordError(); 
+        }
+        finally
+        {
+            sw.Stop();
+
+            metrics.RequestToIndex(sw.Elapsed);
+        }
     }
-}
+}

Program.cs

@@ -1,7 +1,32 @@
+using OpenTelemetry.Logs;
+using OpenTelemetry.Metrics;
+using OpenTelemetry.Resources;
+using OpenTelemetry.Trace;
+using telemetry;
+
+
 var builder = WebApplication.CreateBuilder(args);
 
 // Add services to the container.
 builder.Services.AddRazorPages();
+builder.Services.AddSingleton<Metrics>();
+builder.Logging.AddOpenTelemetry(options =>
+{
+    options
+        .SetResourceBuilder(
+            ResourceBuilder.CreateDefault()
+                .AddService("TelemetryExample"))
+        .AddConsoleExporter();
+});
+builder.Services.AddOpenTelemetry()
+    .ConfigureResource(resource => resource.AddService("TelemetryExample"))
+    .WithTracing(tracing => tracing
+        .AddAspNetCoreInstrumentation()
+        .AddConsoleExporter())
+    .WithMetrics(metrics => metrics
+        .AddPrometheusExporter()
+        .AddAspNetCoreInstrumentation()
+        .AddConsoleExporter().AddMeter(nameof(Metrics)));
 
 var app = builder.Build();
 
@@ -20,6 +45,8 @@
 
 app.UseAuthorization();
 
+app.UseOpenTelemetryPrometheusScrapingEndpoint();
+
 app.MapRazorPages();
 
 app.Run();

compose.yaml

@@ -0,0 +1,12 @@
+services:
+  prometheus:
+    image: "prom/prometheus"
+    ports:
+      - "9090:9090"
+    volumes:
+      - "./prometheus.yml:/etc/prometheus/prometheus.yml"
+
+  grafana:
+    image: "grafana/grafana-oss"
+    ports:
+      - "3000:3000"

prometheus.yml

@@ -0,0 +1,6 @@
+scrape_configs:
+  - job_name: "prometheus"
+    scrape_interval: 5s
+    static_configs:
+      - targets: ["host.docker.internal:5149"]
+

telemetry.csproj

@@ -4,6 +4,17 @@
     <TargetFramework>net8.0</TargetFramework>
     <Nullable>enable</Nullable>
     <ImplicitUsings>enable</ImplicitUsings>
+    <DockerDefaultTargetOS>Linux</DockerDefaultTargetOS>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="OpenTelemetry" Version="1.13.1" />
+    <PackageReference Include="OpenTelemetry.Exporter.Console" Version="1.13.1" />
+    <PackageReference Include="OpenTelemetry.Exporter.OpenTelemetryProtocol" Version="1.13.1" />
+    <PackageReference Include="OpenTelemetry.Exporter.Prometheus.AspNetCore" Version="1.13.1-beta.1" />
+    <PackageReference Include="OpenTelemetry.Extensions.Hosting" Version="1.13.1" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.AspNetCore" Version="1.13.0" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.Http" Version="1.13.0" />
+  </ItemGroup>
+
 </Project>