Übersicht über Durable Functions im isolierten .NET-Worker

Dieser Artikel bietet eine Übersicht über Durable Functions im isolierten .NET-Worker. Der isolierte Worker ermöglicht die Ausführung einer Durable Functions-App auf einer anderen .NET-Version als der des Azure Functions-Hosts.

Was spricht für die Verwendung von Durable Functions im isolierten .NET-Worker?

Mit diesem Modell können Sie alle Vorteile nutzen, die der isolierte .NET-Workerprozess von Azure Functions bietet. Weitere Informationen finden Sie unter Vorteile des isolierten Workermodells. Darüber hinaus enthält dieses neue SDK einige neue Features.

Featureverbesserungen gegenüber prozessinternen Durable Functions

• Orchestrierungseingaben können direkt eingefügt werden: MyOrchestration([OrchestrationTrigger] TaskOrchestrationContext context, T input)
• Unterstützung stark typisierter Aufrufe und klassenbasierter Aktivitäten und Orchestrierungen (HINWEIS: in der Vorschauversion. Weitere Informationen finden Sie hier.)
• Plus alle Vorteile des isolierten .NET-Workers von Azure Functions.

Quellgenerator und klassenbasierte Aktivitäten und Orchestrierungen

Anforderung: Fügen Sie Ihrem Projekt <PackageReference Include="Microsoft.DurableTask.Generators" Version="1.0.0-preview.1" /> hinzu.

Durch Hinzufügen des Quellgeneratorpakets erhalten Sie Zugriff auf zwei neue Features:

• Klassenbasierte Aktivitäten und Orchestrierungen, eine alternative Methode zum Schreiben von Durable Functions. Statt „funktionsbasiertem“ Code schreiben Sie stark typisierte Klassen, die Typen vom Durable SDK erben.
• Stark typisierte Erweiterungsmethoden zum Aufrufen von untergeordneten Orchestrierungen und Aktivitäten. Diese Erweiterungsmethoden können auch von „funktionsbasierten“ Aktivitäten und Orchestrierungen verwendet werden.

Funktionsbasiertes Beispiel

public static class MyFunctions
{
    [Function(nameof(MyActivity))] 
    public static async Task<string> MyActivity([ActivityTrigger] string input)
    {
        // implementation
    }

    [Function(nameof(MyOrchestration))] 
    public static async Task<string> MyOrchestration([OrchestrationTrigger] TaskOrchestrationContext context, string input)
    {
        // implementation
        return await context.CallActivityAsync(nameof(MyActivity), input);
    }
}

Klassenbasiertes Beispiel

[DurableTask(nameof(MyActivity))]
public class MyActivity : TaskActivity<string, string>
{
    private readonly ILogger logger;

    public MyActivity(ILogger<MyActivity> logger) // activities have access to DI.
    {
        this.logger = logger;
    }

    public async override Task<string> RunAsync(TaskActivityContext context, string input)
    {
        // implementation
    }
}

[DurableTask(nameof(MyOrchestration))]
public class MyOrchestration : TaskOrchestrator<string, string>
{
    public async override Task<string> RunAsync(TaskOrchestrationContext context, string input)
    {
        ILogger logger = context.CreateReplaySafeLogger<MyOrchestration>(); // orchestrations do NOT have access to DI.

        // An extension method was generated for directly invoking "MyActivity".
        return await context.CallMyActivityAsync(input);
    }
}

Dauerhafte Entitäten

Dauerhafte Entitäten werden in isolierten .NET-Workerprozessen unterstützt. Weitere Informationen finden Sie im Entwicklerhandbuch.

Migrationsleitfaden

Bei diesem Prozess wird davon ausgegangen, dass Sie mit einem .NET Durable Functions 2.x-Projekt beginnen, das im Prozess mit dem Functions-Host ausgeführt wird.

Migrieren Ihres Projekts

Der erste Schritt besteht darin, Ihr .NET-Projekt in den isolierten Arbeitsprozess zu migrieren.

Referenz zu Paketen aktualisieren

Nachdem Sie Ihre App migriert haben, um den Isolierarbeitsprozess zu verwenden, müssen Sie das NuGet-Paket „Durable Functions NuGet“ aktualisieren, um auf das isolierte workerspezifische Paket zu verweisen, wie in diesem Beispiel:

Alt:

<ItemGroup>
  <PackageReference Include="Microsoft.Azure.WebJobs.Extensions.DurableTask" Version="2.9.0" />
</ItemGroup>

Neu:

<ItemGroup>
  <PackageReference Include="Microsoft.Azure.Functions.Worker.Extensions.DurableTask" Version="1.1.0" />
