durable-functions package

context.df.Task.all（） 失败时引发的特定错误。 其消息包含失败的所有异常的聚合。 它应采用以下格式：

context.df.Task.all（） 遇到以下错误消息：

名称：DurableError 消息：活动函数“ActivityA”失败。 StackTrace： <堆栈跟踪>

名称：DurableError 消息：活动函数“ActivityB”失败。 StackTrace： <堆栈跟踪>

具有虚拟默认值的实体上下文，用于促进模拟/扩展 Durable Functions API。

具有虚拟默认值的业务流程上下文，以方便模拟/删除 Durable Functions API。

用于启动、查询、终止和引发事件到业务流程和实体实例的客户端。

计划活动或子序表失败时引发的规范错误。 可以通过 instanceof 防护检查此错误，以仅捕获 DurableJS 库引发的异常。

提供实现业务流程作的应用程序代码的功能。

表示持久业务流程实例的状态。

可以使用 DurableClient.getStatus() 提取

实体的唯一标识符，由实体类和实体键组成。

DurableClient.readEntityState 返回的响应。

包含实例管理 HTTP 终结点的数据结构。

Azure 托管标识的令牌源实现。

示例

通过调用 Azure 资源管理器 HTTP API 获取 Azure 订阅的列表。

const df = require("durable-functions");

df.app.orchestration(function* (context) {
  return yield context.df.callHttp({
      method: "GET",
      url: "https://management.azure.com/subscriptions?api-version=2019-06-01",
      tokenSource: df.ManagedIdentityTokenSource("https://management.core.windows.net"),
  });
});

用于保存有关此清除历史记录执行的统计信息的类。 DurableClient.purgeHistory（） 的返回类型

定义可作为参数传递给各种作的重试策略。

提供给业务流程上下文 callHttp() 方法的选项对象

为 Durable Client 函数配置输入、输出和处理程序。

提供实现实体作的应用程序代码的功能。

传递给实体函数的上下文对象。

传递给客户端 getStatus() 方法的选项对象

配置 HTTP 触发的 Durable Client 函数的选项。

传递给业务流程函数的上下文对象。

传递给 DurableClient API 的选项对象，用于筛选要对其执行作的业务流程

Durable Functions 任务。

Durable Functions 任务。

选项对象作为 client.startNew() 方法的可选第二个参数提供

Durable Functions 任务。

传递给 DurableClient API 以指定任务中心属性的选项对象

为计时器触发的 Durable Client 函数配置选项。

从 durableClient 返回。如果调用未 createTimer(Date)-ed，yield。 表示挂起的计时器。 有关详细信息，请参阅有关 任务 的文档。

必须完成或取消所有挂起的计时器，以便业务流程完成。

示例

取消计时器

// calculate expiration date
const timeoutTask = context.df.createTimer(expirationDate);

// do some work

if (!timeoutTask.isCompleted) {
    // An orchestration won't get marked as completed until all its scheduled
    // tasks have returned, or been cancelled. Therefore, it is important
    // to cancel timers when they're no longer needed
    timeoutTask.cancel();
}

示例

创建超时

const now = Date.now();
const expiration = new Date(now.valueOf()).setMinutes(now.getMinutes() + 30);

const timeoutTask = context.df.createTimer(expirationDate);
const otherTask = context.df.callActivity("DoWork");

const winner = yield context.df.Task.any([timeoutTask, otherTask]);

if (winner === otherTask) {
    // do some more work
}

if (!timeoutTask.isCompleted) {
    // An orchestration won't get marked as completed until all its scheduled
    // tasks have returned, or been cancelled. Therefore, it is important
    // to cancel timers when they're no longer needed
    timeoutTask.cancel();
}

传递给 durableClient.waitForCompletionOrCreateCheckStatusResponse() 方法的选项对象指定等待持久函数输出的超时时间，以及检查输出的频率。

由某些触发器触发并接收 DurableClient 实例作为输入的处理程序函数的类型。

可注册为业务流程的生成器的类型

业务流程实例的状态。

返回 OrchestrationClient 实例。