操作指南：从存储中管理配置

了解如何获取应用程序配置并订阅变更

此示例使用 Redis 配置存储组件来演示如何检索配置项。

注意

如果您还没有尝试过，可以先体验一下配置快速入门，快速了解如何使用配置 API。

禁用配置初始化端点

如果您的应用程序不使用配置构建块，则可以在初始化期间禁用对 /dapr/config 端点的自动 HTTP 调用，以减少日志噪音。在使用 dapr run 时使用 --disable-init-endpoints config 标志，或在 Kubernetes 中使用 dapr.io/disable-init-endpoints: "config" 注解。了解有关禁用初始化端点的更多信息。

在存储中创建配置项

在支持的配置存储中创建一个配置项。这可以是一个简单的键值项，键可以由您自行选择。如前所述，此示例使用 Redis 配置存储组件。

使用 Docker 运行 Redis

docker run --name my-redis -p 6379:6379 -d redis:6

保存项

使用 Redis CLI 连接到 Redis 实例：

redis-cli -p 6379

保存一个配置项：

MSET orderId1 "101||1" orderId2 "102||1"

配置 Dapr 配置存储

将以下组件文件保存到您机器上的默认组件文件夹中。您可以使用此文件作为 Dapr 组件 YAML：

对于使用 kubectl 的 Kubernetes 环境。
使用 Dapr CLI 运行时的场景。

注意

由于 Redis 配置组件的元数据与 Redis statestore.yaml 组件相同，如果您已经有 Redis statestore.yaml，可以简单地复制/更改 Redis 状态存储组件类型。

apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
  name: configstore
spec:
  type: configuration.redis
  metadata:
  - name: redisHost
    value: localhost:6379
  - name: redisPassword
    value: <REDIS_PASSWORD>

检索配置项

获取配置项

以下示例展示如何使用 Dapr Configuration API 获取已保存的配置项。

using System;
using System.Collections.Generic;
using System.Threading.Tasks;
using Dapr.Client;

const string CONFIG_STORE_NAME = "configstore";

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddDaprClient();
var app = builder.Build();

using var client = app.Services.GetRequiredServices<DaprClient>();

var configuration = await client.GetConfiguration(CONFIG_STORE_NAME, [ "orderId1", "orderId2" ]);
Console.WriteLine($"Got key=\n{configuration[0].Key} -> {configuration[0].Value}\n{configuration[1].Key} -> {configuration[1].Value}");

//dependencies
import io.dapr.client.DaprClientBuilder;
import io.dapr.client.DaprClient;
import io.dapr.client.domain.ConfigurationItem;
import io.dapr.client.domain.GetConfigurationRequest;
import io.dapr.client.domain.SubscribeConfigurationRequest;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

//code
private static final String CONFIG_STORE_NAME = "configstore";

public static void main(String[] args) throws Exception {
    try (DaprClient client = (new DaprClientBuilder()).build()) {
      List<String> keys = new ArrayList<>();
      keys.add("orderId1");
      keys.add("orderId2");
      GetConfigurationRequest req = new GetConfigurationRequest(CONFIG_STORE_NAME, keys);
      try {
        Mono<List<ConfigurationItem>> items = client.getConfiguration(req);
        items.block().forEach(ConfigurationClient::print);
      } catch (Exception ex) {
        System.out.println(ex.getMessage());
      }
    }
}

#dependencies
from dapr.clients import DaprClient
#code
with DaprClient() as d:
        CONFIG_STORE_NAME = 'configstore'
        keys = ['orderId1', 'orderId2']
        #Startup time for dapr
        d.wait(20)
        configuration = d.get_configuration(store_name=CONFIG_STORE_NAME, keys=[keys], config_metadata={})
        print(f"Got key={configuration.items[0].key} value={configuration.items[0].value} version={configuration.items[0].version}")

package main

import (
	"context"
  "fmt"

	dapr "github.com/dapr/go-sdk/client"
)

func main() {
	ctx := context.Background()
	client, err := dapr.NewClient()
	if err != nil {
		panic(err)
	}
	items, err := client.GetConfigurationItems(ctx, "configstore", ["orderId1","orderId2"])
	if err != nil {
		panic(err)
	}
  for key, item := range items {
    fmt.Printf("get config: key = %s value = %s version = %s",key,(*item).Value, (*item).Version)
  }
}

import { CommunicationProtocolEnum, DaprClient } from "@dapr/dapr";

// JS SDK does not support Configuration API over HTTP protocol yet
const protocol = CommunicationProtocolEnum.GRPC;
const host = process.env.DAPR_HOST ?? "localhost";
const port = process.env.DAPR_GRPC_PORT ?? 3500;

const DAPR_CONFIGURATION_STORE = "configstore";
const CONFIGURATION_ITEMS = ["orderId1", "orderId2"];

async function main() {
  const client = new DaprClient(host, port, protocol);
  // Get config items from the config store
  try {
    const config = await client.configuration.get(DAPR_CONFIGURATION_STORE, CONFIGURATION_ITEMS);
    Object.keys(config.items).forEach((key) => {
      console.log("Configuration for " + key + ":", JSON.stringify(config.items[key]));
    });
  } catch (error) {
    console.log("Could not get config item, err:" + error);
    process.exit(1);
  }
}

main().catch((e) => console.error(e));

Launch a dapr sidecar:

dapr run --app-id orderprocessing --dapr-http-port 3601

在另一个终端中，获取之前保存的配置项：

curl http://localhost:3601/v1.0/configuration/configstore?key=orderId1

启动 Dapr 边车：

dapr run --app-id orderprocessing --dapr-http-port 3601

在另一个终端中，获取之前保存的配置项：

Invoke-RestMethod -Uri 'http://localhost:3601/v1.0/configuration/configstore?key=orderId1'