</ItemGroup>

Aktualisieren Ihres Codes

Durable Functions für isolierten .NET-Worker ist ein völlig neues Paket mit unterschiedlichen Typen und Namespaces. Infolgedessen sind Änderungen am Code erforderlich, aber viele der APIs lassen sich ohne Änderungen verwenden.

Host.json-Schema

Das Schema für Durable Functions für isolierten .NET-Worker und Durable Functions 2.x ist unverändert, es sollten keine Änderungen erforderlich sein.

Öffentliche API-Änderungen

Diese Tabelle enthält keine vollständige Liste der Änderungen.

2.x	Isoliert
IDurableOrchestrationClient	DurableTaskClient
IDurableOrchestrationClient.StartNewAsync	DurableTaskClient.ScheduleNewOrchestrationInstanceAsync
IDurableEntityClient.SignalEntityAsync	DurableTaskClient.Entities.SignalEntityAsync
IDurableEntityClient.ReadEntityStateAsync	DurableTaskClient.Entities.GetEntityAsync
IDurableEntityClient.ListEntitiesAsync	DurableTaskClient.Entities.GetAllEntitiesAsync
IDurableEntityClient.CleanEntityStorageAsync	DurableTaskClient.Entities.CleanEntityStorageAsync
IDurableOrchestrationContext	TaskOrchestrationContext
IDurableOrchestrationContext.GetInput<T>()	TaskOrchestrationContext.GetInput<T>() oder Eingabe als Parameter einfügen: MyOrchestration([OrchestrationTrigger] TaskOrchestrationContext context, T input)
DurableActivityContext	Keine Entsprechung
DurableActivityContext.GetInput<T>()	Einfügen der Eingabe als Parameter MyActivity([ActivityTrigger] T input)
IDurableOrchestrationContext.CallActivityWithRetryAsync	TaskOrchestrationContext.CallActivityAsync, den Parameter TaskOptions mit Wiederholungsdetails einschließen.
IDurableOrchestrationContext.CallSubOrchestratorWithRetryAsync	TaskOrchestrationContext.CallSubOrchestratorAsync, den Parameter TaskOptions mit Wiederholungsdetails einschließen.
IDurableOrchestrationContext.CallHttpAsync	TaskOrchestrationContext.CallHttpAsync
IDurableOrchestrationContext.CreateReplaySafeLogger(ILogger)	TaskOrchestrationContext.CreateReplaySafeLogger<T>() oder TaskOrchestrationContext.CreateReplaySafeLogger(string)
IDurableOrchestrationContext.CallEntityAsync	TaskOrchestrationContext.Entities.CallEntityAsync
IDurableOrchestrationContext.SignalEntity	TaskOrchestrationContext.Entities.SignalEntityAsync
IDurableOrchestrationContext.LockAsync	TaskOrchestrationContext.Entities.LockEntitiesAsync
IDurableOrchestrationContext.IsLocked	TaskOrchestrationContext.Entities.InCriticalSection
IDurableEntityContext	TaskEntityContext.
IDurableEntityContext.EntityName	TaskEntityContext.Id.Name
IDurableEntityContext.EntityKey	TaskEntityContext.Id.Key
IDurableEntityContext.OperationName	TaskEntityOperation.Name
IDurableEntityContext.FunctionBindingContext	Entfernt, fügen Sie FunctionContext als Eingabeparameter hinzu
IDurableEntityContext.HasState	TaskEntityOperation.State.HasState
IDurableEntityContext.BatchSize	Entfernt
IDurableEntityContext.BatchPosition	Entfernt
IDurableEntityContext.GetState	TaskEntityOperation.State.GetState
IDurableEntityContext.SetState	TaskEntityOperation.State.SetState
IDurableEntityContext.DeleteState	TaskEntityOperation.State.SetState(null)
IDurableEntityContext.GetInput	TaskEntityOperation.GetInput
IDurableEntityContext.Return	Entfernt. Stattdessen wird der Rückgabewert der Methode verwendet.
IDurableEntityContext.SignalEntity	TaskEntityContext.SignalEntity
IDurableEntityContext.StartNewOrchestration	TaskEntityContext.ScheduleNewOrchestration
IDurableEntityContext.DispatchAsync	TaskEntityDispatcher.DispatchAsync. Konstruktorparameter entfernt.
IDurableOrchestrationClient.GetStatusAsync	DurableTaskClient.GetInstanceAsync

Verhaltensänderungen

• Das Standardverhalten der Serialisierung hat sich von Newtonsoft.Json in System.Text.Jsongeändert. Weitere Informationen finden Sie hier.