Udostępnij za pośrednictwem


Subaranżacje w usłudze Durable Functions (Azure Functions)

Oprócz wywoływania funkcji działania funkcje orkiestratora mogą wywoływać inne funkcje orkiestratora. Na przykład można utworzyć większą aranżację z biblioteki mniejszych funkcji orkiestratora. Możesz też uruchomić wiele wystąpień funkcji orkiestratora równolegle.

Funkcja orkiestratora może wywoływać inną funkcję orkiestratora przy użyciu interfejsu API "call-sub-orchestrator". Artykuł Obsługa błędów i rekompensata zawiera więcej informacji na temat automatycznego ponawiania prób.

Funkcje podrzędne orkiestratora zachowują się tak samo jak funkcje działania z perspektywy obiektu wywołującego. Mogą zwracać wartość, zgłaszać wyjątek i mogą być oczekiwane przez funkcję nadrzędnego koordynatora.

Uwaga

Orkiestracje podrzędne nie są jeszcze obsługiwane w programie PowerShell.

Uwaga

Wersja 4 modelu programowania Node.js dla usługi Azure Functions jest ogólnie dostępna. Nowy model w wersji 4 został zaprojektowany z myślą o bardziej elastycznym i intuicyjnym środowisku dla deweloperów języków JavaScript i TypeScript. Dowiedz się więcej o różnicach między wersjami 3 i v4 w przewodniku migracji.

W poniższych fragmentach kodu javaScript (PM4) oznacza model programowania W wersji 4, nowe środowisko.

Przykład

Poniższy przykład ilustruje scenariusz IoT ("Internet rzeczy"), w którym należy aprowizować wiele urządzeń. Następująca funkcja reprezentuje przepływ pracy aprowizacji, który należy wykonać dla każdego urządzenia:

public static async Task DeviceProvisioningOrchestration(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    string deviceId = context.GetInput<string>();

    // Step 1: Create an installation package in blob storage and return a SAS URL.
    Uri sasUrl = await context.CallActivityAsync<Uri>("CreateInstallationPackage", deviceId);

    // Step 2: Notify the device that the installation package is ready.
    await context.CallActivityAsync("SendPackageUrlToDevice", Tuple.Create(deviceId, sasUrl));

    // Step 3: Wait for the device to acknowledge that it has downloaded the new package.
    await context.WaitForExternalEvent<bool>("DownloadCompletedAck");

    // Step 4: ...
}

Ta funkcja orkiestratora może być używana jako jednorazowa aprowizacja urządzeń lub może być częścią większej aranżacji. W tym drugim przypadku funkcja nadrzędnego orkiestratora może planować wystąpienia DeviceProvisioningOrchestration przy użyciu interfejsu API "call-sub-orchestrator".

Oto przykład pokazujący sposób równoległego uruchamiania wielu funkcji orkiestratora.

[FunctionName("ProvisionNewDevices")]
public static async Task ProvisionNewDevices(
    [OrchestrationTrigger] IDurableOrchestrationContext context)
{
    string[] deviceIds = await context.CallActivityAsync<string[]>("GetNewDeviceIds");

    // Run multiple device provisioning flows in parallel
    var provisioningTasks = new List<Task>();
    foreach (string deviceId in deviceIds)
    {
        Task provisionTask = context.CallSubOrchestratorAsync("DeviceProvisioningOrchestration", deviceId);
        provisioningTasks.Add(provisionTask);
    }

    await Task.WhenAll(provisioningTasks);

    // ...
}

Uwaga

Poprzednie przykłady języka C# dotyczą rozszerzenia Durable Functions 2.x. W przypadku rozszerzenia Durable Functions 1.x należy użyć funkcji DurableOrchestrationContext IDurableOrchestrationContextzamiast . Aby uzyskać więcej informacji na temat różnic między wersjami, zobacz artykuł Wersje rozszerzenia Durable Functions.

Uwaga

Orkiestracje podrzędne muszą być zdefiniowane w tej samej aplikacji funkcji co orkiestracja nadrzędna. Jeśli musisz wywołać orkiestracje i poczekać na aranżacje w innej aplikacji funkcji, rozważ użycie wbudowanej obsługi interfejsów API HTTP i wzorca użytkownika sondowania HTTP 202. Aby uzyskać więcej informacji, zobacz temat Funkcje HTTP.

Następne kroki