Bagikan melalui

Pengikatan input Status Dapr untuk Azure Functions

  • Artikel

Pengikatan input status Dapr memungkinkan Anda membaca status Dapr selama eksekusi fungsi.

Untuk informasi tentang penyiapan dan detail konfigurasi ekstensi Dapr, lihat gambaran umum ekstensi Dapr.

Contoh

Fungsi C# dapat dibuat menggunakan salah satu mode C# berikut:

Model eksekusi Deskripsi
Model pekerja terisolasi Kode fungsi Anda berjalan dalam proses pekerja .NET terpisah. Gunakan dengan versi .NET dan .NET Framework yang didukung. Untuk mempelajari lebih lanjut, lihat Mengembangkan fungsi proses pekerja terisolasi .NET.
Model dalam proses Kode fungsi Anda berjalan dalam proses yang sama dengan proses host Azure Functions. Hanya mendukung versi Dukungan Jangka Panjang (LTS) .NET. Untuk mempelajari lebih lanjut, lihat Mengembangkan fungsi pustaka kelas .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);
}

Contoh berikut membuat "RetreveOrder" fungsi menggunakan pengikatan DaprStateInput dengan DaprServiceInvocationTrigger:

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

Dalam contoh berikut, pengikatan input pemanggilan Dapr ditambahkan sebagai extraInput dan dipasangkan dengan pemicu HTTP, yang didaftarkan oleh app objek:

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

Contoh berikut menunjukkan pemicu Dapr dalam file function.json dan kode PowerShell yang menggunakan pengikatan tersebut.

Berikut adalah file function.json untuk daprState:

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

Untuk informasi selengkapnya tentang properti file function.json , lihat bagian Konfigurasi .

Dalam kode:

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"

Contoh berikut menunjukkan pengikatan input Status Dapr, yang menggunakan model pemrograman Python v2. Untuk menggunakan pengikatan daprState bersama daprServiceInvocationTrigger dalam kode aplikasi fungsi Python Anda:

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)

Atribut

Dalam model dalam proses, gunakan DaprState untuk membaca status Dapr ke dalam fungsi Anda, yang mendukung parameter ini:

Parameter Deskripsi
StateStore Nama penyimpanan status untuk mengambil status.
Kunci Nama kunci yang akan diambil dari penyimpanan status yang ditentukan.

Anotasi

Anotasi DaprStateInput memungkinkan Anda membaca status Dapr ke dalam fungsi Anda.

Elemen Deskripsi
stateStore Nama penyimpanan status Dapr.
kunci Nilai kunci penyimpanan status.

Konfigurasi

Tabel berikut menjelaskan properti konfigurasi pengikatan yang Anda tetapkan dalam kode.

Properti Deskripsi
stateStore Nama penyimpanan status.
kunci Nama kunci yang akan diambil dari penyimpanan status yang ditentukan.

Tabel berikut menjelaskan properti konfigurasi pengikatan yang Anda atur di file function.json.

Properti function.json Deskripsi
kunci Nama kunci yang akan diambil dari penyimpanan status yang ditentukan.
stateStore Nama penyimpanan status.

Tabel berikut menjelaskan properti konfigurasi pengikatan untuk @dapp.dapr_state_input yang Anda tetapkan dalam kode Python Anda.

Properti Deskripsi
state_store Nama penyimpanan status.
kunci Nilai kunci rahasia. Nama kunci yang akan diambil dari penyimpanan status yang ditentukan.

Lihat Bagian contoh untuk contoh lengkapnya.

Penggunaan

Untuk menggunakan pengikatan input status Dapr, mulailah dengan menyiapkan komponen penyimpanan status Dapr. Anda dapat mempelajari selengkapnya tentang komponen mana yang akan digunakan dan cara menyiapkannya dalam dokumentasi Resmi Dapr.

Untuk menggunakan daprState di Python v2, siapkan proyek Anda dengan dependensi yang benar.

  1. Membuat dan mengaktifkan lingkungan virtual

  2. Di file Anda requirements.text , tambahkan baris berikut:

    azure-functions==1.18.0b3

  3. Di terminal, instal pustaka Python.

    pip install -r .\requirements.txt

  4. Ubah file Anda local.setting.json dengan konfigurasi berikut:

    "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1

Langkah berikutnya

Pelajari selengkapnya tentang manajemen status Dapr.