قم بتطبيق مؤقتات متينة للتأخيرات وانتهاء الوقت

مهم

سينتهي الدعم للنموذج قيد التنفيذ في 10 نوفمبر 2026. نوصي بشدة بترحيل تطبيقاتك إلى نموذج العامل المعزول للحصول على الدعم الكامل.

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

توفر مجموعات تطوير المهام المتطورة مؤقتات متينة للاستخدام في التنسيقات لتنفيذ التأخيرات أو لإعداد مهلات زمنية على الإجراءات غير المتزامنة. استخدم مؤقتات متينة في التنسيقات بدلا من sleepdelay واجهات برمجة التطبيقات التي قد تكون مدمجة في اللغة.

مهم

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

المؤقتات المتطورة هي مهام يتم إنشاؤها باستخدام واجهة برمجة التطبيقات المناسبة create timer للغة المقدمة، كما هو موضح في الأمثلة التالية، وتستغرق إما وقتا مستحقا أو مدة كوسيط.

C#‎

// Put the orchestrator to sleep for 72 hours
DateTime dueTime = context.CurrentUtcDateTime.AddHours(72);
await context.CreateTimer(dueTime, CancellationToken.None);

JavaScript

// Put the orchestrator to sleep for 72 hours
// Note that DateTime comes from the "luxon" module
const deadline = DateTime.fromJSDate(context.df.currentUtcDateTime, {zone: 'utc'}).plus({ hours: 72 });
yield context.df.createTimer(deadline.toJSDate());

Python

# Put the orchestrator to sleep for 72 hours
due_time = context.current_utc_datetime + timedelta(hours=72)
durable_timeout_task = context.create_timer(due_time)

بوويرشيل

# Put the orchestrator to sleep for 72 hours
$duration = New-TimeSpan -Hours 72
Start-DurableTimer -Duration $duration

Java

// Put the orchestrator to sleep for 72 hours
ctx.createTimer(Duration.ofHours(72)).await();

C#‎

// Put the orchestration to sleep for 72 hours
await context.CreateTimer(TimeSpan.FromHours(72), CancellationToken.None);

Python

# Put the orchestration to sleep for 72 hours
from datetime import timedelta
yield ctx.create_timer(timedelta(hours=72))

Java

// Put the orchestration to sleep for 72 hours
ctx.createTimer(Duration.ofHours(72)).await();

JavaScript

// Put the orchestration to sleep for 72 hours
yield ctx.createTimer(72 * 60 * 60);

بوويرشيل

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

عند تنفيذ await مهمة المؤقت، تظل وظيفة المنسق نائمة حتى وقت انتهاء الصلاحية المحدد.

عندما تقوم await بمهمة المؤقت، يبقى التوزيع في حالة نوم حتى الوقت المحدد.

ملحوظة

تستمر الآلات الموسيقية في معالجة الأحداث الواردة الأخرى أثناء انتظار انتهاء مهمة المؤقت.

قيود المؤقت المتانة

عندما تنشئ مؤقتا ينتهي في الساعة 4:30 مساء بالتوقيت العالمي، يقوم إطار العمل الأساسي بإنشاء رسالة تظهر فقط عند الساعة 4:30 مساء بالتوقيت العالمي. إذا تم تقليل عدد الاستخدامات إلى صفر في هذه الأثناء، تضمن رسالة المؤقت المرئية الجديدة تفعيل تطبيق الوظائف مرة أخرى على آلة افتراضية مناسبة.

ملحوظة

