Tutorial: Get started with Azure Functions triggers and bindings in Azure Cache for Redis

This tutorial shows how to implement basic triggers with Azure Cache for Redis and Azure Functions. It guides you through using Visual Studio Code (VS Code) to write and deploy an Azure function in C#.

In this tutorial, you learn how to:

  • Set up the necessary tools.
  • Configure and connect to a cache.
  • Create an Azure function and deploy code to it.
  • Confirm the logging of triggers.

Prerequisites

Set up an Azure Cache for Redis instance

Create a new Azure Cache for Redis instance by using the Azure portal or your preferred CLI tool. This tutorial uses a Standard C1 instance, which is a good starting point. Use the quickstart guide to get started.

Screenshot of creating a cache in the Azure portal.

The default settings should suffice. This tutorial uses a public endpoint for demonstration, but we recommend that you use a private endpoint for anything in production.

Creating the cache can take a few minutes. You can move to the next section while the process finishes.

Set up Visual Studio Code

  1. If you didn't install the Azure Functions extension for VS Code yet, search for Azure Functions on the EXTENSIONS menu, and then select Install. If you don't have the C# extension installed, install it, too.

    Screenshot of the required extensions installed in VS Code.

  2. Go to the Azure tab. Sign in to your Azure account.

  3. To store the project that you're building, create a new local folder on your computer. This tutorial uses RedisAzureFunctionDemo as an example.

  4. On the Azure tab, create a new function app by selecting the lightning bolt icon in the upper right of the Workspace tab.

  5. Select Create function....

    Screenshot that shows the icon for adding a new function from VS Code.

  6. Select the folder that you created to start the creation of a new Azure Functions project. You get several on-screen prompts. Select:

    • C# as the language.
    • .NET 8.0 Isolated LTS as the .NET runtime.
    • Skip for now as the project template.

    If you don't have the .NET Core SDK installed, you're prompted to do so.

    Important

    For .NET functions, using the isolated worker model is recommended over the in-process model. For a comparison of the in-process and isolated worker models, see differences between the isolated worker model and the in-process model for .NET on Azure Functions. This sample uses the isolated worker model.

  7. Confirm that the new project appears on the EXPLORER pane.

    Screenshot of a workspace in VS Code.

Install the necessary NuGet package

You need to install Microsoft.Azure.Functions.Worker.Extensions.Redis, the NuGet package for the Redis extension that allows Redis keyspace notifications to be used as triggers in Azure Functions.

Install this package by going to the Terminal tab in VS Code and entering the following command:

dotnet add package Microsoft.Azure.Functions.Worker.Extensions.Redis --prerelease

Note

The Microsoft.Azure.Functions.Worker.Extensions.Redis package is used for .NET isolated worker process functions. .NET in-process functions and all other languages will use the Microsoft.Azure.WebJobs.Extensions.Redis package instead.

Configure the cache

  1. Go to your newly created Azure Cache for Redis instance.

  2. Go to your cache in the Azure portal, and then:

    1. On the resource menu, select Advanced settings.

    2. Scroll down to the notify-keyspace-events box and enter KEA.

      KEA is a configuration string that enables keyspace notifications for all keys and events. For more information on keyspace configuration strings, see the Redis documentation.

    3. Select Save at the top of the window.

    Screenshot of advanced settings for Azure Cache for Redis in the portal.

  3. Locate Access keys on the Resource menu, and then write down or copy the contents of the Primary connection string box. This string is used to connect to the cache.

    Screenshot that shows the primary connection string for an access key.

