PyMongo

The logfire.instrument_pymongo() method will create a span for every operation performed using your PyMongo clients.

Also works with Motor… 🚗

This integration also works with motor, the asynchronous driver for MongoDB.

Installation

Install logfire with the pymongo extra:

pip

Terminal

pip install 'logfire[pymongo]'

uv

Terminal

uv add 'logfire[pymongo]'

Usage

The following example demonstrates how to use Logfire with PyMongo.

Run Mongo on Docker (Optional)

If you already have a MongoDB instance running, you can skip this step. Otherwise, you can start MongoDB using Docker with the following command:

Terminal

docker run --name mongo -p 27017:27017 -d mongo:latest

Run the Python script

The following script connects to a MongoDB database, inserts a document, and queries it:

Sync

from pymongo import MongoClient

import logfire

logfire.configure()
logfire.instrument_pymongo()

client = MongoClient()
db = client['database']
collection = db['collection']
collection.insert_one({'name': 'MongoDB'})
collection.find_one()

Async

import asyncio

from motor.motor_asyncio import AsyncIOMotorClient

import logfire

logfire.configure()
logfire.instrument_pymongo()


async def main():
    client = AsyncIOMotorClient()
    db = client['database']
    collection = db['collection']
    await collection.insert_one({'name': 'MongoDB'})
    await collection.find_one()


asyncio.run(main())

Note

You can pass capture_statement=True to logfire.instrument_pymongo() to capture the queries.

By default, it is set to False to avoid capturing sensitive information.

The keyword arguments of logfire.instrument_pymongo() are passed to the PymongoInstrumentor().instrument() method of the OpenTelemetry pymongo Instrumentation package, read more about it here.

API Reference

instrument_pymongo

def instrument_pymongo(
    capture_statement: bool = False,
    request_hook: Callable[[Span, CommandStartedEvent], None] | None = None,
    response_hook: Callable[[Span, CommandSucceededEvent], None] | None = None,
    failed_hook: Callable[[Span, CommandFailedEvent], None] | None = None,
    kwargs: Any = {},
) -> None

Instrument the pymongo module so that spans are automatically created for each operation.

Uses the OpenTelemetry pymongo Instrumentation library, specifically PymongoInstrumentor().instrument(), to which it passes **kwargs.

Returns

None

Parameters

capture_statement : bool Default: False

Set to True to capture the statement in the span attributes.

request_hook : Callable[[Span, CommandStartedEvent], None] | None Default: None

A function called when a command is sent to the server.

response_hook : Callable[[Span, CommandSucceededEvent], None] | None Default: None

A function that is called when a command is successfully completed.

failed_hook : Callable[[Span, CommandFailedEvent], None] | None Default: None

A function that is called when a command fails.

**kwargs : Any Default: \{\}

Additional keyword arguments to pass to the OpenTelemetry instrument methods for future compatibility.