A handler that queues events for asynchronous processing.QueueHandler captures events and places them into an asyncio Queue for later
consumption. It supports filtering events based on inclusion and exclusion criteria,
allowing for selective event processing.This handler is useful for:
Decoupling event producers from consumers
Implementing event buffering
Creating event processing pipelines
Selectively capturing specific event types
Attributes:
queue: An asyncio.Queue where events are stored
include: Optional sequence of event types or classes to include
exclude: Optional sequence of event types or classes to excludeMethods:
on_event
Copy
Ask AI
def on_event(self, event: Event)
Process an event and add it to the queue if it passes filtering criteria.This method implements filtering logic based on the include and exclude
parameters provided during initialization. Events are only added to the
queue if they pass all filtering criteria.Args:
event: The Event object to processReturns:
None. If the event passes filtering, it is added to the queue.
Otherwise, the method returns without adding the event.