التعامل مع الأحداث الخارجية

يمكن لوظائف التنسيق الانتظار والاستماع إلى الأحداث الخارجية. هذه الميزة في Durable Functions غالبا ما تكون مفيدة للتعامل مع التفاعل البشري أو محفزات خارجية أخرى.

ملحوظة

الأحداث الخارجية هي عمليات غير متزامنة أحادية الاتجاه. ليست مناسبة للحالات التي يحتاج فيها العميل الذي يرسل الحدث إلى استجابة متزامنة من وظيفة المنسق.

يمكن للتوزيعات الموسيقية الانتظار والاستماع إلى الأحداث الخارجية. غالبا ما تكون هذه الميزة مفيدة للتعامل مع التفاعل البشري أو المحفزات الخارجية الأخرى.

ملحوظة

الأحداث الخارجية هي عمليات غير متزامنة أحادية الاتجاه. ليست مناسبة للمواقف التي يحتاج فيها العميل الذي يرسل الحدث إلى استجابة متزامنة من التنسيق.

مهم

حاليا، حزمة تطوير المهام الدائمة PowerShell غير متوفرة.

انتظر الأحداث

تسمح واجهة برمجة التطبيقات "انتظار حدث خارجي"لربط محفز التنسيق لوظيفة المنسق بالانتظار والاستماع بشكل غير متزامن لحدث يقدمه عميل خارجي. وظيفة المنسق الاستماعي تعلن عن اسم الحدث وشكل البيانات التي يتوقع استلامها.

تسمح واجهة برمجة التطبيقات "انتظار الحدث الخارجي" للتنسيق بالانتظار والاستماع بشكل غير متزامن لحدث يسلمها عميل خارجي. تعلن التوزيع الموسيقي للاستماع اسم الحدث وشكل البيانات التي يتوقع استلامها.

C#‎

نموذج عامل معزول

using Microsoft.Azure.Functions.Worker;
using Microsoft.DurableTask;
using Microsoft.Extensions.Logging;

public class BudgetApproval
{
    private readonly ILogger _logger;

    public BudgetApproval(ILoggerFactory loggerFactory)
    {
        _logger = loggerFactory.CreateLogger<BudgetApproval>();
    }

    [Function("BudgetApproval")]
    public async Task Run(
        [OrchestrationTrigger] TaskOrchestrationContext context)
    {
        bool approved = await context.WaitForExternalEventAsync<bool>("Approval");
        if (approved)
        {
            // approval granted - do the approved action
        }
        else
        {
            // approval denied - send a notification
        }
    }
}

نموذج قيد المعالجة

[FunctionName("BudgetApproval")]
public static async Task Run(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    bool approved = await context.WaitForExternalEvent<bool>("Approval");
    if (approved)
    {
        // approval granted - do the approved action
    }
    else
    {
        // approval denied - send a notification
    }
}

ملحوظة

إذا كنت تستخدم Durable Functions 1.x، استخدم DurableOrchestrationContext بدلا من IDurableOrchestrationContext. اطلع على مقال Durable Functions versions لمزيد من التفاصيل المتعلقة بالإصدارات.

JavaScript

const df = require("durable-functions");

module.exports = df.orchestrator(function*(context) {
    const approved = yield context.df.waitForExternalEvent("Approval");
    if (approved) {
        // approval granted - do the approved action
    } else {
        // approval denied - send a notification
    }
});

Python

import azure.functions as func
import azure.durable_functions as df

def orchestrator_function(context: df.DurableOrchestrationContext):
    approved = yield context.wait_for_external_event('Approval')
    if approved:
        # approval granted - do the approved action
    else:
        # approval denied - send a notification

main = df.Orchestrator.create(orchestrator_function)

Java

@FunctionName("WaitForExternalEvent")
public void waitForExternalEvent(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx) {
    boolean approved = ctx.waitForExternalEvent("Approval", boolean.class).await();
    if (approved) {
        // approval granted - do the approved action
    } else {
        // approval denied - send a notification
    }
}

بوويرشيل

param($Context)

