ربط إخراج ربط Dapr لوظائف Azure

يوضح المثال التالي استخدام مشغل استدعاء خدمة Dapr وربط إخراج Dapr لقراءة طلب الربط ومعالجته.

[FunctionName("SendMessageToKafka")]
public static async Task Run(
    [DaprServiceInvocationTrigger] JObject payload,
    [DaprBinding(BindingName = "%KafkaBindingName%", Operation = "create")] IAsyncCollector<object> messages,
    ILogger log)
{
    log.LogInformation("C#  function processed a SendMessageToKafka request.");
    await messages.AddAsync(payload);
}

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

[Function("SendMessageToKafka")]
[DaprBindingOutput(BindingName = "%KafkaBindingName%", Operation = "create")]
public static JsonElement Run(
    [DaprServiceInvocationTrigger] JsonElement payload, FunctionContext functionContext)
{
    var log = functionContext.GetLogger("SendMessageToKafka");
    log.LogInformation("C#  function processed a SendMessageToKafka request.");

    return payload;
}

في المثال التالي، يتم إقران ربط إخراج Dapr بمشغل إخراج استدعاء Dapr، والذي تم تسجيله بواسطة app الكائن:

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

app.generic('SendMessageToKafka', {
    trigger: trigger.generic({
        type: 'daprServiceInvocationTrigger',
        name: "payload"
    }),
    return: daprBindingOutput,
    handler: async (request, context) => {
        context.log("Node function processed a SendMessageToKafka request from the Dapr Runtime.");
        context.log(context.triggerMetadata.payload)

        return { "data": context.triggerMetadata.payload };
    }
});

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

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

{
  "bindings": 
    {
      "type": "daprBinding",
      "direction": "out",
      "bindingName": "%KafkaBindingName%",
      "operation": "create",
      "name": "messages"
    }
}

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

ها هي كود JavaScript:

module.exports = async function (context) {
    context.log("Node HTTP trigger function processed a request.");
    context.bindings.messages = { "data": context.bindings.args };
};

يوضح المثال التالي ربط إخراج Dapr Binding، والذي يستخدم نموذج برمجة v2 Python. لاستخدامها @dapp.dapr_binding_output في التعليمات البرمجية لتطبيق وظائف Python:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="SendMessageToKafka")
@app.dapr_service_invocation_trigger(arg_name="payload", method_name="SendMessageToKafka")
@app.dapr_binding_output(arg_name="messages", binding_name="%KafkaBindingName%", operation="create")
def main(payload: str, messages: func.Out[bytes]) -> None:
    logging.info('Python processed a SendMessageToKafka request from the Dapr Runtime.')
    messages.set(json.dumps({"data": payload}).encode('utf-8'))

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

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

{
  "scriptFile": "__init__.py",
  "bindings": 
    {
      "type": "daprBinding",
      "direction": "out",
      "bindingName": "%KafkaBindingName%",
      "operation": "create",
      "name": "messages"
    }
}

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

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

import logging
import json
import azure.functions as func

def main(args, messages: func.Out[bytes]) -> None:
    logging.info('Python processed a SendMessageToKafka request from the Dapr Runtime.')
    messages.set(json.dumps({"data": args}))

في النموذج قيد المعالجة، استخدم DaprBinding لتعريف ربط إخراج ربط Dapr، والذي يدعم هذه المعلمات:

في نموذج العامل المعزول، استخدم DaprBindingOutput لتعريف ربط إخراج ربط Dapr، والذي يدعم هذه المعلمات:

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

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

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

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

لاستخدام daprBinding في 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 أي تغييرات إضافية، بصرف النظر عن إعداد مكون ربط الإخراج.