Dapr State bemeneti kötés az Azure Functionshez
A Dapr-állapot bemeneti kötése lehetővé teszi a Dapr-állapot olvasását egy függvény végrehajtása során.
A Dapr-bővítmény beállítási és konfigurációs részleteiről a Dapr bővítmény áttekintésében olvashat.
Példa
A C#-függvények a következő C#-módok egyikével hozhatók létre:
Végrehajtási modell | Leírás |
---|---|
Izolált feldolgozói modell | A függvénykód egy külön .NET-feldolgozófolyamatban fut. A .NET és a .NET-keretrendszer támogatott verzióival használható. További információ: .NET izolált feldolgozói folyamatfüggvények fejlesztése. |
Folyamaton belüli modell | A függvénykód ugyanabban a folyamatban fut, mint a Functions gazdafolyamata. Csak a .NET hosszú távú támogatási (LTS) verzióit támogatja. További információ: .NET-osztálykódtár-függvények fejlesztése. |
[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);
}
Az alábbi példa egy függvényt "RetreveOrder"
hoz létre a DaprStateInput
következő kötéssel DaprServiceInvocationTrigger
:
@FunctionName("RetrieveOrder")
public String run(
@DaprServiceInvocationTrigger(
methodName = "RetrieveOrder")
String payload,
@DaprStateInput(
stateStore = "%StateStoreName%",
key = "order")
String product,
final ExecutionContext context)
A következő példában a Dapr-meghívás bemeneti kötése hozzáadódik és extraInput
párosítva lesz egy HTTP-eseményindítóval, amelyet az app
objektum regisztrál:
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;
}
});
Az alábbi példák a Dapr-eseményindítókat mutatják be egy function.json fájlban és a PowerShell-kódban, amely ezeket a kötéseket használja.
A következő function.json fájl:daprState
{
"bindings":
{
"type": "daprState",
"direction": "in",
"key": "order",
"stateStore": "%StateStoreName%",
"name": "order"
}
}
A function.json fájltulajdonságokról a Konfiguráció szakaszban talál további információt.
Kódban:
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"
Az alábbi példa egy Dapr State bemeneti kötést mutat be, amely a v2 Python programozási modellt használja. A kötés és a daprServiceInvocationTrigger
Python-függvényalkalmazás kódjának használatadaprState
:
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)
Attribútumok
A folyamatban lévő modellben a DaprState
Dapr állapotot olvassa be a függvénybe, amely a következő paramétereket támogatja:
Paraméter | Leírás |
---|---|
StateStore | Az állapot lekéréséhez használt állapottároló neve. |
Kulcs | A megadott állapottárolóból lekérendő kulcs neve. |
Jegyzetek
A DaprStateInput
széljegyzet lehetővé teszi a Dapr állapot beolvasását a függvénybe.
Elem | Leírás |
---|---|
stateStore | A Dapr-állapottároló neve. |
key | Az állapottároló kulcsértéke. |
Konfiguráció
Az alábbi táblázat a kódban beállított kötéskonfigurációs tulajdonságokat ismerteti.
Tulajdonság | Leírás |
---|---|
stateStore | Az állapottároló neve. |
key | A megadott állapottárolóból lekérendő kulcs neve. |
Az alábbi táblázat a function.json fájlban beállított kötéskonfigurációs tulajdonságokat ismerteti.
function.json tulajdonság | Leírás |
---|---|
key | A megadott állapottárolóból lekérendő kulcs neve. |
stateStore | Az állapottároló neve. |
A teljes példákért tekintse meg a Példa szakaszt .
Használat
A Dapr-állapot bemeneti kötésének használatához először állítson be egy Dapr-állapottároló-összetevőt. A hivatalos Dapr-dokumentációban többet is megtudhat arról, hogy melyik összetevőt használja, és hogyan állíthatja be.
A Python v2-ben való daprState
használatához állítsa be a projektet a megfelelő függőségekkel.
requirements.text
A fájlban adja hozzá a következő sort:azure-functions==1.18.0b3
Telepítse a Python-kódtárat a terminálban.
pip install -r .\requirements.txt
Módosítsa a
local.setting.json
fájlt a következő konfigurációval:"PYTHON_ISOLATE_WORKER_DEPENDENCIES":1