Kedro:在管道中按命名空间保存日志消息

问题描述

简介

我正在处理一个项目,其中我有几个不同的目标变量,我们在 Kedro 中使用相同的建模框架将管道与每个目标变量挂钩。每个管道都定义有自己的命名空间。我有一个 __default__ 管道,可以一起运行所有这些命名空间管道。

问题

当我在 __default__ 管道上运行时,有没有办法根据其命名空间保存日志信息?我看到了 link 上的帖子,其中提到您可以登录到特定的管道文件夹(仍在尝试弄清楚如何做到这一点)。但是,我不确定是否可以让它登录到特定的命名空间文件夹。该文档仅展示了如何引发其他日志。

设置

我目前使用的是 Kedro 0.16.6。该代码目前在顺序运行器上。 这是我的 hooks.py

    def register_pipelines(self) -> Dict[str,Pipeline]:

        def pipeline_creation(cov):
            return pipeline(
                                create_ulm_freqsev(),inputs = {'data': 'dataset'},parameters = {'parameters': f'params:parameters_{cov}'},namespace = f'{cov}'
                            )
        
        cov_list = ['A','B']

        pipeline_list = {f'{cov}': pipeline_creation(cov) for cov in cov_list}
        pipeline_list['__default__'] = reduce(add,pipeline_list.values())
        return pipeline_list

感谢大家的帮助。

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)