metrics

docker-compose.yaml

@@ -20,4 +20,31 @@ services:
     container_name: opentelemetry_jaeger_redis
     ports:
       - '16686:16686'
-      - '4318:4318'
+
+  otel-collector:
+    image: otel/opentelemetry-collector-contrib:latest
+    command: ["--config=/etc/otel-collector.yaml"]
+    volumes:
+      - ./otel-collector.yaml:/etc/otel-collector.yaml
+    ports:
+      - "9464:9464"
+      - "4318:4318"
+      - "4317:4317"
+
+  prometheus:
+    image: prom/prometheus:latest
+    volumes:
+      - ./prometheus.yaml:/etc/prometheus/prometheus.yaml
+    command: ["--config.file=/etc/prometheus/prometheus.yaml"]
+    ports:
+      - "9090:9090"
+
+  grafana:
+    image: grafana/grafana-enterprise
+    container_name: grafana
+    restart: unless-stopped
+    ports:
+     - '3001:3000'
+    environment:
+      GF_SECURITY_ADMIN_USER: "${GRAFANA_USER}"
+      GF_SECURITY_ADMIN_PASSWORD: "${GRAFANA_PASSWORD}"

otel-collector.yaml

@@ -0,0 +1,37 @@
+receivers:
+  otlp:
+    protocols:
+      http:
+        endpoint: 0.0.0.0:4318
+  prometheus:
+    config:
+      scrape_configs:
+        - job_name: otel-collector
+          metrics_path: '/api/newsletter/metrics'
+          scrape_interval: 10s
+          static_configs:
+            - targets: 
+              - host.docker.internal:3000
+
+processors:
+  batch:
+
+exporters:
+  otlp:
+    endpoint: jaeger:4317
+    tls:
+      insecure: true
+
+  prometheus:
+    endpoint: 0.0.0.0:9464
+
+service:
+  pipelines:
+    traces:
+      receivers: [otlp]
+      processors: [batch]
+      exporters: [otlp]
+    metrics:
+      receivers: [otlp, prometheus]
+      processors: [batch]
+      exporters: [prometheus]

package.json

@@ -28,7 +28,7 @@
     "@opentelemetry/sdk-metrics": "^1.27.0",
     "@opentelemetry/sdk-node": "^0.54.0",
     "@opentelemetry/sdk-trace-node": "^1.27.0",
-    "bullmq": "^5.21.2",
+    "bullmq": "^5.40.0",
     "bullmq-otel": "^1.0.1",
     "dotenv": "^16.4.5",
     "express": "^4.19.2",

prometheus.yaml

@@ -0,0 +1,7 @@
+global:
+  scrape_interval: 10s
+
+scrape_configs:
+  - job_name: 'otel-collector'
+    static_configs:
+      - targets: ['otel-collector:9464']

src/controllers/newsletter.controller.ts

@@ -5,6 +5,7 @@ class NewsletterController {
     constructor() {
         this.subscribeToNewsletter = this.subscribeToNewsletter.bind(this);
         this.unsubcribeFromNewsletter = this.unsubcribeFromNewsletter.bind(this);
+        this.exportMetrics = this.exportMetrics.bind(this);
     }
 
     async subscribeToNewsletter(req: Request, res: Response, next: NextFunction) {
@@ -32,6 +33,18 @@ class NewsletterController {
             return next(err);
         }
     }
+
+    async exportMetrics(_: Request, res: Response, next: NextFunction) {
+        try {
+            const newsletterMetrics = await NewsletterService.exportMetrics();
+            return res.writeHead(200, {
+                'Content-Type': 'text/plain',
+                'Content-Length': Buffer.byteLength(newsletterMetrics)}
+            ).end(newsletterMetrics);
+        } catch(err) {
+            return next(err);
+        }
+    }
 }
 
 export default new NewsletterController();

src/routes/newsletter.route.ts

@@ -9,4 +9,6 @@ router.post('/subscribe', newsletterController.subscribeToNewsletter);
 
 router.post('/unsubscribe', newsletterController.unsubcribeFromNewsletter);
 
+router.get('/metrics', newsletterController.exportMetrics);
+
 export default router;

src/services/newsletter.service.ts

@@ -20,6 +20,10 @@ class NewsletterService {
         this.subscribedUserCRUD = SubscribedUserCrud;
     }
 
+    exportMetrics() {
+        return this.queue.exportPrometheusMetrics();
+    }
+
     async subscribeToNewsletter(email: string) {
         const subscribedUser = await this.subscribedUserCRUD.create(email);
         if (!subscribedUser) {