Dynatrace OneAgent SDK Auto Instrumentation for Python

DISCLAIMER: This project was developed as a hobby. It is not complete, nor supported and only intended as a starting point for those wanting to implement OneAgent SDK for Python with minimal code changes.

This package will instrument your python code with the OneAgentSDK.

Usage

pip install autodynatrace

For most technologies, just import it in your code.

import autodynatrace

Technologies supported:

• celery
• confluent_kafka
• django
• flask
• pymongo
• redis
• sqlalchemy
• urllib3
• custom annotations

Django

For Django, add "autodynatrace.wrappers.django" to INSTALLED_APPS

Confluent Kafka

confluent_kafka is written in C, which means we cannot patch the objects, to use it, just replace the confluent_kafka.Consumer and confluent_kafka.Producer imports with autodynatrace.wrappers.confluent_kafka.Producer and autodynatrace.wrappers.confluent_kafka.Consumer

import autodynatrace
from autodynatrace.wrappers.confluent_kafka import Consumer, Producer
import time
from concurrent.futures import ThreadPoolExecutor

p = Producer({"bootstrap.servers": "localhost:32769"})
c = Consumer({"bootstrap.servers": "localhost:32769", "group.id": "mygroup", "auto.offset.reset": "earliest"})
c.subscribe(["mytopic"])


@autodynatrace.trace
def produce():
    message = "Hello world!"
    p.produce("mytopic", message.encode("utf-8"))


def producer():
    while True:
        produce()
        time.sleep(2)


def consumer():
    while True:
        msg = c.poll(1.0)

        if msg is None:
            continue
        if msg.error():
            print("Consumer error: {}".format(msg.error()))
            continue

        print("Received message: {}".format(msg.headers()))

    c.close()


def main():
    with ThreadPoolExecutor(max_workers=2) as e:
        e.submit(producer)
        e.submit(consumer)


if __name__ == "__main__":
    main()

Environment variables

• AUTODYNATRACE_CAPTURE_HEADERS: Default: False, set to True to capture request headers
• AUTODYNATRACE_LOG_LEVEL: Default WARNING