• بالنسبة لتطبيقات JavaScript وPython وPowerShell، فإن المؤقتات الطويلة محدودة بستة أيام فقط. لتجاوز هذا القيد، استخدم واجهات برمجة التطبيقات المؤقتة في حلقة while لمحاكاة تأخير أطول. تدعم تطبيقات .NET وJava المحدثة تطبيقات طويلة الأمد بشكل تعسفي.
• اعتمادا على إصدار مجموعة تطوير البرمجيات ومزود التخزين المستخدم، قد يتم تنفيذ المؤقتات الطويلة التي تستمر ستة أيام أو أكثر داخليا باستخدام سلسلة من المؤقتات الأقصر (على سبيل المثال، بمدة ثلاثة أيام) حتى الوصول إلى وقت انتهاء الصلاحية المرغوب. يمكن ملاحظة هذا السلوك في مخزن البيانات الأساسي لكنه لا يؤثر على سلوك التنسيق.
• لا تستخدم واجهات برمجة تطبيقات مدمجة للتاريخ أو الوقت للحصول على الوقت الحالي. عند حساب تاريخ مستقبلي لانتهاء المؤقت، استخدم دائما واجهة برمجة التطبيقات الحالية للوقت في وظيفة المنسق. لمزيد من المعلومات، راجع المقالة قيود رمز دالة المنسق.

عندما تنشئ مؤقتا ينتهي في الساعة 4:30 مساء بالتوقيت العالمي، يقوم إطار العمل الأساسي بإنشاء رسالة تظهر فقط عند الساعة 4:30 مساء بالتوقيت العالمي. تضمن رسالة المؤقت أن العامل ينشط مرة أخرى عند انتهاء المؤقت.

ملحوظة

• تحديد تأخير طويل (على سبيل المثال، تأخير لبضعة أيام أو أكثر) قد يؤدي إلى إنشاء عدة مؤقتات دائمة مدارة داخليا. لا يحتاج كود التوزيع الموسيقي إلى أن يكون على علم بهذا السلوك. ومع ذلك، قد يكون مرئيا في سجلات الإطار وحالة التاريخ المخزن.
• لا تستخدم واجهات برمجة التطبيقات المدمجة للتاريخ والوقت للحصول على الوقت الحالي. عند حساب تاريخ مستقبلي لانتهاء المؤقت، استخدم دائما خاصية الوقت الحالية لسياق التوزيع (مثل context.CurrentUtcDateTime في .NET، ctx.current_utc_datetime في Python، أو ctx.currentUtcDateTime في JavaScript).

استخدم مؤقتات متينة للتأخيرات

يوضح المثال التالي كيفية استخدام مؤقتات متينة لتأخير التنفيذ. المثال يصدر إشعار فوترة يوميا لمدة 10 أيام.

C#‎

[FunctionName("BillingIssuer")]
public static async Task Run(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    for (int i = 0; i < 10; i++)
    {
        DateTime deadline = context.CurrentUtcDateTime.Add(TimeSpan.FromDays(1));
        await context.CreateTimer(deadline, CancellationToken.None);
        await context.CallActivityAsync("SendBillingEvent");
    }
}

ملحوظة

المثال السابق من C# يستهدف Durable Functions 2.x. بالنسبة ل Durable Functions 1.x، استخدم DurableOrchestrationContext بدلا من IDurableOrchestrationContext. لمزيد من المعلومات حول الفروقات بين الإصدارات، راجع مقال Durable Functions versions.

JavaScript

const df = require("durable-functions");
const { DateTime } = require("luxon");

module.exports = df.orchestrator(function*(context) {
    for (let i = 0; i < 10; i++) {
        const deadline = DateTime.fromJSDate(context.df.currentUtcDateTime, {zone: 'utc'}).plus({ days: 1 });
        yield context.df.createTimer(deadline.toJSDate());
        yield context.df.callActivity("SendBillingEvent");
    }
});

Python

import azure.functions as func
import azure.durable_functions as df
from datetime import datetime, timedelta

def orchestrator_function(context: df.DurableOrchestrationContext):
    for i in range(0, 9):
        deadline = context.current_utc_datetime + timedelta(days=1)
        yield context.create_timer(deadline)
        yield context.call_activity("SendBillingEvent")

main = df.Orchestrator.create(orchestrator_function)

بوويرشيل

param($Context)

for ($num = 0 ; $num -le 9 ; $num++){
    $expiryTime = New-TimeSpan -Days 1
    $timerTask = Start-DurableTimer -Duration $expiryTime
    Invoke-DurableActivity -FunctionName 'SendBillingEvent'
}