$approved = Start-DurableExternalEventListener -EventName "Approval"

if ($approved) {
    # approval granted - do the approved action
} else {
    # approval denied - send a notification
}

C#‎

public class BudgetApproval : TaskOrchestrator<object?, bool>
{
    public override async Task<bool> RunAsync(TaskOrchestrationContext context, object? input)
    {
        bool approved = await context.WaitForExternalEvent<bool>("Approval");
        if (approved)
        {
            // approval granted - do the approved action
        }
        else
        {
            // approval denied - send a notification
        }
        return approved;
    }
}

Python

from durabletask import task

def budget_approval(ctx: task.OrchestrationContext, _):
    approved = yield ctx.wait_for_external_event("Approval")
    if approved:
        # approval granted - do the approved action
        pass
    else:
        # approval denied - send a notification
        pass
    return approved

Java

public class BudgetApproval implements TaskOrchestration {
    @Override
    public void run(TaskOrchestrationContext ctx) {
        boolean approved = ctx.waitForExternalEvent("Approval", boolean.class).await();
        if (approved) {
            // approval granted - do the approved action
        } else {
            // approval denied - send a notification
        }
    }
}

JavaScript

import { OrchestrationContext, TOrchestrator } from "@microsoft/durabletask-js";

const budgetApproval: TOrchestrator = async function* (ctx: OrchestrationContext): any {
    const approved = yield ctx.waitForExternalEvent("Approval");
    if (approved) {
        // approval granted - do the approved action
    } else {
        // approval denied - send a notification
    }
    return approved;
};

بوويرشيل

حزمة تطوير المهام المتغيرة غير متوفرة لجهاز PowerShell. استخدم Durable Functions بدلا من ذلك.

المثال السابق يستمع لحدث واحد محدد ويتخذ إجراء عند استلام الحدث.

يمكنك الاستماع إلى عدة أحداث في نفس الوقت، كما في المثال التالي، الذي ينتظر أحد ثلاثة إشعارات محتملة للأحداث.

C#‎

نموذج عامل معزول

[Function("Select")]
public async Task Run(
    [OrchestrationTrigger] TaskOrchestrationContext context)
{
    Task<float> event1 = context.WaitForExternalEventAsync<float>("Event1");
    Task<bool> event2 = context.WaitForExternalEventAsync<bool>("Event2");
    Task<int> event3 = context.WaitForExternalEventAsync<int>("Event3");

    Task winner = await Task.WhenAny(event1, event2, event3);
    if (winner == event1)
    {
        // ...
    }
    else if (winner == event2)
    {
        // ...
    }
    else if (winner == event3)
    {
        // ...
    }
}

نموذج قيد المعالجة

[FunctionName("Select")]
public static async Task Run(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    var event1 = context.WaitForExternalEvent<float>("Event1");
    var event2 = context.WaitForExternalEvent<bool>("Event2");
    var event3 = context.WaitForExternalEvent<int>("Event3");

    var winner = await Task.WhenAny(event1, event2, event3);
    if (winner == event1)
    {
        // ...
    }
    else if (winner == event2)
    {
        // ...
    }
    else if (winner == event3)
    {
        // ...
    }
}

ملحوظة

هل تستخدم Durable Functions 1.x؟ قم DurableOrchestrationContext بالتبديل بدلا من IDurableOrchestrationContext. راجع مقالة Durable Functions versions لتتعرف على اختلافات الإصدارات الأخرى.

JavaScript

const df = require("durable-functions");

module.exports = df.orchestrator(function*(context) {
    const event1 = context.df.waitForExternalEvent("Event1");
    const event2 = context.df.waitForExternalEvent("Event2");
    const event3 = context.df.waitForExternalEvent("Event3");

    const winner = yield context.df.Task.any([event1, event2, event3]);
    if (winner === event1) {
        // ...
    } else if (winner === event2) {
        // ...
    } else if (winner === event3) {
        // ...
    }
});

Python

import azure.functions as func
import azure.durable_functions as df

