مشغل Dapr Topic ل Azure Functions

يمكن تشغيل Azure Functions على اشتراك موضوع Dapr باستخدام أحداث Dapr التالية.

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

مثال

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

نموذج التنفيذ	‏‏الوصف
نموذج عامل معزول	تعمل تعليمة دالتك البرمجية في عملية عامل .NET منفصلة. استخدم مع الإصدارات المدعومة من .NET و.NET Framework. لمعرفة المزيد، راجع تطوير وظائف معالجة العامل المعزولة .NET.
نموذج قيد المعالجة	تعمل تعليمة دالتك البرمجية في نفس العملية مثل عملية مضيف الدالات. يدعم إصدارات الدعم طويل الأجل (LTS) فقط من .NET. لمعرفة المزيد، راجع تطوير وظائف مكتبة فئة .NET.

قيد التنفيذ

[FunctionName("TransferEventBetweenTopics")]
public static void Run(
    [DaprTopicTrigger("%PubSubName%", Topic = "A")] CloudEvent subEvent,
    [DaprPublish(PubSubName = "%PubSubName%", Topic = "B")] out DaprPubSubEvent pubEvent,
    ILogger log)
{
    log.LogInformation("C# function processed a TransferEventBetweenTopics request from the Dapr Runtime.");


    pubEvent = new DaprPubSubEvent("Transfer from Topic A: " + subEvent.Data);
}

عملية معزولة

[Function("TransferEventBetweenTopics")]
[DaprPublishOutput(PubSubName = "%PubSubName%", Topic = "B")]
public static DaprPubSubEvent Run(
    [DaprTopicTrigger("%PubSubName%", Topic = "A")] CloudEvent subEvent, FunctionContext functionContext)
{
    var log = functionContext.GetLogger("TransferEventBetweenTopics");
    log.LogInformation("C# function processed a TransferEventBetweenTopics request from the Dapr Runtime.");

    return new DaprPubSubEvent("Transfer from Topic A: " + subEvent.Data);
}

إليك رمز Java للاشتراك في موضوع باستخدام مشغل Dapr Topic:

@FunctionName("PrintTopicMessage")
public String run(
        @DaprTopicTrigger(
            pubSubName = "%PubSubName%",
            topic = "B")
        String payload,
        final ExecutionContext context) throws JsonProcessingException {
    Logger logger = context.getLogger();
    logger.info("Java function processed a PrintTopicMessage request from the Dapr Runtime.");

Node.js v4

استخدم الكائن app لتسجيل daprTopicTrigger:

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

app.generic('TransferEventBetweenTopics', {
    trigger: trigger.generic({
        type: 'daprTopicTrigger',
        name: "subEvent",
        pubsubname: "%PubSubName%",
        topic: "A"
    }),
    return: daprPublishOutput,
    handler: async (request, context) => {
        context.log("Node function processed a TransferEventBetweenTopics request from the Dapr Runtime.");
        context.log(context.triggerMetadata.subEvent.data);

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

Node.js v3

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

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

{
  "bindings": [
    {
      "type": "daprTopicTrigger",
      "pubsubname": "messagebus",
      "topic": "B",
      "name": "subEvent"
    }
  ]
}

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

فيما يلي التعليمات البرمجية JavaScript لمشغل Dapr Topic:

module.exports = async function (context) {
    context.log("Node function processed a PrintTopicMessage request from the Dapr Runtime.");
    context.log(`Topic B received a message: ${context.bindings.subEvent.data}.`);
};

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

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

{
  "bindings": [
    {
      "type": "daprTopicTrigger",
      "pubsubname": "%PubSubName%",
      "topic": "B",
      "name": "subEvent",
      "direction": "in"
    }
  ]
}

لمزيد من المعلومات حول خصائص الملف 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 (
    $subEvent
)

Write-Host "PowerShell function processed a PrintTopicMessage request from the Dapr Runtime."

# Convert the object to a JSON-formatted string with ConvertTo-Json
$jsonString = $subEvent["data"] | ConvertTo-Json -Compress

Write-Host "Topic B received a message: $jsonString"

Python v2

يظهر المثال التالي مشغل Dapr Topic، والذي يستخدم نموذج برمجة v2 Python. لاستخدام في التعليمات البرمجية daprTopicTrigger لتطبيق دالة Python:

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="PrintTopicMessage")
@app.dapr_topic_trigger(arg_name="subEvent", pub_sub_name="%PubSubName%", topic="B", route="B")
def main(subEvent) -> None:
    logging.info('Python function processed a PrintTopicMessage request from the Dapr Runtime.')
    subEvent_json = json.loads(subEvent)
    logging.info("Topic B received a message: " + subEvent_json["data"])

Python v1

يظهر المثال التالي مشغل Dapr Topic، والذي يستخدم نموذج برمجة v1 Python.

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

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "type": "daprTopicTrigger",
      "pubsubname": "messagebus",
      "topic": "B",
      "name": "subEvent",
      "direction": "in"
    }
  ]
}

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

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

import logging
import json
import azure.functions as func

def main(subEvent) -> None:
    logging.info('Python function processed a PrintTopicMessage request from the Dapr Runtime.')
    subEvent_json = json.loads(subEvent)
    logging.info("Topic B received a message: " + subEvent_json["data"])

السمات

قيد التنفيذ

في النموذج قيد المعالجة، استخدم DaprTopicTrigger لتشغيل ربط النشر/الفرعي ل Dapr، والذي يدعم الخصائص التالية.

المعلمة	‏‏الوصف‬
PubSubName	اسم Dapr pub/sub.
الموضوع	اسم موضوع Dapr.

عملية معزولة

في نموذج العامل المعزول، استخدم DaprTopicTrigger لتعريف مشغل موضوع Dapr، والذي يدعم هذه المعلمات:

المعلمة	‏‏الوصف‬
PubSubName	اسم Dapr pub/sub.
الموضوع	اسم موضوع Dapr.

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

يتيح لك التعليق التوضيحي DaprTopicTrigger إنشاء دالة يتم تشغيلها عند تلقي موضوع ما.

العنصر	الوصف
pubSubName	اسم Dapr pub/sub.
الموضوع	اسم موضوع Dapr.

التكوين

Node.js v4

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

الخاصية	‏‏الوصف
pubsubname	اسم نوع المكون Dapr pub/sub.
الموضوع	اسم الموضوع.

Node.js v3

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

خاصية function.json	‏‏الوصف
pubsubname	اسم نوع المكون Dapr pub/sub.
الموضوع	اسم الموضوع.

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

خاصية function.json	‏‏الوصف
pubsubname	اسم نوع المكون Dapr pub/sub.
الموضوع	اسم الموضوع.

Python v2

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

الخاصية	‏‏الوصف	يمكن إرسالها عبر السمة	يمكن إرسالها عبر RequestBody
pub_sub_name	اسم نوع مكون اشتراك Dapr.	✔️	❌
الموضوع	موضوع الاشتراك.	✔️	❌

Python v1

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

خاصية function.json	‏‏الوصف	يمكن إرسالها عبر السمة	يمكن إرسالها عبر RequestBody
pubsubname	اسم نوع مكون اشتراك Dapr.	✔️	❌
الموضوع	اسم الموضوع.	✔️	❌

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

الاستخدام

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

• مواصفات مكون Dapr pub/sub
• كيفية: نشر رسالة والاشتراك في موضوع

Python v2

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

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

تعرف على المزيد حول نشر Dapr والاشتراك فيه.