Início Rápido: Criar um aplicativo de Funções Duráveis em TypeScript

Use Durable Functions, um recurso do Azure Functions, para criar fluxos de trabalho sem servidor com estado em TypeScript. 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.

Pré-requisitos

• Node.js 20+ 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

Executar o exemplo de início rápido

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

   cd samples/durable-functions/typescript/HelloCities
   

2. Instale dependências e crie o projeto:

   npm install
   npm run build
   

3. 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"
     }
   }
   

4. Inicie o aplicativo de funções:

   func start
   

5. 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
   

6. 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!"]
}

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.ts).

Função de atividade

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

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

Funções de orquestrador

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

const chainingOrchestrator: OrchestrationHandler = function* (
  context: OrchestrationContext
) {
  const outputs: string[] = [];
  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;
};
df.app.orchestration("chainingOrchestration", chainingOrchestrator);

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

const fanOutFanInOrchestrator: OrchestrationHandler = function* (
  context: OrchestrationContext
) {
  const cities: string[] = ["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: string[] = yield context.df.Task.all(tasks);
  return results;
};
df.app.orchestration("fanOutFanInOrchestration", fanOutFanInOrchestrator);

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: HttpRequest,
    context: InvocationContext
  ): Promise<HttpResponse> => {
    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 os provedores de armazenamento do Durable Functions.