Быстрый старт: Создание приложения Устойчивые функции на TypeScript

Используйте Устойчивые функции — функцию Функции Azure, чтобы создавать бессерверные рабочие процессы с отслеживанием состояния на TypeScript. В этом кратком руководстве вы клонируете и запускаете пример приложения, в котором демонстрируются два распространенных шаблона оркестрации:

Цепочка функций: вызывает действия последовательно (Токио → Сиэтл → Лондон).
Fan-out/fan-in: Параллельно вызывает активности в пяти городах, а затем агрегирует результаты.

В итоге у вас будут локально запущены обе оркестрации с помощью эмулятора Durable Task Scheduler, и вы сможете просматривать их состояние в панели мониторинга.

Клонируйте и подготовьте пример проекта Hello Cities.
Настройте эмулятор планировщика устойчивых задач и Azurite для локальной разработки.
Запустите приложение-функцию и инициируйте обе оркестрации.
Просмотрите состояние оркестрации и результаты в панели мониторинга Durable Task Scheduler.

Необходимые условия

Node.js 20 или выше установлен.
Функции Azure Core Tools версии 4 или более поздней версии.
Docker для запуска эмулятора и Azurite.
Клонируйте репозиторий Durable Task Scheduler на GitHub для работы с примером начального уровня.

Настройте эмулятор планировщика Durable Task

Эмулятор планировщика задач Durable Task Scheduler предоставляет локальную среду разработки, чтобы можно было протестировать оркестрации без подписки Azure. Узел функций также требует Azurite для локального хранилища.

Запустите оба контейнера:

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

Tip

После запуска эмулятора вы можете получить доступ к панели мониторинга Durable Task Scheduler по адресу http://localhost:8082, чтобы отслеживать оркестрации.

Запустите пример из краткого руководства

Перейдите в пример каталога Hello Cities:
```
cd samples/durable-functions/typescript/HelloCities
```
Установите зависимости и создайте проект:
```
npm install
npm run build
```

Убедитесь, что local.settings.json файл содержит следующую конфигурацию:

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

Запустите приложение-функцию:
```
func start
```
В отдельном терминале запустите оркестрацию последовательного вызова функций:
```
$response = Invoke-RestMethod -Method POST -Uri http://localhost:7071/api/StartChaining
$response
```
Ответ содержит URL-адреса состояния для экземпляра оркестрации. statusQueryGetUri Скопируйте значение и запустите его, чтобы проверить результат:
```
Invoke-RestMethod -Uri $response.statusQueryGetUri
```

Активируйте оркестрацию вентилятора или вентилятора :

$response = Invoke-RestMethod -Method POST -Uri http://localhost:7071/api/StartFanOutFanIn
Invoke-RestMethod -Uri $response.statusQueryGetUri

Ожидаемые выходные данные

Запрос POST возвращает ответ JSON с URL-адресами состояния. Рассмотрим пример.

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

Когда вы запрашиваете statusQueryGetUri и значение runtimeStatus оркестрации — Completed, результаты приветствия можно найти в поле output. Возвращается оркестрация цепочек:

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

Оркестрация fan-out/fan-in возвращает:

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

Tip

Если на runtimeStatus отображается Running или Pending, подождите немного и снова запросите statusQueryGetUri.

Откройте панель мониторинга Durable Task Scheduler по адресу http://localhost:8082, чтобы просмотреть состояние оркестрации и историю выполнения.

Изучение кода

В примере используется модель программирования Node.js версии 4, где все функции определены в одном файле (src/functions/helloCities.ts).

Функция активности

Действие sayHello принимает имя города и возвращает приветствие:

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

Функции оркестратора

Оркестратор цепочек последовательно вызывает sayHello для трех городов:

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);

Оркестратор «fan-out/fan-in» запускает действия параллельно:

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);

Клиентские функции

Клиентские функции, запускаемые по HTTP, запускают каждую оркестрацию. Например, средство запуска цепочки:

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);
  },
});

Конфигурация

В этом примере в качестве механизма хранения используется эмулятор Durable Task Scheduler. Это настроено в 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)"
  }
}

Очистите ресурсы

Остановите контейнеры эмулятора после завершения:

docker stop dtsemulator azurite && docker rm dtsemulator azurite

Дальнейшие действия

Узнайте о общих шаблонах приложений Устойчивые функции.
Узнайте о поставщиках хранилища Устойчивые функции.

Обратная связь

Были ли сведения на этой странице полезными?

Last updated on 2026-06-05