Erick Figueiredo
12/27/2024, 2:23 PMclass LoggingHooks:
@hook_impl
def on_pipeline_start(self, pipeline, catalog, run_params, **kwargs):
logger = logging.getLogger("kedro")
credentials = CONFIG_LOADER_CLASS.get('credentials', {})
if not (app_insights := credentials.get('app_insights')):
logger.warning('Could not configure App Insights!')
return
azure_handler = AzureLogHandler(
connection_string=app_insights.get('conn_string')
)
logger.addHandler(azure_handler)
console_handler = logging.StreamHandler()
console_handler.setFormatter(
logging.Formatter("%(asctime)s [%(levelname)s] - %(name)s: %(message)s")
)
logger.addHandler(console_handler)
logger.propagate = False
Hall
12/27/2024, 2:23 PMdatajoely
12/27/2024, 8:46 PMdatajoely
12/27/2024, 8:47 PMlogging.DictConfig
datajoely
12/27/2024, 8:48 PMdatajoely
12/27/2024, 8:48 PM