Ebedi Orkestrasyonlar

Sonsuz orkestrasyonlar, API'yi kullanarak kendi geçmişlerini düzenli aralıklarla resetleyip süresiz çalışan orchestrator işlevleridir continue-as-new . Veri toplayıcılar, periyodik arka plan görevleri ve sınırsız tarihçe büyümesi olmadan sonsuz döngü gerektiren Dayanıklı İşlevler senaryoları için kullanışlıdır.

continue-as-new olmadan, sürekli döngüde olan bir orkestratör zamanlanmış her görevle orkestrasyon geçmişi biriktirir, ve sonunda performans problemlerine ve aşırı bellek tüketimine yol açar. Sonsuz düzenleme düzeni, her yinelemenin geçmişini sıfırlayarak bunu çözer.

Uyarı

C#, JavaScript, Python ve Java için sonsuz düzenleme kodu örnekleri sağlanır. PowerShell desteklemez continue-as-new.

Bu makalede:

• Yeniden başlatma nasıl çalışır — Yeniden başlatma mekanizması
• Dikkat edilmesi gerekenler — Özel durum davranışı, tamamlanmamış görevler ve dış olaylar
• Düzenli çalışma örneği — Zamanlayıcı çakışmalarını önleyen bir temizleme döngüsü
• Sonsuz bir düzenleme başlatın — Başlatma ve tekil desenler
• Sonsuz düzenlemeden çık — Zarif durdurma ve sonlandırma

Ebedi düzenlemeler , API'yi kullanarak continue-as-new kendi geçmişlerini düzenli aralıklarla sıfırlayarak süresiz olarak çalışan düzenlemelerdir. Toplayıcılar, düzenli arka plan işleri ve sınırsız geçmiş birikimi olmadan sonsuz döngü gerektiren tüm senaryolar için kullanışlıdır.

continue-as-new olmadan, sürekli döngüye giren bir orkestrasyon her zamanlanmış görevle birlikte geçmiş biriktirir ve nihayetinde performans sorunları ile aşırı bellek kullanımına yol açar. Sonsuz düzenleme düzeni, her yinelemenin geçmişini sıfırlayarak bunu çözer.

Önemli

Şu anda PowerShell Dayanıklı Görev SDK'sı kullanılamıyor.

Bu makalede:

• Yeni olarak devam etmenin işleyişi — Sıfırlama mekanizması
• Dikkat edilmesi gerekenler — Özel durum davranışı, tamamlanmamış görevler ve dış olaylar
• Düzenli çalışma örneği — Zamanlayıcı çakışmalarını önleyen bir temizleme döngüsü
• Sonsuz bir düzenleme başlatın — Başlatma ve tekil desenler
• Sürekli orkestrasyondan çıkış — Zarif durdurma ve son verme

Yeni olarak devam etme nasıl çalışır?

Orchestrator işlevleri, sonsuz döngüler kullanmak yerine continue-as-new yöntemini çağırarak durumlarını sıfırlar. Bu yöntem, sonraki orchestrator işlev oluşturma işlemi için yeni giriş haline gelen JSON serileştirilebilir bir parametre alır.

çağırdığınızda continue-as-newdüzenleme örneği yeni giriş değeriyle kendini yeniden başlatır. Aynı örnek kimliği korunur, ancak düzenleyici işlevinin geçmişi sıfırlanır.

Düzenlemeler, sonsuz döngüler kullanmak yerine düzenleme bağlamındaki continue-as-new yöntemini çağırarak durumunu sıfırlar. Bu yöntem, sonraki düzenleme nesli için yeni giriş haline gelen JSON serileştirilebilir bir parametre alır.

çağırdığınızda continue-as-newdüzenleme örneği yeni giriş değeriyle kendini yeniden başlatır. Aynı örnek kimliği korunur, ancak orkestrasyonun geçmişi sıfırlanır.

Ebedi düzenlemeyle ilgili dikkat edilmesi gerekenler

continue-as-new yöntemini bir düzenlemede kullanırken şu noktaları göz önünde bulundurun:

• Bir düzenleyici işlevi yöntemi kullanılarak continue-as-new sıfırlandığında Dayanıklı Görev Çerçevesi aynı örnek kimliğini korur, ancak dahili olarak yeni bir yürütme kimliği oluşturur ve kullanır. Bu yürütme kimliği harici olarak açığa çıkarılmaz, ancak orchestrasyon yürütmesi sırasında hata ayıklarken kullanışlıdır.