def orchestrator_function(context: df.DurableOrchestrationContext):
    event1 = context.wait_for_external_event('Event1')
    event2 = context.wait_for_external_event('Event2')
    event3 = context.wait_for_external_event('Event3')

    winner = yield context.task_any([event1, event2, event3])
    if winner == event1:
        # ...
    elif winner == event2:
        # ...
    elif winner == event3:
        # ...

main = df.Orchestrator.create(orchestrator_function)

Java

@FunctionName("Select")
public void selectOrchestrator(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx) {
    Task<Void> event1 = ctx.waitForExternalEvent("Event1");
    Task<Void> event2 = ctx.waitForExternalEvent("Event2");
    Task<Void> event3 = ctx.waitForExternalEvent("Event3");

    Task<?> winner = ctx.anyOf(event1, event2, event3).await();
    if (winner == event1) {
        // ...
    } else if (winner == event2) {
        // ...
    } else if (winner == event3) {
        // ...
    }
}

بوويرشيل

param($Context)

$event1 = Start-DurableExternalEventListener -EventName "Event1" -NoWait
$event2 = Start-DurableExternalEventListener -EventName "Event2" -NoWait
$event3 = Start-DurableExternalEventListener -EventName "Event3" -NoWait

$winner = Wait-DurableTask -Task @($event1, $event2, $event3) -Any

if ($winner -eq $event1) {
    # ...
} else if ($winner -eq $event2) {
    # ...
} else if ($winner -eq $event3) {
    # ...
}

C#‎

public class SelectOrchestrator : TaskOrchestrator<object?, object?>
{
    public override async Task<object?> RunAsync(TaskOrchestrationContext context, object? input)
    {
        Task<float> event1 = context.WaitForExternalEvent<float>("Event1");
        Task<bool> event2 = context.WaitForExternalEvent<bool>("Event2");
        Task<int> event3 = context.WaitForExternalEvent<int>("Event3");

        Task winner = await Task.WhenAny(event1, event2, event3);
        if (winner == event1)
        {
            // ...
        }
        else if (winner == event2)
        {
            // ...
        }
        else if (winner == event3)
        {
            // ...
        }
        return null;
    }
}

Python

from durabletask import task

def select_orchestrator(ctx: task.OrchestrationContext, _):
    event1 = ctx.wait_for_external_event("Event1")
    event2 = ctx.wait_for_external_event("Event2")
    event3 = ctx.wait_for_external_event("Event3")

    winner = yield task.when_any([event1, event2, event3])
    if winner == event1:
        # ...
        pass
    elif winner == event2:
        # ...
        pass
    elif winner == event3:
        # ...
        pass

Java

public class SelectOrchestrator implements TaskOrchestration {
    @Override
    public void run(TaskOrchestrationContext ctx) {
        Task<Void> event1 = ctx.waitForExternalEvent("Event1");
        Task<Void> event2 = ctx.waitForExternalEvent("Event2");
        Task<Void> event3 = ctx.waitForExternalEvent("Event3");

        Task<?> winner = ctx.anyOf(event1, event2, event3).await();
        if (winner == event1) {
            // ...
        } else if (winner == event2) {
            // ...
        } else if (winner == event3) {
            // ...
        }
    }
}

JavaScript

import { OrchestrationContext, TOrchestrator, whenAny } from "@microsoft/durabletask-js";

const selectOrchestrator: TOrchestrator = async function* (ctx: OrchestrationContext): any {
    const event1 = ctx.waitForExternalEvent("Event1");
    const event2 = ctx.waitForExternalEvent("Event2");
    const event3 = ctx.waitForExternalEvent("Event3");

    const winner = yield whenAny([event1, event2, event3]);
    if (winner === event1) {
        // ...
    } else if (winner === event2) {
        // ...
    } else if (winner === event3) {
        // ...
    }
};

بوويرشيل

حزمة تطوير المهام المتغيرة غير متوفرة لجهاز PowerShell. استخدم Durable Functions بدلا من ذلك.

المثال السابق يستمع لأي من الأحداث المتعددة. يمكنك أيضا الانتظار لجميع الفعاليات.

C#‎

نموذج عامل معزول

