Azure'associazione di output redis gestita per Azure Functions

È possibile creare una funzione C# usando una delle modalità C# seguenti:

• Modello di lavoro isolato: funzione C# compilata eseguita in un processo di lavoro isolato dal runtime. Il processo di lavoro isolato è necessario per supportare le funzioni C# in esecuzione in versioni LTS e non LTS .NET e .NET Framework. Le estensioni per le funzioni del processo di lavoro isolato usano spazi dei nomi Microsoft.Azure.Functions.Worker.Extensions.*.
• Modello in-process: funzione C# compilata eseguita nello stesso processo del runtime di Funzioni. In una variante di questo modello, le funzioni possono essere eseguite usando script C#, che è supportato principalmente per la modifica del portale C#. Le estensioni per le funzioni in-process usano spazi dei nomi Microsoft.Azure.WebJobs.Extensions.*.

L'esempio seguente mostra un trigger pub/sub sull'evento set con un'associazione di output alla stessa istanza di Redis. L'evento set attiva la cache e l'associazione di output restituisce un comando delete per la chiave che ha attivato la funzione.

using Microsoft.Extensions.Logging;

namespace Microsoft.Azure.Functions.Worker.Extensions.Redis.Samples.RedisOutputBinding
{
    internal class SetDeleter
    {
        [Function(nameof(SetDeleter))]
        [RedisOutput(Common.connectionString, "DEL")]
        public static string Run(
            [RedisPubSubTrigger(Common.connectionString, "__keyevent@0__:set")] string key,
            ILogger logger)
        {
            logger.LogInformation($"Deleting recently SET key '{key}'");
            return key;
        }
    }
}

using Microsoft.Extensions.Logging;

namespace Microsoft.Azure.WebJobs.Extensions.Redis.Samples.RedisOutputBinding
{
    internal class SetDeleter
    {
        [FunctionName(nameof(SetDeleter))]
        public static void Run(
            [RedisPubSubTrigger(Common.connectionStringSetting, "__keyevent@0__:set")] string key,
            [Redis(Common.connectionStringSetting, "DEL")] out string[] arguments,
            ILogger logger)
        {
            logger.LogInformation($"Deleting recently SET key '{key}'");
            arguments = new string[] { key };
        }
    }
}

L'esempio seguente mostra un trigger pub/sub sull'evento set con un'associazione di output alla stessa istanza di Redis. L'evento set attiva la cache e l'associazione di output restituisce un comando delete per la chiave che ha attivato la funzione.

package com.function.RedisOutputBinding;

import com.microsoft.azure.functions.*;
import com.microsoft.azure.functions.annotation.*;
import com.microsoft.azure.functions.redis.annotation.*;

public class SetDeleter {
    @FunctionName("SetDeleter")
    @RedisOutput(
                name = "value",
                connection = "redisConnectionString",
                command = "DEL")
    public String run(
            @RedisPubSubTrigger(
                name = "key",
                connection = "redisConnectionString",
                channel = "__keyevent@0__:set")
                String key,
            final ExecutionContext context) {
        context.getLogger().info("Deleting recently SET key '" + key + "'");
        return key;
    }
}

Questo esempio mostra un trigger pub/sub sull'evento set con un'associazione di output alla stessa istanza di Redis. L'evento set attiva la cache e l'associazione di output restituisce un comando delete per la chiave che ha attivato la funzione.

{
    "bindings": [
        {
            "type": "redisPubSubTrigger",
            "connection": "redisConnectionString",
            "channel": "__keyevent@0__:set",
            "name": "key",
            "direction": "in"
        },
        {
            "type": "redis",
            "connection": "redisConnectionString",
            "command": "DEL",
            "name": "$return",
            "direction": "out"
        }
    ],
    "scriptFile": "index.js"
}

module.exports = async function (context, key) {
    context.log("Deleting recently SET key '" + key + "'");
    return key;
}

Questo esempio mostra un trigger pub/sub sull'evento set con un'associazione di output alla stessa istanza di Redis. L'evento set attiva la cache e l'associazione di output restituisce un comando delete per la chiave che ha attivato la funzione.

Le associazioni sono definite in questo function.json file:

{
    "bindings": [
        {
            "type": "redisPubSubTrigger",
            "connection": "redisLocalhost",
            "channel": "__keyevent@0__:set",
            "name": "key",
            "direction": "in"
        },
        {
            "type": "redis",
            "connection": "redisLocalhost",
            "command": "DEL",
            "name": "retVal",
            "direction": "out"
        }
    ],
    "scriptFile": "run.ps1"
}

Questo codice dal run.ps1 file accetta la chiave dal trigger e la passa all'associazione di output per eliminare l'elemento memorizzato nella cache.

param($key, $TriggerMetadata)
Write-Host "Deleting recently SET key '$key'"
Push-OutputBinding -Name retVal -Value $key

Questo esempio mostra un trigger pub/sub sull'evento set con un'associazione di output alla stessa istanza di Redis. L'evento set attiva la cache e l'associazione di output restituisce un comando delete per la chiave che ha attivato la funzione.

{
    "bindings": [
        {
            "type": "redisPubSubTrigger",
            "connection": "redisLocalhost",
            "channel": "__keyevent@0__:set",
            "name": "key",
            "direction": "in"
        },
        {
            "type": "redis",
            "connection": "redisLocalhost",
            "command": "DEL",
            "name": "$return",
            "direction": "out"
        }
    ],
    "scriptFile": "__init__.py"
}

import logging

def main(key: str) -> str:
    logging.info("Deleting recently SET key '" + key + "'")
    return key

Attributi

Il modo in cui si definisce un parametro di associazione di output dipende dal fatto che le funzioni C# vengono eseguite in-process o in un processo di lavoro isolato.

L'associazione di output viene definita in questo modo:

In questo caso, il tipo restituito dal metodo è un valore chiave usato dall'associazione per eseguire il comando sulla cache specifica.

Quando la funzione include più associazioni di output, è invece possibile applicare l'attributo di associazione alla proprietà di un tipo che è un valore di chiave, che l'associazione usa per eseguire il comando sulla cache specifica. Per altre informazioni, vedere Più associazioni di output.

Indipendentemente dalla modalità di processo C#, le stesse proprietà sono supportate dall'attributo di associazione di output:

Annotazioni

L'annotazione RedisOutput supporta queste proprietà:

Impostazione

Nella tabella seguente sono illustrate le proprietà di configurazione dell'associazione impostate nel file function.json.