ربط إدخال حالة Dapr لوظائف Azure

يسمح لك ربط إدخال حالة Dapr بقراءة حالة Dapr أثناء تنفيذ دالة.

للحصول على معلومات حول تفاصيل الإعداد والتكوين لملحق Dapr، راجع نظرة عامة على ملحق Dapr.

مثال

يمكن إنشاء وظيفة #C باستخدام أحد أوضاع C# التالية:

نموذج التنفيذ	‏‏الوصف
نموذج عامل معزول	تعمل تعليمة دالتك البرمجية في عملية عامل .NET منفصلة. استخدم مع الإصدارات المدعومة من .NET و.NET Framework. لمعرفة المزيد، راجع تطوير وظائف معالجة العامل المعزولة .NET.
نموذج قيد المعالجة	تعمل تعليمة دالتك البرمجية في نفس العملية مثل عملية مضيف الدالات. يدعم إصدارات الدعم طويل الأجل (LTS) فقط من .NET. لمعرفة المزيد، راجع تطوير وظائف مكتبة فئة .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);
}

عملية معزولة

تتوفر المزيد من العينات لربط حالة إدخال Dapr في مستودع GitHub.

[Function("StateInputBinding")]
public static string Run(
    [HttpTrigger(AuthorizationLevel.Function, "get", Route = "state/{key}")] HttpRequestData req,
    [DaprStateInput("statestore", Key = "{key}")] string state, 
    FunctionContext functionContext)
{
    var log = functionContext.GetLogger("StateInputBinding");
    log.LogInformation("C# HTTP trigger function processed a request.");

    return state;
}

ينشئ المثال التالي دالة "RetreveOrder" باستخدام DaprStateInput الربط مع DaprServiceInvocationTrigger:

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

Node.js v4

في المثال التالي، تتم إضافة ربط إدخال استدعاء Dapr ك extraInput وإقرانه بمشغل HTTP، والذي تم تسجيله بواسطة 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;
    }
});

Node.js v3

تظهر الأمثلة التالية مشغلات Dapr في ملف function.json ورمز JavaScript الذي يستخدم هذه الروابط.

فيما يلي ملف function.json ل daprState:

{
  "bindings": 
    {
      "type": "daprState",
      "direction": "in",
      "dataType": "string",
      "name": "state",
      "stateStore": "statestore",
      "key": "{key}"
    }
}

لمزيد من المعلومات حول خصائص الملف function.json ، راجع قسم التكوين .

ها هي كود JavaScript:

module.exports = async function (context, req) {
    context.log('Current state of this function: ' + context.bindings.daprState);
};

تظهر الأمثلة التالية مشغلات Dapr في ملف function.json ورمز PowerShell الذي يستخدم هذه الروابط.

فيما يلي ملف function.json ل daprState:

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

لمزيد من المعلومات حول خصائص الملف function.json ، راجع قسم التكوين .

في التعليمات البرمجية:

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"

Python v2

يوضح المثال التالي ربط إدخال حالة Dapr، والذي يستخدم نموذج برمجة v2 Python. لاستخدام daprState الربط جنبا إلى جنب مع في التعليمات البرمجية daprServiceInvocationTrigger لتطبيق وظيفة 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)

Python v1

يوضح المثال التالي ربط إدخال حالة Dapr، والذي يستخدم نموذج برمجة v1 Python.

فيما يلي ملف function.json ل daprState:

{
  "scriptFile": "__init__.py",
  "bindings": 
    {
      "type": "daprState",
      "direction": "in",
      "dataType": "string",
      "name": "state",
      "stateStore": "statestore",
      "key": "{key}"
    }
}

لمزيد من المعلومات حول خصائص الملف function.js، راجع قسم التكوين الذي يشرح هذه الخصائص.

إليك التعليمة البرمجية لـ Python:

import logging
import json
import azure.functions as func

def main(payload, data: str) -> None:
    logging.info('Python function processed a RetrieveOrder request from the Dapr Runtime.')
    logging.info(data)