• Yürütme sırasında işlenmeyen bir özel durum oluştuğunda düzenleme başarısız bir duruma girer ve yürütme sonlandırılır. Bir finally bloğundan yapılan bir continue-as-new çağrısı, yakalanmayan bir özel durumdan sonra orchestrasyonu yeniden başlatmaz.

• Tamamlanmamış görevlerin sonuçları, bir orkestrasyon çağırdığında continue-as-new atılır. Örneğin, bir zamanlayıcı ayarlanırsa ve zamanlayıcı tetiklenmeden önce continue-as-new çağrılırsa, zamanlayıcı olayı atılır.

• İsteğe bağlı olarak, yeniden başlatmalar sırasında continue-as-new işlenmemiş dış olayları koruyabilirsiniz. C# dilinde, ContinueAsNew işlenmemiş olayları varsayılan olarak korur. Java'da continueAsNew de varsayılan olarak olayları korur. Python'da continue_as_new, save_events=True sürece olayları korumaz. JavaScript'te, continueAsNew bu davranışı denetlemek için bir saveEvents parametre (true veya false) gerektirir.

continue-as-new yöntemini bir düzenlemede kullanırken şu noktaları göz önünde bulundurun:

• Orkestrasyon continue-as-new metodu kullanılarak sıfırlandığında, Dayanıklı Görev SDK'ları aynı örnek kimliğini aynen muhafaza eder ancak bundan sonra dahili olarak yeni bir yürütme kimliği oluşturur ve kullanır. Bu yürütme kimliği dışarıdan kullanıma sunulmaz, ancak düzenleme yürütme hatalarını ayıklarken yararlı olabilir.

• Yürütme sırasında işlenmeyen bir özel durum oluştuğunda düzenleme başarısız bir duruma girer ve yürütme sonlandırılır. Bir finally bloktan continue-as-new çağrısı, yakalanmamış bir istisnadan sonra orkestrasyonu yeniden başlatmaz.

• Tamamlanmamış görevlerin sonuçları, bir orkestrasyon çağırdığında continue-as-new atılır. Örneğin, bir zamanlayıcı ayarlanırsa ve zamanlayıcı tetiklenmeden önce continue-as-new çağrılırsa, zamanlayıcı olayı atılır.

• İsteğe bağlı olarak, yeniden başlatmalar sırasında continue-as-new işlenmemiş dış olayları koruyabilirsiniz. .NET ve Java continue-as-new, işlenmemiş olayları varsayılan olarak korur. Python'da continue_as_new, save_events=True sürece olayları korumaz. JavaScript'te, continueAsNew bu davranışı denetlemek için bir saveEvents parametre (true veya false) gerektirir. Tüm durumlarda, düzenleme waitForExternalEvent veya wait_for_external_event öğesini bir sonraki çağırdığında işlenmemiş olaylar teslim edilir.

Düzenli çalışma örneği

Sonsuz düzenlemelerde yaygın kullanım örneklerinden biri, temizleme işleri gibi düzenli arka plan çalışmalarıdır.

Zamanlayıcı tetikleyicisi neden kullanılmıyor? CRON tabanlı zamanlayıcı tetikleyicisi, önceki çalıştırmanın tamamlanıp tamamlanmadığına bakılmaksızın sabit zamanlarda çalışır. Kalıcı düzenleme, sonraki yinelemeyi zamanlamadan önce çalışmanın tamamlanmasını bekler, bu yüzden çalıştırmalar hiç çakışmaz.

Approach	Zamanlama (1 saatlik aralık, 30 dakikalık iş)	Çakışma riski
Zamanlayıcı tetikleyicisi (CRON)	1:00, 2:00, 3:00	Evet — iş süreyi aşarsa
Ebedi düzenleme	1:00, 2:30, 4:00	Hayır — sonraki işlem tamamlanmayı bekler

C#

[FunctionName("Periodic_Cleanup_Loop")]
public static async Task Run(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    await context.CallActivityAsync("DoCleanup", null);

    // sleep for one hour between cleanups
    DateTime nextCleanup = context.CurrentUtcDateTime.AddHours(1);
    await context.CreateTimer(nextCleanup, CancellationToken.None);

    context.ContinueAsNew(null);
}

JavaScript

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

