Dela via

Dapr State-indatabindning för Azure Functions

  • Artikel

Med Indatabindningen för Dapr-tillstånd kan du läsa Dapr-tillstånd under en funktionskörning.

Information om installation och konfiguration av Dapr-tillägget finns i översikten över Dapr-tillägget.

Exempel

En C#-funktion kan skapas med något av följande C#-lägen:

Körningsmodell beskrivning
Isolerad arbetsmodell Funktionskoden körs i en separat .NET-arbetsprocess. Använd med versioner av .NET och .NET Framework som stöds. Mer information finns i Utveckla .NET-isolerade arbetsprocessfunktioner.
Processmodell Funktionskoden körs i samma process som Functions-värdprocessen. Stöder endast LTS-versioner (Long Term Support) av .NET. Mer information finns i Utveckla .NET-klassbiblioteksfunktioner. 
[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);
}

I följande exempel skapas en "RetreveOrder" funktion med bindningen DaprStateInput med DaprServiceInvocationTrigger:

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

I följande exempel läggs Dapr-indatabindningen till som en extraInput och paras ihop med en HTTP-utlösare, som registreras av app objektet:

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;
    }
});

I följande exempel visas Dapr-utlösare i en function.json-fil och PowerShell-kod som använder dessa bindningar.

Här är filen function.json för daprState:

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

Mer information om function.json filegenskaper finns i avsnittet Konfiguration .

I kod:

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"

I följande exempel visas en Dapr State-indatabindning som använder programmeringsmodellen v2 Python. Så här använder du bindningen daprState tillsammans med daprServiceInvocationTrigger i python-funktionsappkoden:

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)

Attribut

I den processbaserade modellen använder du DaprState för att läsa Dapr-tillstånd i din funktion, som stöder följande parametrar:

Parameter Description
StateStore Namnet på tillståndsarkivet som ska hämta tillstånd.
Tangent Namnet på nyckeln som ska hämtas från det angivna tillståndsarkivet.

Kommentarer

Med anteckningen DaprStateInput kan du läsa Dapr-tillstånd i din funktion.

Element Description
stateStore Namnet på Dapr-tillståndsarkivet.
nyckel Nyckelvärdet för tillståndsarkivet.

Konfiguration

I följande tabell förklaras de bindningskonfigurationsegenskaper som du anger i koden.

Property beskrivning
stateStore Namnet på tillståndsarkivet.
nyckel Namnet på nyckeln som ska hämtas från det angivna tillståndsarkivet.

I följande tabell förklaras de bindningskonfigurationsegenskaper som du anger i function.json-filen.

function.json egenskap beskrivning
nyckel Namnet på nyckeln som ska hämtas från det angivna tillståndsarkivet.
stateStore Namnet på tillståndsarkivet.

I följande tabell beskrivs bindningskonfigurationsegenskaperna för @dapp.dapr_state_input som du anger i Python-koden.

Property beskrivning
state_store Namnet på tillståndsarkivet.
nyckel Värdet för den hemliga nyckeln. Namnet på nyckeln som ska hämtas från det angivna tillståndsarkivet.

Se avsnittet Exempel för fullständiga exempel.

Användning

Om du vill använda Indatabindningen för Dapr-tillstånd börjar du med att konfigurera en Dapr-tillståndslagerkomponent. Du kan lära dig mer om vilken komponent som ska användas och hur du konfigurerar den i den officiella Dapr-dokumentationen.

Om du vill använda daprState i Python v2 konfigurerar du projektet med rätt beroenden.

  1. Skapa och aktivera en virtuell miljö

  2. requirements.text Lägg till följande rad i filen:

    azure-functions==1.18.0b3

  3. Installera Python-biblioteket i terminalen.

    pip install -r .\requirements.txt

  4. local.setting.json Ändra filen med följande konfiguration:

    "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1

Nästa steg

Läs mer om Dapr-tillståndshantering.