faust.sensors.statsd
¶
Monitor using Statsd.
-
class
faust.sensors.statsd.
StatsdMonitor
(host: str = 'localhost', port: int = 8125, prefix: str = 'faust-app', rate: float = 1.0, **kwargs) → None[source]¶ Statsd Faust Sensor.
This sensor, records statistics to Statsd along with computing metrics for the stats server
-
on_message_in
(tp: faust.types.tuples.TP, offset: int, message: faust.types.tuples.Message) → None[source]¶ Message received by a consumer.
Return type: None
-
on_stream_event_in
(tp: faust.types.tuples.TP, offset: int, stream: faust.types.streams.StreamT, event: faust.types.events.EventT) → None[source]¶ Message sent to a stream as an event.
Return type: None
-
on_stream_event_out
(tp: faust.types.tuples.TP, offset: int, stream: faust.types.streams.StreamT, event: faust.types.events.EventT) → None[source]¶ Event was acknowledged by stream.
Notes
Acknowledged means a stream finished processing the event, but given that multiple streams may be handling the same event, the message cannot be committed before all streams have processed it. When all streams have acknowledged the event, it will go through
on_message_out()
just before offsets are committed.Return type: None
-
on_message_out
(tp: faust.types.tuples.TP, offset: int, message: faust.types.tuples.Message) → None[source]¶ All streams finished processing message.
Return type: None
-
on_table_get
(table: faust.types.tables.CollectionT, key: Any) → None[source]¶ Key retrieved from table.
Return type: None
-
on_table_set
(table: faust.types.tables.CollectionT, key: Any, value: Any) → None[source]¶ Value set for key in table.
Return type: None
-
on_table_del
(table: faust.types.tables.CollectionT, key: Any) → None[source]¶ Key deleted from table.
Return type: None
-
on_commit_completed
(consumer: faust.types.transports.ConsumerT, state: Any) → None[source]¶ Consumer finished committing topic offset.
Return type: None
-
on_send_initiated
(producer: faust.types.transports.ProducerT, topic: str, keysize: int, valsize: int) → Any[source]¶ About to send a message.
Return type: Any
-
on_send_completed
(producer: faust.types.transports.ProducerT, state: Any) → None[source]¶ Message successfully sent.
Return type: None
-
on_tp_commit
(tp_offsets: MutableMapping[faust.types.tuples.TP, int]) → None[source]¶ Return type: None
-
logger
= <Logger faust.sensors.statsd (WARNING)>¶
-