module.exports = df.orchestrator(function*(context) {
    yield context.df.callActivity("DoCleanup");

    // sleep for one hour between cleanups
    const nextCleanup = moment.utc(context.df.currentUtcDateTime).add(1, "h");
    yield context.df.createTimer(nextCleanup.toDate());

    yield context.df.continueAsNew(undefined);
});

Python

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

def orchestrator_function(context: df.DurableOrchestrationContext):
    yield context.call_activity("DoCleanup")

    # sleep for one hour between cleanups
    next_cleanup = context.current_utc_datetime + timedelta(hours = 1)
    yield context.create_timer(next_cleanup)

    context.continue_as_new(None)

main = df.Orchestrator.create(orchestrator_function)

PowerShell

PowerShell desteklemez continue-as-new. PowerShell'de düzenli çalışmalar için bunun yerine tekli düzenleme ile dayanıklı bir zamanlayıcı kullanın.

Java

@FunctionName("Periodic_Cleanup_Loop")
public void periodicCleanupLoop(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx) {
    ctx.callActivity("DoCleanup").await();

    ctx.createTimer(Duration.ofHours(1)).await();

    ctx.continueAsNew(null);
}

C#

public class PeriodicCleanupLoop : TaskOrchestrator<object?, object?>
{
    public override async Task<object?> RunAsync(TaskOrchestrationContext context, object? input)
    {
        await context.CallActivityAsync("DoCleanup");

        // sleep for one hour between cleanups
        await context.CreateTimer(TimeSpan.FromHours(1), CancellationToken.None);

        context.ContinueAsNew(null);
        return null;
    }
}

Python

from datetime import timedelta
from durabletask import task

def do_cleanup(ctx: task.ActivityContext, _) -> None:
    # Cleanup logic here
    pass

def periodic_cleanup_loop(ctx: task.OrchestrationContext, _):
    yield ctx.call_activity(do_cleanup)

    # sleep for one hour between cleanups
    yield ctx.create_timer(timedelta(hours=1))

    ctx.continue_as_new(None)

Java

public class PeriodicCleanupLoop implements TaskOrchestration {
    @Override
    public void run(TaskOrchestrationContext ctx) {
        ctx.callActivity("DoCleanup").await();

        // sleep for one hour between cleanups
        ctx.createTimer(Duration.ofHours(1)).await();

        ctx.continueAsNew(null);
    }
}

JavaScript

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

const doCleanup = async (_: ActivityContext, _input: void): Promise<void> => {
    // Cleanup logic here
};

const periodicCleanupLoop: TOrchestrator = async function* (ctx: OrchestrationContext): any {
    yield ctx.callActivity(doCleanup);

    // sleep for one hour between cleanups
    yield ctx.createTimer(60 * 60);

    ctx.continueAsNew(null, false);
};

PowerShell

Dayanıklı Görev SDK'sı PowerShell için kullanılamaz. PowerShell'deki kalıcı orkestrasyonlar için Dayanıklı İşlevler, bir kalıcı zamanlayıcı ve bir singleton deseni kullanın.

Sonsuz bir düzenleme başlatın

Diğer tüm düzenleme işlevleri gibi sonsuz bir düzenleme başlatmak için start-new veya schedule-new dayanıklı istemci yöntemini kullanın. Aynı anda yalnızca bir örneğin çalıştığından emin olmak için sabit bir örnek kimliği kullanın. Daha fazla bilgi için bkz. Singleton düzenlemeleri.

C#

[FunctionName("Trigger_Eternal_Orchestration")]
public static async Task<HttpResponseMessage> OrchestrationTrigger(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequestMessage request,
    [DurableClient] IDurableOrchestrationClient client)
{
    string instanceId = "StaticId";

    await client.StartNewAsync("Periodic_Cleanup_Loop", instanceId); 
    return client.CreateCheckStatusResponse(request, instanceId);
}

JavaScript

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

module.exports = async function (context, req) {
    const client = df.getClient(context);
    const instanceId = "StaticId";

    // null is used as the input, since there is no input in "Periodic_Cleanup_Loop".
    await client.startNew("Periodic_Cleanup_Loop", instanceId, null);

    context.log(`Started orchestration with ID = '${instanceId}'.`);
    return client.createCheckStatusResponse(context.bindingData.req, instanceId);
};

Python

