Dayanıklı İşlevler'deki zamanlayıcılar (Azure İşlevleri)

Dayanıklı İşlevler, gecikmeleri uygulamak veya zaman uyumsuz eylemlerde zaman aşımlarını ayarlamak için düzenleyici işlevlerinde kullanılmak üzere dayanıklı zamanlayıcılar sağlar. Dayanıklı zamanlayıcılar, dilde yerleşik olarak bulunabilecek "uyku" veya "gecikme" API'leri yerine düzenleyici işlevlerinde kullanılmalıdır.

Dayanıklı zamanlayıcılar, aşağıda gösterildiği gibi sağlanan dil için uygun "zamanlayıcı oluşturma" API'si kullanılarak oluşturulan ve bağımsız değişken olarak bir süre veya süre alan görevlerdir.

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)

PowerShell

# 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();

Zamanlayıcı görevini "beklediğiniz" zaman, orchestrator işlevi belirtilen süre sonu süresine kadar uyku moduna girer.

Dekont

Zamanlayıcı görevinin süresinin dolması beklenirken, düzenleme işlemleri diğer gelen olayları işlemeye devam eder.

Süreölçer sınırlamaları

Utc saat 16:30'da süresi dolan bir süreölçer oluşturduğunuzda, temel alınan Dayanıklı Görev Çerçevesi yalnızca 16:30 UTC'de görünür hale gelen bir ileti sıralar. Bu sırada işlev uygulamasının ölçeği sıfır örneğe düşürüldüyse, yeni görünen zamanlayıcı iletisi işlev uygulamasının uygun bir VM'de yeniden etkinleştirilmesini sağlar.

Dekont

• JavaScript, Python ve PowerShell uygulamaları için Dayanıklı zamanlayıcılar altı günle sınırlıdır. Bu sınırlamayı geçici olarak çözmek için, daha uzun bir gecikmenin benzetimini yapmak için döngüdeki while zamanlayıcı API'lerini kullanabilirsiniz. Güncel .NET ve Java uygulamaları rastgele uzun süreölçerleri destekler.
• Kullanılan SDK ve depolama sağlayıcısının sürümüne bağlı olarak, istenen süre sonu zamanına ulaşılana kadar 6 gün veya daha uzun süreölçerler dahili olarak bir dizi daha kısa süreölçer (örneğin, 3 günlük süreler) kullanılarak uygulanabilir. Bu, temel alınan veri deposunda gözlemlenebilir ancak düzenleme davranışını etkilemez.
• Geçerli saati almak için yerleşik tarih/saat API'lerini kullanmayın. Zamanlayıcının süresinin dolması için gelecekteki bir tarihi hesaplarken her zaman orchestrator işlevinin geçerli saat API'sini kullanın. Daha fazla bilgi için orchestrator işlev kodu kısıtlamaları makalesine bakın.

Gecikme için kullanım

Aşağıdaki örnekte, yürütmeyi geciktirmek için dayanıklı süreölçerlerin nasıl kullanılacağı gösterilmektedir. Örnek, 10 gün boyunca her gün bir faturalama bildirimi verme işlemidir.

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");
    }
}

Dekont

Önceki C# örneği 2.x Dayanıklı İşlevler hedeflemektedir. Dayanıklı İşlevler 1.x için yerine IDurableOrchestrationContextkullanmanız DurableOrchestrationContext gerekir. Sürümler arasındaki farklar hakkında daha fazla bilgi için Dayanıklı İşlevler sürümleri makalesine bakın.

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)

PowerShell

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";
}

Uyarı

Orchestrator işlevlerinde sonsuz döngülerden kaçının. Sonsuz döngü senaryolarını güvenli ve verimli bir şekilde uygulama hakkında bilgi için bkz . Eternal Orchestrations.

Zaman aşımı için kullanım

Bu örnekte, zaman aşımlarını uygulamak için dayanıklı zamanlayıcıların nasıl kullanılacağı gösterilmektedir.

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;
        }
    }
}

Dekont

Önceki C# örneği 2.x Dayanıklı İşlevler hedeflemektedir. Dayanıklı İşlevler 1.x için yerine IDurableOrchestrationContextkullanmanız DurableOrchestrationContext gerekir. Sürümler arasındaki farklar hakkında daha fazla bilgi için Dayanıklı İşlevler sürümleri makalesine bakın.

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)

PowerShell

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;
    }
}

Uyarı

.NET, JavaScript, Python ve PowerShell'de, kodunuz tamamlanmasını beklemiyorsa oluşturulan dayanıklı zamanlayıcıları iptal etmeniz gerekir. Bekleyen süreölçerleri iptal etme hakkında yukarıdaki örneklere bakın. Dayanıklı Görev Çerçevesi, dayanıklı zamanlayıcı görevleri de dahil olmak üzere tüm bekleyen görevler tamamlanana veya iptal edilene kadar düzenlemenin durumunu "Tamamlandı" olarak değiştirmez.

Herhangi bir zaman desenini kullanan bu iptal mekanizması devam eden etkinlik işlevini veya alt düzenleme yürütmelerini sonlandırmaz. Bunun yerine, orchestrator işlevinin sonucu yoksaymasına ve devam etmesine olanak tanır. İşlev uygulamanız Tüketim planını kullanıyorsa, bırakılan etkinlik işlevi tarafından tüketilen her zaman ve bellek için faturalandırılırsınız. Varsayılan olarak, Tüketim planında çalışan işlevlerin zaman aşımı beş dakikadır. Bu sınır aşılırsa, Azure İşlevleri ana bilgisayarı tüm yürütmeyi durdurmak ve bir kaçak faturalama durumunu önlemek için geri dönüştürülür. İşlev zaman aşımı yapılandırılabilir.

Orchestrator işlevlerinde zaman aşımlarını uygulama hakkında daha ayrıntılı bir örnek için İnsan Etkileşimi ve Zaman Aşımları - Telefon Doğrulama makalesine bakın.

Sonraki adımlar

Dış olayları tetiklemeyi ve işlemeyi öğrenin