Set up the example code for Redis triggers

  1. In VS Code, add a file called Common.cs to the project. This class is used to help parse the JSON serialized response for the PubSubTrigger.

  2. Copy and paste the following code into the Common.cs file:

    public class Common
    {
        public const string connectionString = "redisConnectionString";
    
        public class ChannelMessage
        {
            public string SubscriptionChannel { get; set; }
            public string Channel { get; set; }
            public string Message { get; set; }
        }
    }
    
  3. Add a file called RedisTriggers.cs to the project.

  4. Copy and paste the following code sample into the new file:

    using Microsoft.Extensions.Logging;
    using Microsoft.Azure.Functions.Worker;
    using Microsoft.Azure.Functions.Worker.Extensions.Redis;
    
    public class RedisTriggers
    {
        private readonly ILogger<RedisTriggers> logger;
    
        public RedisTriggers(ILogger<RedisTriggers> logger)
        {
            this.logger = logger;
        }
    
        // PubSubTrigger function listens to messages from the 'pubsubTest' channel.
        [Function("PubSubTrigger")]
        public void PubSub(
        [RedisPubSubTrigger(Common.connectionString, "pubsubTest")] Common.ChannelMessage channelMessage)
        {
        logger.LogInformation($"Function triggered on pub/sub message '{channelMessage.Message}' from channel '{channelMessage.Channel}'.");
        }
    
        // KeyeventTrigger function listens to key events from the 'del' operation.
        [Function("KeyeventTrigger")]
        public void Keyevent(
            [RedisPubSubTrigger(Common.connectionString, "__keyevent@0__:del")] Common.ChannelMessage channelMessage)
        {
            logger.LogInformation($"Key '{channelMessage.Message}' deleted.");
        }
    
        // KeyspaceTrigger function listens to key events on the 'keyspaceTest' key.
        [Function("KeyspaceTrigger")]
        public void Keyspace(
            [RedisPubSubTrigger(Common.connectionString, "__keyspace@0__:keyspaceTest")] Common.ChannelMessage channelMessage)
        {
            logger.LogInformation($"Key 'keyspaceTest' was updated with operation '{channelMessage.Message}'");
        }
    
        // ListTrigger function listens to changes to the 'listTest' list.
        [Function("ListTrigger")]
        public void List(
            [RedisListTrigger(Common.connectionString, "listTest")] string response)
        {
            logger.LogInformation(response);
        }
    
        // StreamTrigger function listens to changes to the 'streamTest' stream.
        [Function("StreamTrigger")]
        public void Stream(
            [RedisStreamTrigger(Common.connectionString, "streamTest")] string response)
        {
            logger.LogInformation(response);
        }
    }
    
  5. This tutorial shows multiple ways to trigger on Redis activity:

    • PubSubTrigger, which is triggered when an activity is published to the Pub/Sub channel named pubsubTest.
    • KeyspaceTrigger, which is built on the Pub/Sub trigger. Use it to look for changes to the keyspaceTest key.
    • KeyeventTrigger, which is also built on the Pub/Sub trigger. Use it to look for any use of the DEL command.
    • ListTrigger, which looks for changes to the listTest list.
    • StreamTrigger, which looks for changes to the streamTest stream.

Connect to your cache

  1. To trigger on Redis activity, you need to pass in the connection string of your cache instance. This information is stored in the local.settings.json file that was automatically created in your folder. We recommend that you use the local settings file as a security best practice.

  2. To connect to your cache, add a ConnectionStrings section in the local.settings.json file, and then add your connection string by using the redisConnectionString parameter. The section should look like this example:

    {
      "IsEncrypted": false,
      "Values": {
        "AzureWebJobsStorage": "",
        "FUNCTIONS_WORKER_RUNTIME": "dotnet-isolated",
        "redisConnectionString": "<your-connection-string>"
      }
    }
    

    The code in Common.cs looks to this value when it's running locally:

    public const string connectionString = "redisConnectionString";
    

Build and run the code locally

  1. Switch to the Run and debug tab in VS Code and select the green arrow to debug the code locally. If you don't have Azure Functions core tools installed, you're prompted to do so. In that case, you'll need to restart VS Code after installing.

  2. The code should build successfully. You can track its progress in the terminal output.

  3. To test the trigger functionality, try creating and deleting the keyspaceTest key.

    You can use any way you prefer to connect to the cache. An easy way is to use the built-in console tool in the Azure Cache for Redis portal. Go to the cache instance in the Azure portal, and then select Console to open it.

    Screenshot of C-Sharp code and a connection string.

    After the console is open, try the following commands:

    • SET keyspaceTest 1
    • SET keyspaceTest 2
    • DEL keyspaceTest
    • PUBLISH pubsubTest testMessage
    • LPUSH listTest test
    • XADD streamTest * name Clippy

    Screenshot of a console and some Redis commands and results.

  4. Confirm that the triggers are being activated in the terminal.

    Screenshot of the VS Code editor with code running.

Add Redis bindings