[Function("NewBuildingPermit")]
public async Task Run(
    [OrchestrationTrigger] TaskOrchestrationContext context)
{
    string applicationId = context.GetInput<string>();

    Task gate1 = context.WaitForExternalEventAsync<object>("CityPlanningApproval");
    Task gate2 = context.WaitForExternalEventAsync<object>("FireDeptApproval");
    Task gate3 = context.WaitForExternalEventAsync<object>("BuildingDeptApproval");

    // all three departments must grant approval before a permit can be issued
    await Task.WhenAll(gate1, gate2, gate3);

    await context.CallActivityAsync("IssueBuildingPermit", applicationId);
}

نموذج قيد المعالجة

[FunctionName("NewBuildingPermit")]
public static async Task Run(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    string applicationId = context.GetInput<string>();

    var gate1 = context.WaitForExternalEvent("CityPlanningApproval");
    var gate2 = context.WaitForExternalEvent("FireDeptApproval");
    var gate3 = context.WaitForExternalEvent("BuildingDeptApproval");

    // all three departments must grant approval before a permit can be issued
    await Task.WhenAll(gate1, gate2, gate3);

    await context.CallActivityAsync("IssueBuildingPermit", applicationId);
}

ملحوظة

إذا كنت تستخدم Durable Functions 1.x، استخدم DurableOrchestrationContext بدلا من IDurableOrchestrationContext. توجه إلى Durable Functions versions للحصول على شرح كامل لفروقات الإصدارات.

في .NET، إذا لم يكن بالإمكان تحويل حمولة الحدث إلى النوع المتوقع T، يتم إلقاء استثناء.

JavaScript

const df = require("durable-functions");

module.exports = df.orchestrator(function*(context) {
    const applicationId = context.df.getInput();

    const gate1 = context.df.waitForExternalEvent("CityPlanningApproval");
    const gate2 = context.df.waitForExternalEvent("FireDeptApproval");
    const gate3 = context.df.waitForExternalEvent("BuildingDeptApproval");

    // all three departments must grant approval before a permit can be issued
    yield context.df.Task.all([gate1, gate2, gate3]);

    yield context.df.callActivity("IssueBuildingPermit", applicationId);
});

Python

import azure.functions as func
import azure.durable_functions as df

def orchestrator_function(context: df.DurableOrchestrationContext):
    application_id = context.get_input()

    gate1 = context.wait_for_external_event('CityPlanningApproval')
    gate2 = context.wait_for_external_event('FireDeptApproval')
    gate3 = context.wait_for_external_event('BuildingDeptApproval')

    yield context.task_all([gate1, gate2, gate3])
    yield context.call_activity('IssueBuildingPermit', application_id)

main = df.Orchestrator.create(orchestrator_function)

Java

@FunctionName("NewBuildingPermit")
public void newBuildingPermit(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx) {
    String applicationId = ctx.getInput(String.class);

    Task<Void> gate1 = ctx.waitForExternalEvent("CityPlanningApproval");
    Task<Void> gate2 = ctx.waitForExternalEvent("FireDeptApproval");
    Task<Void> gate3 = ctx.waitForExternalEvent("BuildingDeptApproval");

    // all three departments must grant approval before a permit can be issued
    ctx.allOf(List.of(gate1, gate2, gate3)).await();

    ctx.callActivity("IssueBuildingPermit", applicationId).await();
}

بوويرشيل

param($Context)

$applicationId = $Context.Input
$gate1 = Start-DurableExternalEventListener -EventName "CityPlanningApproval" -NoWait
$gate2 = Start-DurableExternalEventListener -EventName "FireDeptApproval" -NoWait
$gate3 = Start-DurableExternalEventListener -EventName "BuildingDeptApproval" -NoWait

Wait-DurableTask -Task @($gate1, $gate2, $gate3)

Invoke-ActivityFunction -FunctionName 'IssueBuildingPermit' -Input $applicationId

C#‎