Java

@FunctionName("BillingIssuer")
public String billingIssuer(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx) {
    for (int i = 0; i < 10; i++) {
        ctx.createTimer(Duration.ofDays(1)).await();
        ctx.callActivity("SendBillingEvent").await();
    }
    return "done";
}

C#‎

public class BillingIssuer : TaskOrchestrator<object?, string>
{
    public override async Task<string> RunAsync(TaskOrchestrationContext context, object? input)
    {
        for (int i = 0; i < 10; i++)
        {
            await context.CreateTimer(TimeSpan.FromDays(1), CancellationToken.None);
            await context.CallActivityAsync("SendBillingEvent");
        }
        return "done";
    }
}

Python

from datetime import timedelta
from durabletask import task

def send_billing_event(ctx: task.ActivityContext, _) -> None:
    # Send billing event
    pass

def billing_issuer(ctx: task.OrchestrationContext, _):
    for i in range(10):
        yield ctx.create_timer(timedelta(days=1))
        yield ctx.call_activity(send_billing_event)
    return "done"

Java

public class BillingIssuer implements TaskOrchestration {
    @Override
    public void run(TaskOrchestrationContext ctx) {
        for (int i = 0; i < 10; i++) {
            ctx.createTimer(Duration.ofDays(1)).await();
            ctx.callActivity("SendBillingEvent").await();
        }
        ctx.complete("done");
    }
}

JavaScript

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

const sendBillingEvent = async (_: ActivityContext): Promise<void> => {
    // Send billing event
};

const billingIssuer: TOrchestrator = async function* (ctx: OrchestrationContext): any {
    for (let i = 0; i < 10; i++) {
        yield ctx.createTimer(24 * 60 * 60); // 1 day
        yield ctx.callActivity(sendBillingEvent);
    }
    return "done";
};

بوويرشيل

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

التحذير

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

التحذير

تجنب الحلقات اللانهائية في التوزيعات. للحصول على معلومات حول كيفية تنفيذ سيناريوهات الحلقات اللانهائية بأمان وكفاءة، راجع التنسيقات الأبدية.

استخدم مؤقتات متينة لإيقاف الوقت

يوضح هذا المثال كيفية استخدام المؤقتات المتينة لتنفيذ المهلات:

C#‎

[FunctionName("TryGetQuote")]
public static async Task<bool> Run(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    TimeSpan timeout = TimeSpan.FromSeconds(30);
    DateTime deadline = context.CurrentUtcDateTime.Add(timeout);

    using (var cts = new CancellationTokenSource())
    {
        Task activityTask = context.CallActivityAsync("GetQuote");
        Task timeoutTask = context.CreateTimer(deadline, cts.Token);

        Task winner = await Task.WhenAny(activityTask, timeoutTask);
        if (winner == activityTask)
        {
            // success case
            cts.Cancel();
            return true;
        }
        else
        {
            // timeout case
            return false;
        }
    }
}

ملحوظة

يستهدف المثال السابق من C# Durable Functions 2.x. بالنسبة ل Durable Functions 1.x، استخدم DurableOrchestrationContext بدلا من IDurableOrchestrationContext. لمزيد من المعلومات حول الفروقات بين الإصدارات، راجع مقال Durable Functions versions.

JavaScript

const df = require("durable-functions");
const { DateTime } = require("luxon");

module.exports = df.orchestrator(function*(context) {
    const deadline = DateTime.fromJSDate(context.df.currentUtcDateTime, {zone: 'utc'}).plus({ seconds: 30 });

    const activityTask = context.df.callActivity("GetQuote");
    const timeoutTask = context.df.createTimer(deadline.toJSDate());

    const winner = yield context.df.Task.any([activityTask, timeoutTask]);
    if (winner === activityTask) {
        // success case
        timeoutTask.cancel();
        return true;
    }
    else
    {
        // timeout case
        return false;
    }
});

Python

import azure.functions as func
import azure.durable_functions as df
from datetime import datetime, timedelta

