Skip to main content

queue

Queue handler for forwarding telemetry records between processes.

Classes​

TelemetryQueueHandler​

class TelemetryQueueHandler(queue):

QueueHandler that keeps structured telemetry records structured.

The stock prepare replaces record.msg with its formatted string, so a telemetry event model or dict reached the listener's Datadog handler as a flat message. Telemetry records keep their msg object instead; every other record is prepared as usual.

Initialise an instance, using the passed queue.

Ancestors​

Methods​

prepare​

def prepare(self, record: logging.LogRecord) ‑> logging.LogRecord:

Prepare record for pickling onto the queue.

Arguments

  • record: The record to enqueue.

Returns The record to put on the queue.