Python: module iasLogDumper

iasLogDumper

index
/home/fedora/ias/KafkaUtils/src/main/python/iasLogDumper.py

Dumps in the stdout the logs published in a BSDB topic

Created on Apr 11, 2024

@author: acaproni

Modules

Classes

IasKafkaUtils.IasKafkaConsumer.IasLogListener(builtins.object)

DumperListener

class DumperListener(IasKafkaUtils.IasKafkaConsumer.IasLogListener)

DumperListener(quiet: bool, max_messages: int) -> None

Method resolution order:: DumperListener; IasKafkaUtils.IasKafkaConsumer.IasLogListener; builtins.object

Methods defined here:

__init__(self, quiet: bool, max_messages: int) -> None: Constructor

Params:
    quiet: True if the logs must not be printed in the stdout
           (to be used with -m or -o)
    max_messages: the max number of messages to wait
                  (0 means unlimited)

get_processed_logs(self): Returns: the numberof logs procesed so far

iasLogReceived(self, log: str) -> None: Process the log

Data descriptors inherited from IasKafkaUtils.IasKafkaConsumer.IasLogListener:

__dict__: dictionary for instance variables

__weakref__: list of weak references to the object

Functions

Lock = allocate_lock(...): allocate_lock() -> lock object
(allocate() is an obsolete synonym)

Create a new lock object. See help(type(threading.Lock())) for
information about locks.

interrupt_handler(signum, frame): The handler of CTRL-C

Data
		consumer = None terminated = False termination_lock = <unlocked _thread.lock object>