Skip to content

Commit 21222c2

Browse files
emmuhammemmuhamm
committed
[TO REVERT] storing
1 parent 6a60f1e commit 21222c2

2 files changed

Lines changed: 87 additions & 82 deletions

File tree

‎src/daqpytools/apps/logging_demonstrator.py‎

Lines changed: 86 additions & 81 deletions
Original file line numberDiff line numberDiff line change
@@ -152,112 +152,117 @@ def main(
152152
ers_kafka_handler=ersprotobufstream,
153153
throttle=throttle
154154
)
155-
main_logger.debug("example debug message")
156-
main_logger.info("example info message")
157-
main_logger.warning("example warning message")
158-
main_logger.error("example error message")
159-
main_logger.critical("example critical message")
160-
main_logger.info(
161-
"[dim cyan]You[/dim cyan] "
162-
"[bold green]can[/bold green] "
163-
"[bold yellow]also[/bold yellow] "
164-
"[bold red]add[/bold red] "
165-
"[bold white on red]colours[/bold white on red] "
166-
"[bold red]to[/bold red] "
167-
"[bold yellow]your[/bold yellow] "
168-
"[bold green]log[/bold green] "
169-
"[dim cyan]record[/dim cyan] "
170-
"[bold green]text[/bold green] "
171-
"[bold yellow]with[/bold yellow] "
172-
"[bold green]markdown[/bold green]!"
173-
)
174-
main_logger.warning(
175-
"Note: [red] the daqpytools.logging.formatter removes markdown-style "
176-
"comments from the log record message [/red]."
177-
)
155+
# main_logger.debug("example debug message")
156+
# main_logger.info("example info message")
157+
# main_logger.warning("example warning message")
158+
# main_logger.error("example error message")
159+
# main_logger.critical("example critical message")
160+
# main_logger.info(
161+
# "[dim cyan]You[/dim cyan] "
162+
# "[bold green]can[/bold green] "
163+
# "[bold yellow]also[/bold yellow] "
164+
# "[bold red]add[/bold red] "
165+
# "[bold white on red]colours[/bold white on red] "
166+
# "[bold red]to[/bold red] "
167+
# "[bold yellow]your[/bold yellow] "
168+
# "[bold green]log[/bold green] "
169+
# "[dim cyan]record[/dim cyan] "
170+
# "[bold green]text[/bold green] "
171+
# "[bold yellow]with[/bold yellow] "
172+
# "[bold green]markdown[/bold green]!"
173+
# )
174+
# main_logger.warning(
175+
# "Note: [red] the daqpytools.logging.formatter removes markdown-style "
176+
# "comments from the log record message [/red]."
177+
# )
178178

179-
if child_logger:
180-
nested_logger: logging.Logger = get_daq_logger(
181-
logger_name=f"{logger_name}.child",
182-
log_level=log_level,
183-
use_parent_handlers=not disable_logger_inheritance,
184-
rich_handler=rich_handler,
185-
file_handler_path=file_handler_path,
186-
stream_handlers=stream_handlers,
187-
)
188-
nested_logger.debug("example debug message")
189-
nested_logger.info("example info message")
190-
nested_logger.warning("example warning message")
191-
nested_logger.error("example error message")
192-
nested_logger.critical("example critical message")
193-
nested_logger.info(
194-
"[dim cyan]You[/dim cyan] "
195-
"[bold green]can[/bold green] "
196-
"[bold yellow]also[/bold yellow] "
197-
"[bold red]add[/bold red] "
198-
"[bold white on red]colours[/bold white on red] "
199-
"[bold red]to[/bold red] "
200-
"[bold yellow]your[/bold yellow] "
201-
"[bold green]log[/bold green] "
202-
"[dim cyan]record[/dim cyan] "
203-
"[bold green]text[/bold green] "
204-
"[bold yellow]with[/bold yellow] "
205-
"[bold green]markdown[/bold green]!"
206-
)
207-
nested_logger.warning(
208-
"Note: [red] the daqpytools.logging.formatter removes markdown-style "
209-
"comments from the log record message [/red]."
210-
)
179+
# if child_logger:
180+
# nested_logger: logging.Logger = get_daq_logger(
181+
# logger_name=f"{logger_name}.child",
182+
# log_level=log_level,
183+
# use_parent_handlers=not disable_logger_inheritance,
184+
# rich_handler=rich_handler,
185+
# file_handler_path=file_handler_path,
186+
# stream_handlers=stream_handlers,
187+
# )
188+
# nested_logger.debug("example debug message")
189+
# nested_logger.info("example info message")
190+
# nested_logger.warning("example warning message")
191+
# nested_logger.error("example error message")
192+
# nested_logger.critical("example critical message")
193+
# nested_logger.info(
194+
# "[dim cyan]You[/dim cyan] "
195+
# "[bold green]can[/bold green] "
196+
# "[bold yellow]also[/bold yellow] "
197+
# "[bold red]add[/bold red] "
198+
# "[bold white on red]colours[/bold white on red] "
199+
# "[bold red]to[/bold red] "
200+
# "[bold yellow]your[/bold yellow] "
201+
# "[bold green]log[/bold green] "
202+
# "[dim cyan]record[/dim cyan] "
203+
# "[bold green]text[/bold green] "
204+
# "[bold yellow]with[/bold yellow] "
205+
# "[bold green]markdown[/bold green]!"
206+
# )
207+
# nested_logger.warning(
208+
# "Note: [red] the daqpytools.logging.formatter removes markdown-style "
209+
# "comments from the log record message [/red]."
210+
# )
211211

