如何使版本化的 KV 存储与 VaultPropertySource 一起工作

Question

我正在尝试使保管库的版本化 KV 存储与 VaultPropertySource 一起使用，以便可以使用 @Value 访问属性。但是它没有按预期工作。我正在使用 spring-vault-core 的 2.1.2.RELEASE 版本。目的是使其与 spring 保险库和 Spring MVC 一起使用。

我已经尝试使用@import(EnvironmentVaultConfiguration.class) 无济于事。

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.PropertySource;
import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.core.env.MutablePropertySources;
import org.springframework.vault.authentication.ClientAuthentication;
import org.springframework.vault.authentication.TokenAuthentication;
import org.springframework.vault.client.VaultEndpoint;
import org.springframework.vault.config.AbstractVaultConfiguration;
import org.springframework.vault.core.VaultTemplate;
import org.springframework.vault.core.env.VaultPropertySource;

import javax.annotation.PostConstruct;
import java.net.URI;
import java.util.List;

@Configuration
@PropertySource("vault.properties")
public class AppConfig extends AbstractVaultConfiguration {

    @Value("${vault.uri}")
    private URI vaultUri;

    @Value("${vault.token}")
    private String token;

    @Value("#{'${vault.sources:}'.split(',')}")
    private List<String> vaultSources;

    @Autowired
    private ConfigurableEnvironment environment;

    @Autowired
    private VaultTemplate vaultTemplate;

    /**
     * Specify an endpoint for connecting to Vault.
     */
    @Override
    public VaultEndpoint vaultEndpoint() {
        return VaultEndpoint.from(vaultUri);
    }

    /**
     * Configure a client authentication.
     * Please consider a more secure authentication method
     * for production use.
     */
    @Override
    public ClientAuthentication clientAuthentication() {
        return new TokenAuthentication(token);
    }

    @PostConstruct
    public void setPropertySource() {
        MutablePropertySources sources = environment.getPropertySources();
        vaultSources.stream().forEach(vs -> {
            sources.addFirst(new VaultPropertySource(vaultTemplate, vs));
        });
    }
}

在给定的代码中，如果我提供 vault.sources=secret/data/abcd,secret/data/pqrs 然后它就可以工作并且 returns 带有 data. 和 metadata. 前缀的秘密。这意味着它使用通用方法来获取机密而不是 kv one。

如果我从路径中删除数据，即 vault.sources=secret/abcd,secret/pqrs，它根本不会连接并抛出 403 异常。这意味着它不能使用 kv v2。

有人可以帮助我了解如何在此代码中使用 spring-vault 的 Versioned API 吗？

Answer 1

Key-Value 2 支持使用 VaultPropertySource 尚未发布。它将与 Spring Vault 2.2 一起提供（参见 this GitHub issue）。

在那之前，您可以使用快照构建来验证代码是否对您的用例有帮助。

Answer 2

根据 Mark 的上述回复，我决定将 VaultPropertySource 与 PropertyTransformer 一起使用，直到我们开箱即用地支持 KV version2。

public class DataMetadataPrefixRemoverPropertyTransformer implements PropertyTransformer {

    private final String dataPrefix = "data.";
    private final String metadataPrefix = "metadata.";

    public Map<String, Object> transformProperties(Map<String, ? extends Object> inputProperties) {
        Map<String, Object> target = new LinkedHashMap(inputProperties.size(), 1.0F);
        Iterator propertiesIterator = inputProperties.entrySet().iterator();

        while(propertiesIterator.hasNext()) {

            Map.Entry<String, ? extends Object> entry = (Map.Entry)propertiesIterator.next();
            String key = entry.getKey();

            // do not add metadata properties to environment for now - do not see a use case for it as of now.
            if (StringUtils.startsWithIgnoreCase(key, metadataPrefix)) {
                continue;
            }

            if (StringUtils.startsWithIgnoreCase(key, dataPrefix)) {
                key = StringUtils.replace(key, dataPrefix, "");
            }

            target.put(key, entry.getValue());
        }
        return target;
    }
}

希望它可以帮助寻找类似解决方案的人。

如何使版本化的 KV 存储与 VaultPropertySource 一起工作

How to make versioned KV store work with VaultPropertySource

spring-vault