async def main(req: func.HttpRequest, starter: str) -> func.HttpResponse:
    client = df.DurableOrchestrationClient(starter)
    instance_id = 'StaticId'

    await client.start_new('Periodic_Cleanup_Loop', instance_id, None)

    logging.info(f"Started orchestration with ID = '{instance_id}'.")
    return client.create_check_status_response(req, instance_id)

PowerShell

PowerShell desteklemez continue-as-new. PowerShell'de düzenli çalışmalar için bunun yerine singleton düzenleme ile dayanıklı zamanlayıcı kullanın.

Java

@FunctionName("Trigger_Eternal_Orchestration")
public HttpResponseMessage triggerEternalOrchestration(
        @HttpTrigger(name = "req") HttpRequestMessage<?> req,
        @DurableClientInput(name = "durableContext") DurableClientContext durableContext) {

    String instanceID = "StaticID";
    DurableTaskClient client = durableContext.getClient();
    client.scheduleNewOrchestrationInstance("Periodic_Cleanup_Loop", null, instanceID);
    return durableContext.createCheckStatusResponse(req, instanceID);
}

Diğer tüm düzenlemelerde olduğu gibi sonsuz bir düzenleme başlatmak için schedule-new istemci yöntemini kullanın. Aynı anda yalnızca bir örneğin çalıştığından emin olmak için sabit bir örnek kimliği kullanın. Daha fazla bilgi için bkz. Singleton düzenlemeleri.

C#

string instanceId = "StaticId";
await client.ScheduleNewOrchestrationInstanceAsync(
    "PeriodicCleanupLoop",
    null,
    new StartOrchestrationOptions { InstanceId = instanceId });

Python

instance_id = "StaticId"
client.schedule_new_orchestration(periodic_cleanup_loop, instance_id=instance_id)

Java

String instanceId = "StaticId";
client.scheduleNewOrchestrationInstance("PeriodicCleanupLoop", null, instanceId);

JavaScript

const instanceId = "StaticId";
await client.scheduleNewOrchestration(periodicCleanupLoop, undefined, instanceId);

PowerShell

Dayanıklı Görev SDK'sı PowerShell için kullanılamaz. PowerShell'de sonsuz orkestrasyonlar için Dayanıklı İşlevler ile bir dayanıklı zamanlayıcı ve singleton deseni kullanın.

Sonsuz orkestrasyondan çıkış

Bir düzenleyici işlevinin sonunda tamamlanması gerekiyorsa continue-as-new çağırmayın ve işlevin sonlanmasına izin verin.

Orchestrator işlevi sonsuz bir döngüdeyse ve durdurulması gerekiyorsa, durdurmak için orchestration istemci bağlamasınınsonlandırma API'sini kullanın.

C#

await client.TerminateAsync(instanceId, "Cleanup no longer needed");

JavaScript

await client.terminate(instanceId, "Cleanup no longer needed");

Python

await client.terminate(instance_id, "Cleanup no longer needed")

PowerShell

Stop-DurableOrchestration -InstanceId $instanceId -Reason "Cleanup no longer needed"

Java

client.terminate(instanceId, "Cleanup no longer needed");

Daha fazla bilgi için bkz Örnekyönetimi.

Bir düzenlemenin sonunda tamamlanması gerekiyorsa, continue-as-new çağırmayın ve düzenlemenin çıkışına izin verin.

Düzenleme sonsuz bir döngüdeyse ve durdurulması gerekiyorsa, bunu durdurmak için dayanıklı görev istemcisindeki sonlandırma API'sini kullanın.

C#

await client.TerminateInstanceAsync(instanceId, "Cleanup no longer needed");

Python

client.terminate_orchestration(instance_id, output="Cleanup no longer needed")

Java

client.terminate(instanceId, "Cleanup no longer needed");

JavaScript

await client.terminateOrchestration(instanceId, "Cleanup no longer needed");

PowerShell

Dayanıklı Görev SDK'sı PowerShell için kullanılamaz. PowerShell'de sürekli orkestrasyonlar için Dayanıklı Fonksiyonlar, dayanıklı zamanlayıcı ve bir tekillik deseni kullanın.

Sonraki Adımlar

Singleton orkestrasyonları uygulamayı öğrenin

• Dayanıklı zamanlayıcılar
• Örnek yönetimi
• Dayanıklı İşlevler bağlamaları

Dayanıklı Görev SDK'larını kullanmaya başlama

• Singleton orkestrasyonlar
• Dayanıklı zamanlayıcılar
• Örnek yönetimi