如何在kedro管道中访问环境名称

Question

有没有办法访问kedro管道环境名称？其实下面是我的问题。

我正在加载如下配置路径

conf_paths = ["conf/base", "conf/local"]  
conf_loader = ConfigLoader(conf_paths)
parameters = conf_loader.get("parameters*", "parameters*/**")
catalog = conf_loader.get("catalog*")

但我的环境很少，如"conf/server" 、"conf/test" 等，所以如果我有可用的环境名称，我可以将其添加到 conf_paths 为"conf/<env_name>"，这样 kedro 就会从相应的 env 文件夹中读取文件。 但是现在如果未将 env 路径添加到 conf_paths，即使我在运行 kedro 时指定了 env 名称，文件也不会被 kedro 读取，例如 kedro run --env=server 我搜索了所有文档，但找不到任何解决方案。

编辑： 更详细地阐述了这个问题。 我在节点中使用上面给出的参数和目录字典。我只有conf/base/parameters.yml 中所有运行通用的键和conf/server/parameters.yml 中的环境特定键但是当我做kedro run --env=server 时我得到keyerror 这意味着conf/server/parameters.yml 中的键在参数中不可用字典。如果我将conf/server 添加到 config_paths kedro 运行良好，没有 keyerror。

Answer 1

除非你试图覆盖某些东西，否则你不需要定义配置路径、配置加载器等。

如果您使用的是 kedro 0.17.x，则 hooks.py 将如下所示。

Kedro 会将基础、本地和您在运行时在conf_paths 中指定的环境传递到ConfigLoader。

class ProjectHooks:
    @hook_impl
    def register_config_loader(
        self, conf_paths: Iterable[str], env: str, extra_params: Dict[str, Any]
    ) -> ConfigLoader:
        return ConfigLoader(conf_paths)

    @hook_impl
    def register_catalog(
        self,
        catalog: Optional[Dict[str, Dict[str, Any]]],
        credentials: Dict[str, Dict[str, Any]],
        load_versions: Dict[str, str],
        save_version: str,
        journal: Journal,
    ) -> DataCatalog:
        return DataCatalog.from_config(
            catalog, credentials, load_versions, save_version, journal
        )

有问题，我可以看到您已经定义了 conf_paths 和 conf_loader 并且 env 路径不存在。所以kedro会忽略运行时传递的env。