Skip to content

RedisParamsStorage

faststream.redis.broker.logging.RedisParamsStorage #

RedisParamsStorage()

Bases: DefaultLoggerStorage

Source code in faststream/redis/broker/logging.py 
14
15
16
17
18
19
def __init__(self) -> None:
    super().__init__()

    self._max_channel_name = 4

    self.logger_log_level = logging.INFO

logger_log_level instance-attribute #

logger_log_level = INFO

set_level #

set_level(level)
Source code in faststream/redis/broker/logging.py 
21
22
def set_level(self, level: int) -> None:
    self.logger_log_level = level

register_subscriber #

register_subscriber(params)
Source code in faststream/redis/broker/logging.py 
24
25
26
27
28
29
30
def register_subscriber(self, params: dict[str, Any]) -> None:
    self._max_channel_name = max(
        (
            self._max_channel_name,
            len(params.get("channel", "")),
        ),
    )

get_logger #

get_logger(*, context)
Source code in faststream/redis/broker/logging.py 
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
def get_logger(self, *, context: "ContextRepo") -> "LoggerProto":
    message_id_ln = 10

    # TODO: generate unique logger names to not share between brokers
    if not (lg := self._get_logger_ref()):
        lg = get_broker_logger(
            name="redis",
            default_context={
                "channel": "",
            },
            message_id_ln=message_id_ln,
            fmt=(
                "%(asctime)s %(levelname)-8s - "
                f"%(channel)-{self._max_channel_name}s | "
                f"%(message_id)-{message_id_ln}s "
                "- %(message)s"
            ),
            context=context,
            log_level=self.logger_log_level,
        )
        self._logger_ref.add(lg)

    return lg