public class NewBuildingPermit : TaskOrchestrator<string, object?>
{
    public override async Task<object?> RunAsync(TaskOrchestrationContext context, string applicationId)
    {
        Task<object?> gate1 = context.WaitForExternalEvent<object?>("CityPlanningApproval");
        Task<object?> gate2 = context.WaitForExternalEvent<object?>("FireDeptApproval");
        Task<object?> gate3 = context.WaitForExternalEvent<object?>("BuildingDeptApproval");

        // all three departments must grant approval before a permit can be issued
        await Task.WhenAll(gate1, gate2, gate3);

        await context.CallActivityAsync("IssueBuildingPermit", applicationId);
        return null;
    }
}

في .NET، إذا لم يكن بالإمكان تحويل حمولة الحدث إلى النوع المتوقع T، يتم إلقاء استثناء.

Python

from durabletask import task

def issue_building_permit(ctx: task.ActivityContext, application_id: str) -> None:
    # Issue the permit
    pass

def new_building_permit(ctx: task.OrchestrationContext, application_id: str):
    gate1 = ctx.wait_for_external_event("CityPlanningApproval")
    gate2 = ctx.wait_for_external_event("FireDeptApproval")
    gate3 = ctx.wait_for_external_event("BuildingDeptApproval")

    # all three departments must grant approval before a permit can be issued
    yield task.when_all([gate1, gate2, gate3])
    yield ctx.call_activity(issue_building_permit, input=application_id)

Java

public class NewBuildingPermit implements TaskOrchestration {
    @Override
    public void run(TaskOrchestrationContext ctx) {
        String applicationId = ctx.getInput(String.class);

        Task<Void> gate1 = ctx.waitForExternalEvent("CityPlanningApproval");
        Task<Void> gate2 = ctx.waitForExternalEvent("FireDeptApproval");
        Task<Void> gate3 = ctx.waitForExternalEvent("BuildingDeptApproval");

        // all three departments must grant approval before a permit can be issued
        ctx.allOf(List.of(gate1, gate2, gate3)).await();

        ctx.callActivity("IssueBuildingPermit", applicationId).await();
    }
}

JavaScript

import { ActivityContext, OrchestrationContext, TOrchestrator, whenAll } from "@microsoft/durabletask-js";

const issueBuildingPermit = async (_: ActivityContext, applicationId: string): Promise<void> => {
    // Issue the permit
};

const newBuildingPermit: TOrchestrator = async function* (
    ctx: OrchestrationContext,
    applicationId: string,
): any {
    const gate1 = ctx.waitForExternalEvent("CityPlanningApproval");
    const gate2 = ctx.waitForExternalEvent("FireDeptApproval");
    const gate3 = ctx.waitForExternalEvent("BuildingDeptApproval");

    // all three departments must grant approval before a permit can be issued
    yield whenAll([gate1, gate2, gate3]);
    yield ctx.callActivity(issueBuildingPermit, applicationId);
};

بوويرشيل

حزمة تطوير المهام المتغيرة غير متوفرة لجهاز PowerShell. استخدم Durable Functions بدلا من ذلك.

واجهة برمجة التطبيقات "انتظار الحدث الخارجي" تنتظر إلى أجل غير مسمى بعض المدخلات. يمكنك تفريغ تطبيق الوظائف بأمان أثناء الانتظار. إذا وعندما وصل حدث لهذا المثيل التنسيقي، يتم إيقاظ المثيل تلقائيا ويعالج الحدث فورا.

ملحوظة

إذا كان تطبيق الوظيفة الخاص بك يستخدم خطة الاستهلاك، فلن يتم فرض رسوم فوترة أثناء انتظار وظيفة المنسق مهمة حدث خارجي، بغض النظر عن مدة الانتظار.

كما هو الحال مع وظائف النشاط، تحتوي الأحداث الخارجية على ضمان تسليم مرة واحدة على الأقل . هذا يعني أنه تحت ظروف معينة (مثل إعادة التشغيل، التكبير، الأعطال، إلخ)، قد يتلقى تطبيقك نسخا من نفس الحدث الخارجي. لذلك، نوصي بأن تحتوي الأحداث الخارجية على نوع من معرف يسمح بإزالتها يدويا في المنظمات.

