Examples of how to track .NET Mongodb queries in Application Insights

.NETMongoApplicationInsightsExamples.cs

class Program
{
    static void Main(string[] args)
    {
        var telemetryClient = new TelemetryClient(new TelemetryConfiguration("APP_INSIGHTS_KEY"));
        var mongoConnectionString = "mongodb://localhost:27017/test";

        TrackMongoByEvents(mongoConnectionString, telemetryClient);

        TrackMongoManually(mongoConnectionString, telemetryClient);
    }

    private static void TrackMongoManually(string mongoConnectionString, TelemetryClient telemetryClient)
    {
        var mongoClient = new MongoClient(mongoConnectionString);
        var database = mongoClient.GetDatabase("foo");
        var collection = database.GetCollection<BsonDocument>("bar");

        var document = new BsonDocument
        {
            { "name", "MongoDB" },
            { "type", "Database" },
            { "count", 1 },
            { "info", new BsonDocument
                {
                    { "x", 203 },
                    { "y", 102 }
                }}
        };

        var timestamp = DateTimeOffset.Now;
        var stopwatch = Stopwatch.StartNew();

        // Insert one document
        collection.InsertOne(document);

        stopwatch.Stop();

        var dependency = new DependencyTelemetry
        {
            Type = "Mongo",
            Name = "InsertOne",
            Target = collection.ToString(),
            Timestamp = timestamp,
            Duration = stopwatch.Elapsed,
            Success = true,
        };

        telemetryClient.TrackDependency(dependency);
    }

    private static void TrackMongoByEvents(string mongoConnectionString, TelemetryClient telemetryClient)
    {
        var mongoUrl = new MongoUrl(mongoConnectionString);
        var mongoClientSettings = MongoClientSettings.FromUrl(mongoUrl);

        // Send mongo events to Application Insights
        mongoClientSettings.ClusterConfigurator = builder =>
        {
            builder.Subscribe<CommandSucceededEvent>(e =>
            {
                if (e.OperationId == null)
                    return;

                telemetryClient.TrackDependency("mongodb", e.CommandName, DateTime.Now.Subtract(e.Duration), e.Duration, true);
            });

            builder.Subscribe<CommandFailedEvent>(e =>
            {
                telemetryClient.TrackDependency("mongodb", $"{e.CommandName} - {e.ToString()}", DateTime.Now.Subtract(e.Duration), e.Duration, false);
            });
        };

        var mongoClient = new MongoClient(mongoClientSettings);
        var database = mongoClient.GetDatabase("foo");
        var collection = database.GetCollection<BsonDocument>("bar");

        var document = new BsonDocument
        {
            { "name", "MongoDB" },
            { "type", "Database" },
            { "count", 1 },
            { "info", new BsonDocument
                {
                    { "x", 203 },
                    { "y", 102 }
                }}
        };

        collection.InsertOne(document);
    }
}