Início Rápido: Criar um aplicativo de Durable Functions em C#

Use Durable Functions, um recurso do Azure Functions, para escrever fluxos de trabalho sem servidor com estado em C#. Neste guia de início rápido, você vai clonar e executar uma aplicação de exemplo que demonstra o padrão de orquestração por encadeamento de funções:

  • Encadeamento de funções: chama as atividades sequencialmente (Tóquio → Seattle → Londres).

Ao final, você terá a orquestração em execução localmente com o emulador do Agendador de Tarefas Duráveis e poderá exibir seu status no painel.

  • Clone e prepare o projeto de exemplo Hello Cities.
  • Configure o emulador do Agendador de Tarefas Duráveis e o Azurite para desenvolvimento local.
  • Crie e execute o aplicativo de funções e dispare a orquestração.
  • Verifique o status e a saída da orquestração no dashboard do Durable Task Scheduler.

Pré-requisitos

Configurar o emulador do Agendador de Tarefas Duráveis

O emulador Durable Task Scheduler fornece um ambiente de desenvolvimento local para que você possa testar orquestrações sem uma assinatura Azure. O host do .NET Functions também requer Azurite para armazenamento local.

Inicie ambos os contêineres:

docker run -d --name dtsemulator -p 8080:8080 -p 8082:8082 \
  mcr.microsoft.com/dts/dts-emulator:latest

docker run -d --name azurite -p 10000:10000 -p 10001:10001 -p 10002:10002 \
  mcr.microsoft.com/azure-storage/azurite

Dica

Depois que o emulador estiver em execução, você poderá acessar o painel http://localhost:8082 do Agendador de Tarefas Duráveis para monitorar orquestrações.

Executar o exemplo de início rápido

  1. Navegue até o diretório de exemplo Hello Cities:

    cd samples/durable-functions/dotnet/HelloCities/http

  2. Crie um local.settings.json arquivo com a configuração do emulador:

    {
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "dotnet-isolated",
    "DURABLE_TASK_SERVICE_CONNECTION_STRING": "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None",
    "TASKHUB_NAME": "default"
  }
}

  3. Compile o projeto:

    dotnet build

  4. Inicie o aplicativo de funções:

    func start

  5. Em um terminal separado, dispare a orquestração:

    $response = Invoke-RestMethod -Method POST -Uri http://localhost:7071/api/DurableFunctionsOrchestrationCSharp1_HttpStart
$response

    A resposta contém URLs de status para a instância de orquestração. Copie o valor statusQueryGetUri e execute-o para verificar o resultado:

    Invoke-RestMethod -Uri $response.statusQueryGetUri

Resultado esperado

A solicitação POST retorna uma resposta JSON com URLs de status. Por exemplo:

{
  "id": "<instanceId>",
  "statusQueryGetUri": "http://localhost:7071/runtime/webhooks/durabletask/instances/<instanceId>?code=...",
  "sendEventPostUri": "...",
  "terminatePostUri": "...",
  "purgeHistoryDeleteUri": "..."
}

Quando você consulta statusQueryGetUri e o runtimeStatus da orquestração é Completed, você pode encontrar os resultados da saudação no campo output:

{
  "name": "DurableFunctionsOrchestrationCSharp1",
  "runtimeStatus": "Completed",
  "output": ["Hello Tokyo!", "Hello Seattle!", "Hello London!"]
}

Dica

Se runtimeStatus mostrar Running ou Pending, aguarde um momento e consulte statusQueryGetUri novamente.

Abra o painel do Agendador de Tarefas Duráveis em http://localhost:8082 para ver o status da orquestração e o histórico de execução.

Entender o código

O projeto de exemplo em DurableFunctionsOrchestrationCSharp1.cs contém todos os três tipos de função necessários para um aplicativo Durable Functions.

Função de atividade

A SayHello atividade usa um nome de cidade e retorna uma saudação:

[Function(nameof(SayHello))]
public static string SayHello([ActivityTrigger] string name, FunctionContext executionContext)
{
    ILogger logger = executionContext.GetLogger("SayHello");
    logger.LogInformation("Saying hello to {name}.", name);
    return $"Hello {name}!";
}

Função de orquestrador

O orquestrador chama SayHello sequencialmente para três cidades:

[Function(nameof(DurableFunctionsOrchestrationCSharp1))]
public static async Task<List<string>> RunOrchestrator(
    [OrchestrationTrigger] TaskOrchestrationContext context)
{
    ILogger logger = context.CreateReplaySafeLogger(nameof(DurableFunctionsOrchestrationCSharp1));
    logger.LogInformation("Saying hello.");
    var outputs = new List<string>();

    outputs.Add(await context.CallActivityAsync<string>(nameof(SayHello), "Tokyo"));
    outputs.Add(await context.CallActivityAsync<string>(nameof(SayHello), "Seattle"));
    outputs.Add(await context.CallActivityAsync<string>(nameof(SayHello), "London"));

    return outputs;
}

Função cliente

Uma função de cliente disparada por HTTP inicia a orquestração:

[Function("DurableFunctionsOrchestrationCSharp1_HttpStart")]
public static async Task<HttpResponseData> HttpStart(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post")] HttpRequestData req,
    [DurableClient] DurableTaskClient client,
    FunctionContext executionContext)
{
    ILogger logger = executionContext.GetLogger("DurableFunctionsOrchestrationCSharp1_HttpStart");
    string instanceId = await client.ScheduleNewOrchestrationInstanceAsync(
        nameof(DurableFunctionsOrchestrationCSharp1));

    logger.LogInformation("Started orchestration with ID = '{instanceId}'.", instanceId);
    return await client.CreateCheckStatusResponseAsync(req, instanceId);
}

Configuration

O exemplo usa o emulador do Agendador de Tarefas Duráveis como seu back-end de armazenamento. Isso está configurado em host.json:

{
  "version": "2.0",
  "extensions": {
    "durableTask": {
      "storageProvider": {
        "type": "azureManaged",
        "connectionStringName": "DURABLE_TASK_SERVICE_CONNECTION_STRING"
      },
      "hubName": "%TASKHUB_NAME%"
    }
  }
}

O cadeia de conexão do emulador e o nome do hub de tarefas são definidos em local.settings.json:

{
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "dotnet-isolated",
    "DURABLE_TASK_SERVICE_CONNECTION_STRING": "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None",
    "TASKHUB_NAME": "default"
  }
}

Limpar os recursos

Interrompa os contêineres do emulador quando terminar:

docker stop dtsemulator azurite && docker rm dtsemulator azurite

Próximas Etapas 

  • Last updated on