How-To: Manage configuration from a store

Learn how to get application configuration and subscribe for changes

Introduction

This HowTo uses the Redis configuration store component as an example on how to retrieve a configuration item.

This API is currently in Alpha state and only available on gRPC. An HTTP1.1 supported version with this URL syntax /v1.0/configuration will be available before the API is certified into Stable state.

Example:

The below code examples loosely describe an application that processes orders. In the examples, there is an order processing service which has a Dapr sidecar. The order processing service uses Dapr to retrieve the configuration from a Redis configuration store.

Diagram showing get configuration of example service

Step 1: Create a configuration item in store

First, create a configuration item in a supported configuration store. This can be a simple key-value item, with any key of your choice. For this example, we’ll use the Redis configuration store component.

Run Redis with Docker

  1. docker run --name my-redis -p 6379:6379 -d redis

Save an item

Using the Redis CLI, connect to the Redis instance:

  1. redis-cli -p 6379

Save a configuration item:

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

Configure a Dapr configuration store

Save the following component file, for example to the default components folder on your machine. You can use this as the Dapr component YAML for Kubernetes using kubectl or when running with the Dapr CLI. Note: The Redis configuration component has identical metadata to the Redis state store component, so you can simply copy and change the Redis state store component type if you already have a Redis state store YAML file.

  1. apiVersion: dapr.io/v1alpha1
  2. kind: Component
  3. metadata:
  4. name: configstore
  5. spec:
  6. type: configuration.redis
  7. metadata:
  8. - name: redisHost
  9. value: localhost:6379
  10. - name: redisPassword
  11. value: <PASSWORD>

Get configuration items using Dapr SDKs

  1. //dependencies
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Threading.Tasks;
  5. using Dapr.Client;
  6. //code
  7. namespace ConfigurationApi
  8. {
  9. public class Program
  10. {
  11. private static readonly string CONFIG_STORE_NAME = "configstore";
  12. [Obsolete]
  13. public static async Task Main(string[] args)
  14. {
  15. using var client = new DaprClientBuilder().Build();
  16. var configuration = await client.GetConfiguration(CONFIG_STORE_NAME, new List<string>() { "orderId1", "orderId2" });
  17. Console.WriteLine($"Got key=\n{configuration[0].Key} -> {configuration[0].Value}\n{configuration[1].Key} -> {configuration[1].Value}");
  18. }
  19. }
  20. }

Navigate to the directory containing the above code and run the following command to launch the application along with a Dapr sidecar:

  1. dapr run --app-id orderprocessing --components-path ./components -- dotnet run
  1. //dependencies
  2. import io.dapr.client.DaprClientBuilder;
  3. import io.dapr.client.DaprPreviewClient;
  4. import io.dapr.client.domain.ConfigurationItem;
  5. import io.dapr.client.domain.GetConfigurationRequest;
  6. import io.dapr.client.domain.SubscribeConfigurationRequest;
  7. import reactor.core.publisher.Flux;
  8. import reactor.core.publisher.Mono;
  9. //code
  10. private static final String CONFIG_STORE_NAME = "configstore";
  11. public static void main(String[] args) throws Exception {
  12. try (DaprPreviewClient client = (new DaprClientBuilder()).buildPreviewClient()) {
  13. List<String> keys = new ArrayList<>();
  14. keys.add("orderId1");
  15. keys.add("orderId2");
  16. GetConfigurationRequest req = new GetConfigurationRequest(CONFIG_STORE_NAME, keys);
  17. try {
  18. Mono<List<ConfigurationItem>> items = client.getConfiguration(req);
  19. items.block().forEach(ConfigurationClient::print);
  20. } catch (Exception ex) {
  21. System.out.println(ex.getMessage());
  22. }
  23. }
  24. }

Navigate to the directory containing the above code and run the following command to launch the application along with a Dapr sidecar:

  1. dapr run --app-id orderprocessing --components-path ./components mvn spring-boot:run
  1. #dependencies
  2. from dapr.clients import DaprClient
  3. #code
  4. with DaprClient() as d:
  5. CONFIG_STORE_NAME = 'configstore'
  6. keys = ['orderId1', 'orderId2']
  7. #Startup time for dapr
  8. d.wait(20)
  9. configuration = d.get_configuration(store_name=CONFIG_STORE_NAME, keys=[keys], config_metadata={})
  10. print(f"Got key={configuration.items[0].key} value={configuration.items[0].value} version={configuration.items[0].version}")

Navigate to the directory containing the above code and run the following command to launch the application along with a Dapr sidecar:

  1. dapr run --app-id orderprocessing --components-path ./components python3 OrderProcessingService.py

Get configuration items using gRPC API

Using your favorite language, create a Dapr gRPC client from the Dapr proto. The following examples show Java, C#, Python and Javascript clients.

  1. Dapr.ServiceBlockingStub stub = Dapr.newBlockingStub(channel);
  2. stub.GetConfigurationAlpha1(new GetConfigurationRequest{ StoreName = "redisconfigstore", Keys = new String[]{"myconfig"} });
  1. var call = client.GetConfigurationAlpha1(new GetConfigurationRequest { StoreName = "redisconfigstore", Keys = new String[]{"myconfig"} });
  1. response = stub.GetConfigurationAlpha1(request={ StoreName: 'redisconfigstore', Keys = ['myconfig'] })
  1. client.GetConfigurationAlpha1({ StoreName: 'redisconfigstore', Keys = ['myconfig'] })
Watch configuration items

Create a Dapr gRPC client from the Dapr proto using your preferred language. Then use the proto method SubscribeConfigurationAlpha1 on your client stub to start subscribing to events. The method accepts the following request object:

  1. message SubscribeConfigurationRequest {
  2. // The name of configuration store.
  3. string store_name = 1;
  4. // Optional. The key of the configuration item to fetch.
  5. // If set, only query for the specified configuration items.
  6. // Empty list means fetch all.
  7. repeated string keys = 2;
  8. // The metadata which will be sent to configuration store components.
  9. map<string,string> metadata = 3;
  10. }

Using this method, you can subscribe to changes in specific keys for a given configuration store. gRPC streaming varies widely based on language - see the gRPC examples here for usage.

Stop watching configuration items

After you have subscribed to watch configuration items, the gRPC-server stream starts. This stream thread does not close itself, and you have to do by explicitly call the UnSubscribeConfigurationRequest API. This method accepts the following request object:

  1. // UnSubscribeConfigurationRequest is the message to stop watching the key-value configuration.
  2. message UnSubscribeConfigurationRequest {
  3. // The name of configuration store.
  4. string store_name = 1;
  5. // Optional. The keys of the configuration item to stop watching.
  6. // Store_name and keys should match previous SubscribeConfigurationRequest's keys and store_name.
  7. // Once invoked, the subscription that is watching update for the key-value event is stopped
  8. repeated string keys = 2;
  9. }

Using this unsubscribe method, you can stop watching configuration update events. Dapr locates the subscription stream based on the store_name and any optional keys supplied and closes it.

Next steps

Last modified February 18, 2022: Update setup-jetstream.md (#2200) (428d8c2)