Auto Instrumentation: Get request body of NodeJs express application using Auto Instrumentation.

[jishnumuralikrishna]

Hello ! I am new to OpenTelemetry. I am trying to implement Auto Instrumentation on NodeJs express application. I also want to capture request body as well using Auto Instrumentation for one my use case. Can anyone help me how to implement it. Have been trying to do it for some time now. I created a sample application to test it out. Here's code.

Server.js

const express = require("express");
const { MongoClient } = require("mongodb");

const app = express();
app.use(express.json());

const port = 3000;
let db;

app.get("/todo", async (req, res) => {
    const todos = await db.collection("todos").find({}).toArray();
    res.send(todos);
});

app.get("/todo/:id", async (req, res) => {
    const todo = await db.collection("todos").findOne({ id: req.params.id });
    res.send(todo);
});

app.post("/addTodo", async (req, res) => {
    const todo = req.body;

    MongoClient.connect("mongodb://localhost:26116", (err, client) => {
        db = client.db("todo");
        db.collection("todos").insertOne(todo);
    });

    res.status(201).json("Added");
});

const startServer = () => {
    MongoClient.connect("mongodb://localhost:26116", (err, client) => {
        db = client.db("todo");
        db.collection("todos").insertMany([
            { id: "1", title: "Buy groceries" },
            { id: "2", title: "Install Aspecto" },
            { id: "3", title: "buy my own name domain" },
        ]);
    });
};

app.listen(port, () => {
    console.log(`Example app listening on port ${port}`);
});

startServer();

Tracing.js

"use strict";

const process = require("process");
const { diag, DiagConsoleLogger, DiagLogLevel } = require("@opentelemetry/api");
const opentelemetry = require("@opentelemetry/sdk-node");
const { OTLPTraceExporter } = require("@opentelemetry/exporter-otlp-grpc");
const {
    getNodeAutoInstrumentations,
} = require("@opentelemetry/auto-instrumentations-node");
const {
    SemanticResourceAttributes,
} = require("@opentelemetry/semantic-conventions");
const { Resource } = require("@opentelemetry/resources");

// Tracer exporter
const traceExporter = new OTLPTraceExporter();

const instrumentations = getNodeAutoInstrumentations({
    captureRequestBody: true,
});

// SDK configuration and start up
const sdk = new opentelemetry.NodeSDK({
    traceExporter,
    instrumentations,
});

(async () => {
    try {
        await sdk.start();
        console.log("Tracing started.");
    } catch (error) {
        console.log("Error :");
        console.error(error);
    }
})();

// For local development to stop the tracing using Control+c
process.on("SIGINT", async () => {
    try {
        await sdk.shutdown();
        console.log("Tracing finished.");
    } catch (error) {
        console.error(error);
    } finally {
        process.exit(0);
    }
});

diag.setLogger(new DiagConsoleLogger(), DiagLogLevel.DEBUG);