Guia de Início Rápido: Criar um aplicativo JavaScript com Durable Functions

Use Durable Functions, um recurso do Azure Functions, para criar fluxos de trabalho sem servidor e com estado em JavaScript. Neste início rápido, você clona e executa um aplicativo de exemplo que demonstra dois padrões comuns de orquestração:

Encadeamento de funções: chama as atividades sequencialmente (Tóquio → Seattle → Londres).
Fan-out/fan-in: chama atividades em paralelo em cinco cidades e agrega os resultados.

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

Faça o clone e prepare o projeto de exemplo Hello Cities.
Configure o emulador do Agendador de Tarefas Duráveis e o Azurite para desenvolvimento local.
Execute o aplicativo de função e acione ambas as orquestrações.
Examine o status e a saída da orquestração no painel do Agendador de Tarefas Duráveis.

Pré-requisitos

Node.js 18+ instalado.
Azure Functions Core Tools v4 ou posterior.
Docker para executar o emulador e o Azurite.
Clone o repositório Durable Task Scheduler GitHub para usar o exemplo de início rápido.

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 Functions também requer o 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

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

cd samples/durable-functions/javascript/HelloCities

Instalar dependências:
```
npm install
```

Verifique se o local.settings.json arquivo contém a seguinte configuração:

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "node",
    "DURABLE_TASK_SCHEDULER_CONNECTION_STRING": "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None"
  }
}

Inicie o aplicativo de funções:
```
func start
```
Em um terminal separado, dispare a orquestração de encadeamento de funções :
```
$response = Invoke-RestMethod -Method POST -Uri http://localhost:7071/api/StartChaining
$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
```

Acione a orquestração fan-out/fan-in:

$response = Invoke-RestMethod -Method POST -Uri http://localhost:7071/api/StartFanOutFanIn
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. A orquestração de encadeamento retorna:

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

A orquestração fan-out/fan-in retorna:

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

Dica

Se runtimeStatus mostrar Running ou Pending, aguarde um momento e verifique 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 exemplo usa o modelo de programação Node.js v4, em que todas as funções são definidas em um único arquivo (src/functions/helloCities.js).

Função de atividade

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

df.app.activity("sayHello", {
  handler: (city) => {
    return `Hello ${city}!`;
  },
});

Funções de orquestrador

O orquestrador de encadeamento chama sayHello sequencialmente para três cidades:

df.app.orchestration("chainingOrchestration", function* (context) {
  const outputs = [];
  outputs.push(yield context.df.callActivity("sayHello", "Tokyo"));
  outputs.push(yield context.df.callActivity("sayHello", "Seattle"));
  outputs.push(yield context.df.callActivity("sayHello", "London"));
  return outputs;
});

O orquestrador fan-out/fan-in programa as atividades em paralelo:

df.app.orchestration("fanOutFanInOrchestration", function* (context) {
  const cities = ["Tokyo", "Seattle", "London", "Paris", "Berlin"];

  // Fan-out: schedule all activities in parallel
  const tasks = cities.map((city) => context.df.callActivity("sayHello", city));

  // Fan-in: wait for all to complete
  const results = yield context.df.Task.all(tasks);
  return results;
});

Funções do cliente

As funções de cliente disparadas por HTTP iniciam cada orquestração. Por exemplo, o iniciador do encadeamento:

app.http("StartChaining", {
  route: "StartChaining",
  methods: ["POST"],
  authLevel: "anonymous",
  extraInputs: [df.input.durableClient()],
  handler: async (request, context) => {
    const client = df.getClient(context);
    const instanceId = await client.startNew("chainingOrchestration");
    context.log(`Started chaining orchestration with ID = '${instanceId}'.`);
    return client.createCheckStatusResponse(request, 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",
  "logging": {
    "logLevel": {
      "DurableTask.Core": "Warning"
    }
  },
  "extensions": {
    "durableTask": {
      "hubName": "default",
      "storageProvider": {
        "type": "azureManaged",
        "connectionStringName": "DURABLE_TASK_SCHEDULER_CONNECTION_STRING"
      }
    }
  },
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[4.*, 5.0.0)"
  }
}

Limpar os recursos

Interrompa os contêineres do emulador quando terminar:

docker stop dtsemulator azurite && docker rm dtsemulator azurite

Próximas Etapas

Saiba mais sobre os padrões comuns de aplicativos do Durable Functions.
Saiba mais sobre provedores de armazenamento do Durable Functions.

Comentários

Esta página foi útil?

Last updated on 2026-06-05