Compartir vía

Enlace de entrada de estado Dapr para Azure Functions

  • Artículo

El enlace de entrada de estado Dapr permite leer el estado de Dapr durante la ejecución de una función.

Para obtener información sobre la configuración y los detalles de configuración de la extensión Dapr, consulte la introducción a la extensión Dapr.

Ejemplo

Se puede crear una función C# usando uno de los siguientes modos de C#:

Modelo de ejecución Descripción
Modelo de trabajo aislado El código de función se ejecuta en un proceso de trabajo de .NET independiente. Se usa con versiones compatibles de .NET y .NET Framework. Para obtener más información, consulte Desarrollo de funciones de procesos de trabajo aislados en .NET.
Modelo de proceso El código de función se ejecuta en el mismo proceso que el proceso de host de Functions. Solo admite versiones de .NET de compatibilidad a largo plazo (LTS). Para obtener más información, consulte Desarrollo de funciones de la biblioteca de clases de .NET. 
[FunctionName("StateInputBinding")]
public static IActionResult Run(
    [HttpTrigger(AuthorizationLevel.Function, "get", Route = "state/{key}")] HttpRequest req,
    [DaprState("statestore", Key = "{key}")] string state,
    ILogger log)
{
    log.LogInformation("C# HTTP trigger function processed a request.");

    return new OkObjectResult(state);
}

En el ejemplo siguiente se crea una función "RetreveOrder" mediante el enlace DaprStateInput con DaprServiceInvocationTrigger:

@FunctionName("RetrieveOrder")
public String run(
        @DaprServiceInvocationTrigger(
            methodName = "RetrieveOrder") 
        String payload,
        @DaprStateInput(
            stateStore = "%StateStoreName%",
            key = "order")
        String product,
        final ExecutionContext context)

En el ejemplo siguiente, el enlace de entrada de invocación de Dapr se agrega como un extraInput y se empareja con un desencadenador HTTP, que está registrado por el objeto app:

const { app, trigger } = require('@azure/functions');

app.generic('StateInputBinding', {
    trigger: trigger.generic({
        type: 'httpTrigger',
        authLevel: 'anonymous',
        methods: ['GET'],
        route: "state/{key}",
        name: "req"
    }),
    extraInputs: [daprStateInput],
    handler: async (request, context) => {
        context.log("Node HTTP trigger function processed a request.");

        const daprStateInputValue = context.extraInputs.get(daprStateInput);
        // print the fetched state value
        context.log(daprStateInputValue);

        return daprStateInputValue;
    }
});

En los ejemplos siguientes, se muestran desencadenadores de Dapr en un archivo function.json y código de PowerShell que usa esos enlaces.

Este es el archivo function.json para daprState:

{
  "bindings": 
    {
      "type": "daprState",
      "direction": "in",
      "key": "order",
      "stateStore": "%StateStoreName%",
      "name": "order"
    }
}

Para obtener más información sobre las propiedades del archivo function.json, consulte la sección de Configuración.

Mediante código:

using namespace System
using namespace Microsoft.Azure.WebJobs
using namespace Microsoft.Extensions.Logging
using namespace Microsoft.Azure.WebJobs.Extensions.Dapr
using namespace Newtonsoft.Json.Linq

param (
    $payload, $order
)

# C# function processed a CreateNewOrder request from the Dapr Runtime.
Write-Host "PowerShell function processed a RetrieveOrder request from the Dapr Runtime."

# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $order | ConvertTo-Json

Write-Host "$jsonString"

En el ejemplo siguiente se muestra un enlace de entrada de estado Dapr, que usa el modelo de programación de Python v2. Para usar el enlacedaprState junto con daprServiceInvocationTrigger en el código de la aplicación de la función Python:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="RetrieveOrder")
@app.dapr_service_invocation_trigger(arg_name="payload", method_name="RetrieveOrder")
@app.dapr_state_input(arg_name="data", state_store="statestore", key="order")
def main(payload, data: str) :
    # Function should be invoked with this command: dapr invoke --app-id functionapp --method RetrieveOrder  --data '{}'
    logging.info('Python function processed a RetrieveOrder request from the Dapr Runtime.')
    logging.info(data)

Atributos

En el modelo In-Process, use DaprState para leer el estado Dapr en la función, que admite estos parámetros:

Parámetro Descripción
StateStore Nombre del almacén de estado para recuperar el estado.
Clave Nombre de la clave que se va a recuperar del almacén de estado especificado.

anotaciones

La anotación DaprStateInput permite leer el estado de Dapr en la función.

Elemento Descripción
stateStore Nombre del almacén de estado de Dapr.
key Valor de clave de almacén de estado.

Configuración

En la siguiente tabla se explican las propiedades de configuración de enlace que se establecen en el código.

Propiedad Descripción
stateStore Nombre del almacén de estado.
key Nombre de la clave que se va a recuperar del almacén de estado especificado.

En la siguiente tabla se explican las propiedades de configuración de enlace que se establecen en el archivo function.json.

Propiedad de function.json Descripción
key Nombre de la clave que se va a recuperar del almacén de estado especificado.
stateStore Nombre del almacén de estado.

En la tabla siguiente, se explican las propiedades de configuración de enlace para @dapp.dapr_state_input que estableció en el código de Python.

Propiedad Descripción
state_store Nombre del almacén de estado.
key Valor de clave secreta. Nombre de la clave que se va a recuperar del almacén de estado especificado.

Consulte la sección de ejemplos para ver ejemplos completos.

Uso

Para usar el enlace de entrada de estado Dapr, empiece por configurar un componente de almacén de estado Dapr. Puede obtener más información sobre qué componente usar y cómo configurarlo en la documentación oficial de Dapr.

Para usar daprState en Python v2, configure el proyecto con las dependencias correctas.

  1. Creación y activación de un entorno virtual

  2. En el archivo requirements.text, agregue la línea siguiente:

    azure-functions==1.18.0b3

  3. En el terminal, instale la biblioteca de Python.

    pip install -r .\requirements.txt

  4. Modifique su archivo local.setting.json con la configuración siguiente:

    "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1

Pasos siguientes

Más información acerca de la administración de estado Dapr.