Bindings add a streamlined way to read or write data stored on your Redis instance. To demonstrate the benefit of bindings, we add two other functions. One is called SetGetter, which triggers each time a key is set and returns the new value of the key using an input binding. The other is called StreamSetter, which triggers when a new item is added to to the stream myStream and uses an output binding to write the value true to the key newStreamEntry.

  1. Add a file called RedisBindings.cs to the project.

  2. Copy and paste the following code sample into the new file:

    using Microsoft.Extensions.Logging;
    using Microsoft.Azure.Functions.Worker;
    using Microsoft.Azure.Functions.Worker.Extensions.Redis;
    
    public class RedisBindings
    {
        private readonly ILogger<RedisBindings> logger;
    
        public RedisBindings(ILogger<RedisBindings> logger)
        {
            this.logger = logger;
        }
    
        //This example uses the PubSub trigger to listen to key events on the 'set' operation. A Redis Input binding is used to get the value of the key being set.
        [Function("SetGetter")]
        public void SetGetter(
            [RedisPubSubTrigger(Common.connectionString, "__keyevent@0__:set")] Common.ChannelMessage channelMessage,
            [RedisInput(Common.connectionString, "GET {Message}")] string value)
        {
            logger.LogInformation($"Key '{channelMessage.Message}' was set to value '{value}'");
        }
    
        //This example uses the PubSub trigger to listen to key events to the key 'key1'. When key1 is modified, a Redis Output binding is used to set the value of the 'key1modified' key to 'true'.
        [Function("SetSetter")]
        [RedisOutput(Common.connectionString, "SET")]
        public string SetSetter(
            [RedisPubSubTrigger(Common.connectionString, "__keyspace@0__:key1")] Common.ChannelMessage channelMessage)
        {
            logger.LogInformation($"Key '{channelMessage.Message}' was updated. Setting the value of 'key1modified' to 'true'");
            return $"key1modified true";
        }
    }
    
  3. Switch to the Run and debug tab in VS Code and select the green arrow to debug the code locally. The code should build successfully. You can track its progress in the terminal output.

  4. To test the input binding functionality, try setting a new value for any key, for instance using the command SET hello world You should see that the SetGetter function triggers and returns the updated value.

  5. To test the output binding functionality, try adding a new item to the stream myStream using the command XADD myStream * item Order1. Notice that the StreamSetter function triggered on the new stream entry and set the value true to another key called newStreamEntry. This set command also triggers the SetGetter function.

Deploy code to an Azure function

  1. Create a new Azure function:

    1. Go back to the Azure tab and expand your subscription.

    2. Right-click Function App, and then select Create Function App in Azure (Advanced).

    Screenshot of selections for creating a function app in VS Code.

  2. You get several prompts for information to configure the new function app:

    • Enter a unique name.
    • Select .NET 8 Isolated as the runtime stack.
    • Select either Linux or Windows (either works).
    • Select an existing or new resource group to hold the function app.
    • Select the same region as your cache instance.
    • Select Premium as the hosting plan.
    • Create a new Azure App Service plan.
    • Select the EP1 pricing tier.
    • Select an existing storage account or create a new one.
    • Create a new Application Insights resource. You use the resource to confirm that the trigger is working.

    Important

    Redis triggers aren't currently supported on consumption functions.

  3. Wait a few minutes for the new function app to be created. It appears under Function App in your subscription. Right-click the new function app, and then select Deploy to Function App.

    Screenshot of selections for deploying to a function app in VS Code.

  4. The app builds and starts deploying. You can track its progress in the output window.

Add connection string information

  1. In the Azure portal, go to your new function app and select Environment variables from the resource menu.

  2. On the working pane, go to App settings.

  3. For Name, enter redisConnectionString.

  4. For Value, enter your connection string.

  5. Select Apply on the page to confirm.

  6. Navigate to the Overview pane and select Restart to reboot the functions app with the connection string information.

Test your triggers and bindings

  1. After deployment is complete and the connection string information is added, open your function app in the Azure portal. Then select Log Stream from the resource menu.

  2. Wait for Log Analytics to connect, and then use the Redis console to activate any of the triggers. Confirm that triggers are being logged here.

    Screenshot of a log stream for a function app resource on the resource menu.

Clean up resources

If you want to continue to use the resources you created in this article, keep the resource group.

Otherwise, to avoid charges related to the resources, if you're finished using the resources, you can delete the Azure resource group that you created.

Warning

Deleting a resource group is irreversible. When you delete a resource group, all the resources in the resource group are permanently deleted. Make sure that you do not accidentally delete the wrong resource group or resources. If you created the resources inside an existing resource group that has resources you want to keep, you can delete each resource individually instead of deleting the resource group.

Delete a resource group

  1. Sign in to the Azure portal, and then select Resource groups.

  2. Select the resource group to delete.

    If there are many resource groups, in Filter for any field, enter the name of the resource group you created to complete this article. In the list of search results, select the resource group.

    Screenshot that shows a list of resource groups to choose from to delete.

  3. Select Delete resource group.

  4. In the Delete a resource group pane, enter the name of your resource group to confirm, and then select Delete.

    Screenshot that shows a box that requires entering the resource name to confirm deletion.

Within a few moments, the resource group and all of its resources are deleted.