واجهة برمجة التطبيقات "انتظار الحدث الخارجي" تنتظر إلى أجل غير مسمى بعض المدخلات. يمكنك إيقاف العامل بأمان أثناء الانتظار. إذا وعندما وصل حدث لهذا الحدث التنظيمي، يتم إيقاظه تلقائيا ويعالج الحدث فورا.

الفعاليات الخارجية لديها ضمان تسليم مرة واحدة على الأقل . هذا يعني أنه تحت ظروف معينة (مثل إعادة التشغيل، التكبير، الأعطال، إلخ)، قد يتلقى تطبيقك نسخا من نفس الحدث الخارجي. لذلك، نوصي بأن تحتوي الأحداث الخارجية على نوع من معرف يسمح بإزالتها يدويا في التنسيقات.

إرسال الأحداث

يمكنك استخدام واجهة برمجة التطبيقات "raise-event" المعرفة بواسطة ربط عميل التنسيق لإرسال حدث خارجي إلى التنسيق. يمكنك أيضا استخدام واجهة HTTP المدمجة لحدث raise لإرسال حدث خارجي إلى تنسيق التنسيق.

الحدث المرتفع يشمل معلمات instanceIDو a eventNameو eventData as (معلمات). تتعامل وظائف المنسق مع هذه الأحداث باستخدام wait-for-external-event واجهات برمجة التطبيقات (APIs). يجب أن يتطابق كل eventName من جهة الإرسالوالاستقبال لكي يتم معالجة الحدث. يجب أن تكون بيانات الحدث أيضا قابلة للتسلسل عبر JSON.

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

ملحوظة

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

فيما يلي مثال على دالة يتم تفعيلها عبر قائمة الانتظار ترسل حدث "موافقة" إلى مثيل دالة المنسق. معرف مثيل التنسيق يأتي من نص رسالة الطابور.

يمكنك استخدام واجهة برمجة التطبيقات "raise-event" على عميل Durable Task لإرسال حدث خارجي إلى تنسيق التنسيق.

يتضمن الحدث المرتفع معرف مثيل، واسم حدث، وبيانات حدث كمعلمات. تتعامل التنسيقات مع هذه الأحداث باستخدام واجهات برمجة التطبيقات "انتظار الحدث الخارجي". يجب أن يتطابق اسم الحدث في كل من جهة الإرسال والاستقبال لكي يتم معالجة الحدث. يجب أن تكون بيانات الحدث أيضا قابلة للتسلسل عبر JSON.

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

ملحوظة

إذا لم يكن هناك نسخة تنسيقية ب "، instanceIDيتم التخلص من رسالة الحدث.

فيما يلي مثال يرسل حدث "موافقة" إلى مثيل توزيع أوركستراني.

C#‎

نموذج عامل معزول

using Microsoft.Azure.Functions.Worker;
using Microsoft.DurableTask.Client;

public class ApprovalQueueProcessor
{
    [Function("ApprovalQueueProcessor")]
    public async Task Run(
        [QueueTrigger("approval-queue")] string instanceId,
        [DurableClient] DurableTaskClient client)
    {
        await client.RaiseEventAsync(instanceId, "Approval", true);
    }
}

نموذج قيد المعالجة

[FunctionName("ApprovalQueueProcessor")]
public static async Task Run(
    [QueueTrigger("approval-queue")] string instanceId,
    [DurableClient] IDurableOrchestrationClient client)
{
    await client.RaiseEventAsync(instanceId, "Approval", true);
}

ملحوظة

بالنسبة ل Durable Functions 1.x، استخدم خاصية OrchestrationClient ونوع معامل DurableOrchestrationClient بدلا من ذلك. تحقق من مقالة Durable Functions version لجميع التغييرات الخاصة بالإصدارات.

JavaScript

const df = require("durable-functions");

module.exports = async function(context, instanceId) {
    const client = df.getClient(context);
    await client.raiseEvent(instanceId, "Approval", true);
};

Python

import azure.functions as func
import azure.durable_functions as df

