osbrain.logging — osBrain logging logic

Implementation of logging-related features.

class osbrain.logging.Logger(name=None, host=None, serializer=None, transport=None)

Bases: osbrain.agent.Agent

Specialized Agent for logging. Binds a SUB socket and starts logging incoming messages.

Methods

addr(alias)
Parameters:
after(delay, method, *args[, alias]) Execute an action after a delay.
bind(kind[, alias, handler, addr, …]) Bind to an agent address.
connect(server[, alias, handler]) Connect to a server agent address.
each(period, method, *args[, alias]) Execute a repeated action with a defined period.
execute_function(function, *args, **kwargs) Execute a function passed as parameter.
iddle() This function is to be executed when the agent is iddle.
iterate() Agent’s main iteration.
list_timers()
Returns:
log_debug(message[, logger]) Log a debug message.
log_error(message[, logger]) Log an error message.
log_handler(message, topic) Handle incoming log messages.
log_info(message[, logger]) Log an info message.
log_warning(message[, logger]) Log a warning message.
loop() Agent’s main loop.
on_init() This user-defined method is to be executed after initialization.
ping() A test method to check the readiness of the agent.
raise_exception() Raise an exception (for testing purposes).
recv(address) Receive a message from the specified address.
run() Run the agent.
safe_call(method, *args, **kwargs) A safe call to a method.
send(address, message[, topic, handler, …]) Send a message through the specified address.
send_recv(address, message) This method is only used in REQREP communication patterns.
set_attr(**kwargs) Set object attributes.
set_logger(logger[, alias]) Connect the agent to a logger and start logging messages to it.
set_method(*args, **kwargs) Set object methods.
stop() Stop the agent.
stop_all_timers() Stop all currently running timers.
stop_timer(alias) Stop a currently running timer.
subscribe(alias, handlers) Subscribe the agent to another agent.
close_sockets  
get_attr  
kill  
register  
registered  
shutdown  
log_handler(message, topic)

Handle incoming log messages.

on_init()

This user-defined method is to be executed after initialization.

osbrain.logging.pyro_log()

Set environment variables to activate Pyro logging. The log level is set to “DEBUG”.

osbrain.logging.run_logger(name, nsaddr=None, addr=None, base=<class 'osbrain.logging.Logger'>)

Ease the logger creation process.

This function will create a new logger, start the process and then run its main loop through a proxy.

Parameters:
name : str

Logger name or alias.

nsaddr : SocketAddress, default is None

Name server address.

addr : SocketAddress, default is None

New logger address, if it is to be fixed.

Returns:
proxy

A proxy to the new logger.