def orchestrator_function(context: df.DurableOrchestrationContext):
    deadline = context.current_utc_datetime + timedelta(seconds=30)
    activity_task = context.call_activity("GetQuote")
    timeout_task = context.create_timer(deadline)

    winner = yield context.task_any([activity_task, timeout_task])
    if winner == activity_task:
        timeout_task.cancel()
        return True
    elif winner == timeout_task:
        return False

main = df.Orchestrator.create(orchestrator_function)

بوويرشيل

param($Context)

$expiryTime =  New-TimeSpan -Seconds 30

$activityTask = Invoke-DurableActivity -FunctionName 'GetQuote' -NoWait
$timerTask = Start-DurableTimer -Duration $expiryTime -NoWait

$winner = Wait-DurableTask -Task @($activityTask, $timerTask) -Any

if ($winner -eq $activityTask) {
    Stop-DurableTimerTask -Task $timerTask
    return $True
}
else {
    return $False
}

Java

@FunctionName("TryGetQuote")
public boolean tryGetQuote(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx) {
    Task<Double> activityTask = ctx.callActivity("GetQuote", Double.class);
    Task<Void> timerTask = ctx.createTimer(Duration.ofSeconds(30));

    Task<?> winner = ctx.anyOf(activityTask, timerTask);
    if (winner == activityTask) {
        // success case
        return true;
    } else {
        // timeout case
        return false;
    }
}

C#‎

public class TryGetQuote : TaskOrchestrator<object?, bool>
{
    public override async Task<bool> RunAsync(TaskOrchestrationContext context, object? input)
    {
        using var cts = new CancellationTokenSource();

        Task<double> activityTask = context.CallActivityAsync<double>("GetQuote");
        Task timeoutTask = context.CreateTimer(TimeSpan.FromSeconds(30), cts.Token);

        Task winner = await Task.WhenAny(activityTask, timeoutTask);
        if (winner == activityTask)
        {
            // success case
            cts.Cancel();
            return true;
        }
        else
        {
            // timeout case
            return false;
        }
    }
}

Python

from datetime import timedelta
from durabletask import task

def get_quote(ctx: task.ActivityContext, _) -> float:
    # Get quote logic
    return 100.0

def try_get_quote(ctx: task.OrchestrationContext, _):
    activity_task = ctx.call_activity(get_quote)
    timeout_task = ctx.create_timer(timedelta(seconds=30))

    winner = yield task.when_any([activity_task, timeout_task])
    if winner == activity_task:
        # success case
        return True
    else:
        # timeout case
        return False

Java

public class TryGetQuote implements TaskOrchestration {
    @Override
    public void run(TaskOrchestrationContext ctx) {
        Task<Double> activityTask = ctx.callActivity("GetQuote", Double.class);
        Task<Void> timerTask = ctx.createTimer(Duration.ofSeconds(30));

        Task<?> winner = ctx.anyOf(activityTask, timerTask).await();
        if (winner == activityTask) {
            // success case
            ctx.complete(true);
        } else {
            // timeout case
            ctx.complete(false);
        }
    }
}

JavaScript

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

const getQuote = async (_: ActivityContext): Promise<number> => {
    // Get quote logic
    return 100.0;
};

const tryGetQuote: TOrchestrator = async function* (ctx: OrchestrationContext): any {
    const activityTask = ctx.callActivity(getQuote);
    const timeoutTask = ctx.createTimer(30);

    const winner = yield whenAny([activityTask, timeoutTask]);
    if (winner === activityTask) {
        // success case
        return true;
    } else {
        // timeout case
        return false;
    }
};

بوويرشيل

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

التحذير

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

التحذير

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

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

للحصول على مثال أكثر تفصيلا حول كيفية تنفيذ المهمات المنفصلة في وظائف المنسق، راجع مقالة التفاعل البشري .

آلية الإلغاء هذه باستخدام نمط متى-أي لا تنهي النشاط الجاري أو تنفيذ التوزيع الفرعي. بل ببساطة يسمح للتوزيع الموسيقي بتجاهل النتيجة والمضي قدما.

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

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

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