Skip to content

MQTTTelemetryMiddleware

faststream.mqtt.opentelemetry.middleware.MQTTTelemetryMiddleware #

MQTTTelemetryMiddleware(
    *,
    tracer_provider: TracerProvider | None = None,
    meter_provider: MeterProvider | None = None,
    meter: Meter | None = None,
    include_messages_counters: bool = True,
)

Bases: TelemetryMiddleware[MQTTPublishCommand]

Source code in faststream/mqtt/opentelemetry/middleware.py 
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
def __init__(
    self,
    *,
    tracer_provider: TracerProvider | None = None,
    meter_provider: MeterProvider | None = None,
    meter: Meter | None = None,
    include_messages_counters: bool = True,
) -> None:
    super().__init__(
        settings_provider_factory=lambda _: MQTTTelemetrySettingsProvider(),
        tracer_provider=tracer_provider,
        meter_provider=meter_provider,
        meter=meter,
        include_messages_counters=include_messages_counters,
    )