async def main(instance_id:str, starter: str) -> func.HttpResponse:
    client = df.DurableOrchestrationClient(starter)
    await client.raise_event(instance_id, 'Approval', True)

Java

@FunctionName("ApprovalQueueProcessor")
public void approvalQueueProcessor(
        @QueueTrigger(name = "instanceID", queueName = "approval-queue") String instanceID,
        @DurableClientInput(name = "durableContext") DurableClientContext durableContext) {
    durableContext.getClient().raiseEvent(instanceID, "Approval", true);
}

بوويرشيل

param($instanceId)

Send-DurableExternalEvent -InstanceId $InstanceId -EventName "Approval"

داخليا، تقوم واجهة "الحدث المتزايد" بإدخال رسالة يتم التقاطها من قبل وظيفة المنسق المنتظرة. إذا لم يكن المثيل ينتظر اسم الحدث المحدد، تضاف رسالة الحدث إلى مخزن مؤقت داخل الذاكرة. إذا بدأ مثيل التنسيق لاحقا بالاستماع لاسم ذلك الحدث، فإنه يتحقق من المخزن المؤقت بحثا عن رسائل الأحداث ويشغل المهمة التي كانت تنتظره.

ملحوظة

إذا لم يكن هناك مثيل تنسيق بمعرف النسخة المحدد، يتم التخلص من رسالة الحدث.

C#‎

await client.RaiseEventAsync(instanceId, "Approval", true);

Python

client.raise_orchestration_event(instance_id, "Approval", data=True)

Java

client.raiseEvent(instanceId, "Approval", true);

JavaScript

await client.raiseOrchestrationEvent(instanceId, "Approval", true);

بوويرشيل

حزمة تطوير المهام المتغيرة غير متوفرة لجهاز PowerShell. استخدم Durable Functions بدلا من ذلك.

داخليا، تقوم واجهة "حدث الرفع" بإدخال رسالة يتم التقاطها من قبل التنسيق المنتظر. إذا لم يكن المثيل ينتظر اسم الحدث المحدد، تضاف رسالة الحدث إلى مخزن مؤقت داخل الذاكرة. إذا بدأ التنسيق لاحقا في الاستماع لاسم ذلك الحدث، فسيتحقق من المخزن المؤقت بحثا عن رسائل الأحداث ويشغل المهمة التي كانت تنتظره.

ملحوظة

إذا لم يكن هناك مثيل تنسيق بمعرف النسخة المحدد، يتم التخلص من رسالة الحدث.

HTTP

فيما يلي مثال على طلب HTTP الذي يرفع حدثا Approval إلى مثيل تنسيق.

POST /runtime/webhooks/durabletask/instances/MyInstanceId/raiseEvent/Approval&code=XXX
Content-Type: application/json

"true"

في هذه الحالة، يتم ترميز معرف النسخة كمعرف MyInstanceId.

أفضل الممارسات للفعاليات الخارجية

احتفظ بأفضل الممارسات التالية في اعتبارك عند العمل مع الفعاليات الخارجية:

استخدم أسماء الأحداث الفريدة لإزالة التكرار

الفعاليات الخارجية لديها ضمان تسليم مرة واحدة على الأقل . في ظروف نادرة معينة (والتي قد تحدث أثناء إعادة التشغيل أو التحجيم أو الأعطال)، قد يتلقى تطبيقك نسخا من نفس الحدث الخارجي. نوصي بأن تحتوي الأحداث الخارجية على معرف فريد يسمح بإزالتها يدويا في المنظمات.

ملحوظة

مزود تخزين MSSQL يستهلك الأحداث الخارجية ويحدث حالة المنسق بشكل معاملاتي، لذا لا يوجد خطر تكرار الأحداث مع تلك الخلفية، على عكس مزود Azure Storage. ومع ذلك، لا يزال ينصح بأن تكون للأحداث الخارجية أسماء فريدة حتى يكون الكود محمولا عبر الخلفية.

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

تعلم كيفية تنفيذ معالجة الأخطاء

شغل عينة تنتظر تفاعل بشري

ابدأ مع مجموعات تطوير المهام الدائمة