异步任务

使用限制

• 场景限制

  异步任务虽然功能更丰富，但相应的系统开销更大。以下场景建议您关闭任务模式：

  • 您对请求处理链路延时非常敏感，需要平均延时在百毫秒以下。

  • 您需要每秒数千甚至更高的速率发起异步调用。

• 地域限制

  异步任务支持华东1（杭州）、华东2（上海）、华北1（青岛）、华北2（北京）、华北3（张家口）、华北6（乌兰察布）、华南1（深圳）、西南1（成都）、中国香港、新加坡、英国（伦敦）、美国（硅谷）、美国（弗吉尼亚）、德国（法兰克福）、马来西亚（吉隆坡）、印度尼西亚（雅加达）、泰国（曼谷）、日本（东京）和韩国（首尔）地域。

• 时效限制

  仅支持查询7天内的任务状态信息。

异步任务与Jobs功能对比

如果您需要执行异步任务，您可以使用函数计算异步任务功能，也可以使用Kubernetes的Jobs功能来实现。函数计算异步任务提供开箱即用的更高效、更可控并且更易于观测的异步任务执行平台。以下是详细功能对比。

任务管理

异步任务的状态

针对每一次任务调用，函数计算均会记录任务的状态变更过程，并提供实时的状态查询能力。您可以通过SDK或函数计算控制台查看任务的具体状态。目前任务有如下几种状态：

您可以调用GetAsyncTask - 获取异步任务接口获取某次任务执行的详细信息，也可以调用ListAsyncTasks - 获取异步任务列表接口过滤指定状态的任务。

管理任务

{
  "asyncTask": true
}

事件触发

您可以通过创建支持异步调用的触发器来触发异步任务，支持异步调用的触发器列表如下。

• HTTP触发器

• 定时触发器

• OSS触发器

• MNS主题触发器

• 通过事件总线EventBridge实现的触发器，包括以下几种：

  • 轻量消息队列（原 MNS）队列触发器

  • RocketMQ触发器

  • RabbitMQ触发器

  • Kafka触发器

  • MQTT触发器

  • DTS触发器

  重要

  请确保HTTP和通过事件总线EventBridge实现的触发器的调用方式为异步调用。

任务防重复提交

为了避免任务重复执行，函数计算支持为每次提交的任务设定全局唯一的ID，当异步接口提交失败时，例如异步调用提交任务接口超时，您可以通过提交相同ID的任务进行重试。关于重试方式的介绍，请参见重试策略。

函数计算提供TaskID这一任务概念，该ID全局唯一。建议您在每次提交任务时指定该ID，并在出现超时等情况下进行重试。函数计算会对您重复提交的任务进行校验，当有相同ID进入系统时，该次请求将认为是重复提交而被拒绝，并返回错误409。

设置TaskID

您可以在函数计算控制台、使用Serverless Devs或调用API提交一次任务执行。如果需要设置TaskID，请在触发函数执行时设置参数x-fc-async-task-id。

触发任务执行时设置TaskID的示例代码请参见示例代码。

任务监控

您可以使用函数计算提供的任务监控指标实时获取异步任务的状态、及时发现错误和超时等异常信息。

前提条件

已创建函数，详情请参见创建函数。

操作步骤

1. 登录函数计算控制台，在左侧导航栏，单击函数。

2. 在顶部菜单栏，选择地域，然后在函数页面，单击目标函数。

   在目标函数的详情页面，选择监控页签，查看异步调用相关指标和异步任务实例级别的资源使用情况。关于监控指标的详细介绍，请参见监控指标。

   • 单击函数指标页签，查看异步调用相关指标信息，如下图所示。

     

   • 单击实例指标页签，查看异步任务实例级别的资源使用情况，如下图所示。

     说明

     开通实例级别指标前，需先开通日志功能。具体操作，请参见配置日志。

     

3. 为指标设定告警规则。

   如果您想监控某个指标，如内存使用情况、vCPU使用情况等，可以单击指标右上角的，跳转到创建指标告警规则面板，根据界面提示设置告警条件和阈值，然后单击确定。

   关于告警规则的设置，请参见下图。下图中参数设置值表示当函数异步调用积压数大于等于5条时，将全天候通过钉钉、邮件、电话和Webhook的方式上报中级告警到联系人。

   

任务编排

结合云工作流，函数的异步调用可以应用于大规模复杂场景的任务流程。您可以使用顺序、分支和并行等方式来编排函数计算异步任务，云工作流会按照设定好的步骤可靠地协调任务执行，跟踪每个任务的状态转换，并在必要时执行您定义的重试逻辑，以确保任务顺利完成。更多信息，请参见集成函数计算。

前提条件

• 创建异步任务。具体操作，请参见任务管理。

• 授予函数计算访问Serverless 工作流的权限。具体操作，请参见授予函数计算访问其他云服务的权限。

操作步骤

1. 登录云工作流控制台，然后在顶部菜单栏，选择地域。

2. 在左侧导航栏，选择工作流列表，然后在工作流列表页面，单击创建工作流。

3. 在创建工作流对话框，选择创建工作流的方式，然后选择要创建的工作流的模式。

   云工作流支持创建标准和快速两种模式的工作流，关于两种模式的更多信息，请参见标准工作流和快速工作流。更多操作，请参见基于空白画布创建工作流。

4. 编辑上一步创建的工作流。

   1. 编辑流程。

      您可以选择CloudFlow Studio编辑或YAML编辑两种方式，本文以YAML编辑方式为例进行介绍。

      在流程详情页面右上角，单击YAML，在左侧代码编辑框内输入流程定义语言，然后单击保存。

      示例如下。

      Type: StateMachine
      Name: MyFlow
      SpecVersion: v1
      StartAt: InvokeFunction
      States:
        - Type: Task
          Name: InvokeFunction
          Action: FC:InvokeFunction
          TaskMode: RequestComplete
          Parameters:
            invocationType: Async
            resourceArn: acs:fc:us-west-1:103435468****:functions/func-i1****/LATEST
          End: true

   2. 配置流程角色。

      在流程详情页面右上角，单击工作流配置，选择执行角色，然后单击保存。

      说明

      请确保为流程配置的角色已被授予AliyunFCInvocationAccess权限策略。

5. 在流程详情页面，您可以单击右上角的执行触发工作流任务进行测试。