212212

213213
# Throttle demo
214214

215-
def emit_err(i):
216-
main_logger.info(f"Throttle test {i}", extra={"handlers": [HandlerType.Rich, HandlerType.Throttle]})
215+
# def emit_err(i):
216+
# main_logger.info(f"Throttle test {i}", extra={"handlers": [HandlerType.Rich, HandlerType.Throttle]})
217217

218-
if throttle:
219-
for i in range(50):
220-
emit_err(i)
221-
main_logger.warning("Sleeping for 30 seconds")
222-
time.sleep(31) #demonstrate 30s time window
223-
for i in range(100):
224-
emit_err(i)
218+
# if throttle:
219+
# for i in range(500000):
220+
# emit_err(i)
221+
# main_logger.warning("Sleeping for 30 seconds")
222+
# time.sleep(31) #demonstrate 30s time window
223+
# for i in range(100):
224+
# emit_err(i)
225225

226226

227227

228-
# HandlerTypes demo
229-
if not handlertypes:
230-
return
228+
# # HandlerTypes demo
229+
# if not handlertypes:
230+
# return
231231

232-
#* Add all dummy handlers which have not been developed yet
233-
dummy_add_ERSTrace_handler(main_logger, True)
232+
# #* Add all dummy handlers which have not been developed yet
233+
# dummy_add_ERSTrace_handler(main_logger, True)
234234

235235

236236
#* Test choosing which handler to use individually
237-
main_logger.debug("Default go to tty / rich / file when added")
238-
main_logger.critical("Should only go to tty", extra={"handlers": [HandlerType.Rich]})
239-
main_logger.critical("Should only go to file", extra={"handlers": [HandlerType.File]})
240-
main_logger.critical("Should only go to Lstdout", extra={"handlers": [HandlerType.Lstdout]})
241-
main_logger.critical("Should only go to ERSTrace", extra={"handlers": [HandlerType.ERSTrace]})
242-
main_logger.critical("Should only go to Throttle", extra={"handlers": [HandlerType.Throttle]})
243-
main_logger.critical("Should go to tty and Protobufstream", extra={"handlers": [HandlerType.Rich, HandlerType.Protobufstream]})
244237

245238

246-
#* Interlude: Inject sample environment variables
239+
# main_logger.debug("Default goes to both")
240+
# main_logger.critical("Should only go to tty", extra={"handlers": [HandlerType.Rich]})
241+
# main_logger.critical("Should only go to file", extra={"handlers": [HandlerType.File]})
242+
243+
244+
245+
# main_logger.critical("Should only go to Lstdout", extra={"handlers": [HandlerType.Lstdout]})
246+
# main_logger.critical("Should only go to ERSTrace", extra={"handlers": [HandlerType.ERSTrace]})
247+
# main_logger.critical("Should only go to Throttle", extra={"handlers": [HandlerType.Throttle]})
248+
# main_logger.critical("Should go to tty and Protobufstream", extra={"handlers": [HandlerType.Rich, HandlerType.Protobufstream]})
249+
250+
251+
# #* Interlude: Inject sample environment variables
247252
os.environ["DUNEDAQ_ERS_WARNING"] = "erstrace,throttle,lstdout"
248253
os.environ["DUNEDAQ_ERS_INFO"] = "erstrace,throttle,lstdout"
249254
os.environ["DUNEDAQ_ERS_FATAL"] = "erstrace,lstdout"
250255
os.environ["DUNEDAQ_ERS_ERROR"] = "erstrace,throttle,lstdout,protobufstream(monkafka.cern.ch:30092)"
251256

252-
main_logger.info(f"{os.getenv('DUNEDAQ_ERS_ERROR')=}")
253-
main_logger.info(f"{os.getenv('DUNEDAQ_ERS_CRITICAL')=}")
257+
# main_logger.info(f"{os.getenv('DUNEDAQ_ERS_ERROR')=}")
258+
# main_logger.info(f"{os.getenv('DUNEDAQ_ERS_CRITICAL')=}")
254259

255-
#* Test the routing to the Base and Opmon streams
260+
# #* Test the routing to the Base and Opmon streams
256261
handlerconf = LogHandlerConf()
257262
main_logger.warning("Handlerconf Base", extra=handlerconf.Base)
258263
main_logger.warning("Handlerconf Opmon", extra=handlerconf.Opmon)
259264

260-
#* Test ERS Streams
265+
# #* Test ERS Streams
261266
main_logger.warning("ERS Warning erstrace,throttle,lstdout", extra=handlerconf.ERS)
262267
main_logger.info("ERS Info erstrace,throttle,lstdout", extra=handlerconf.ERS)
263268
main_logger.critical("ERS Fatal erstrace,lstdout", extra=handlerconf.ERS)

‎src/daqpytools/logging/handlers.py‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -268,7 +268,7 @@ class ThrottleFilter(BaseHandlerFilter):
268268
... logger.error("Repeated error message")
269269
"""
270270

271-
def __init__(self, initial_threshold: int = 30, time_limit: int = 30):
271+
def __init__(self, initial_threshold: int = 10, time_limit: int = 30):
272272
super().__init__()
273273
self.initial_threshold = initial_threshold
274274
self.time_limit = time_limit

0 commit comments

Comments
 (0)