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

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

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

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

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

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

Node.js версии 18 или выше установлен.
Функции 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/javascript/HelloCities
```
Установите зависимости:
```
npm install
```

Убедитесь, что 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
```

Запустите оркестрацию fan-out/fan-in:

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

Оркестрация вентилятора и вентилятора возвращает:

{
  "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.js).

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

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

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

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

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

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

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

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

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

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

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

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

В этом примере в качестве механизма хранения используется эмулятор 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