السمات

قيد التنفيذ

في النموذج قيد المعالجة، استخدم DaprState لقراءة حالة Dapr في الدالة الخاصة بك، والتي تدعم هذه المعلمات:

المعلمة	‏‏الوصف‬
مخزن الولاية	اسم مخزن الحالة لاسترداد الحالة.
المفتاح	اسم المفتاح المراد استرداده من مخزن الحالة المحدد.

عملية معزولة

في نموذج العامل المعزول، استخدم DaprStateInput لقراءة حالة Dapr في الدالة الخاصة بك، والتي تدعم هذه المعلمات:

المعلمة	‏‏الوصف‬
مخزن الولاية	اسم مخزن الحالة لاسترداد الحالة.
المفتاح	اسم المفتاح المراد استرداده من مخزن الحالة المحدد.

تعليقات توضيحية

DaprStateInput يسمح لك التعليق التوضيحي بقراءة حالة Dapr في وظيفتك.

العنصر	الوصف
stateStore	اسم مخزن ولاية Dapr.
مفتاح	قيمة مفتاح مخزن الحالة.

التكوين

Node.js v4

يوضح الجدول التالي خصائص تكوين الربط التي قمت بتعيينها في التعليمات البرمجية.

الخاصية	‏‏الوصف
stateStore	اسم مخزن الولاية.
مفتاح	اسم المفتاح المراد استرداده من مخزن الحالة المحدد.

Node.js v3

يشرح الجدول الآتي خصائص تكوين ربط البيانات التي عليك تعيينها في ملف function.json.

خاصية function.json	‏‏الوصف
stateStore	اسم مخزن الولاية.
مفتاح	اسم المفتاح المراد استرداده من مخزن الحالة المحدد.

يشرح الجدول الآتي خصائص تكوين ربط البيانات التي عليك تعيينها في ملف function.json.

خاصية function.json	‏‏الوصف
مفتاح	اسم المفتاح المراد استرداده من مخزن الحالة المحدد.
stateStore	اسم مخزن الولاية.

Python v2

يوضح الجدول التالي خصائص تكوين الربط التي @dapp.dapr_state_input قمت بتعيينها في التعليمات البرمجية ل Python.

الخاصية	‏‏الوصف
state_store	اسم مخزن الولاية.
مفتاح	قيمة المفتاح السري. اسم المفتاح المراد استرداده من مخزن الحالة المحدد.

Python v1

يشرح الجدول الآتي خصائص تكوين ربط البيانات التي عليك تعيينها في ملف function.json.

خاصية function.json	‏‏الوصف
stateStore	اسم مخزن الولاية.
مفتاح	اسم المفتاح المراد استرداده من مخزن الحالة المحدد.

راجع قسم Example للحصول على أمثلة كاملة.

الاستخدام

لاستخدام ربط إدخال حالة Dapr، ابدأ بإعداد مكون مخزن حالة Dapr. يمكنك معرفة المزيد حول المكون الذي يجب استخدامه وكيفية إعداده في وثائق Dapr الرسمية.

• مواصفات مكون مخزن حالة Dapr
• كيفية: حفظ الحالة

Python v2

لاستخدام daprState في Python v2، قم بإعداد مشروعك باستخدام التبعيات الصحيحة.

1. إنشاء بيئة ظاهرية وتنشيطها

2. في الملف، requirements.text أضف السطر التالي:

   azure-functions==1.18.0b3
   

3. في المحطة الطرفية، قم بتثبيت مكتبة Python.

   pip install -r .\requirements.txt
   

4. قم بتعديل الملف الخاص بك local.setting.json بالتكوين التالي:

   "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
   

Python v1

لا يتطلب نموذج Python v1 أي تغييرات إضافية، بصرف النظر عن إعداد مخزن الحالة.

الخطوات التالية

تعرف على المزيد حول إدارة حالة Dapr.