异步调用

应用场景

异步调用适用的场景示例如下：

• 音视频处理

  用户使用函数计算处理音视频业务时，涉及处理编码、解码或转码等耗时较长的任务，异步调用这些任务使其在后台运行，前端无需等待，提升用户体验。另外，如果音视频项目较大，需要将其分割成多个任务并行处理或者需要将一个视频转换为多种格式，异步调用多个函数可以轻松实现以上并行处理需求，缩短任务处理时间。

• 数据ETL处理

  ETL流程中，从源头提取数据、转换处理和加载到目标系统这三个步骤可能涉及多个独立的操作，例如数据库查询、文件读写或数据清洗等，采用异步调用可以让这些操作并行执行，减少处理时间，提升系统性能。而针对耗时较长的任务，例如处理大规模数据集或复杂的数据转换，异步调用允许这些任务在后台运行，前端无需等待，提升用户体验。

• 开发Web应用

  函数计算可以搭配其他云产品快速构建Web应用。用户在表单提交、搜索查询或加载内容较多的情况下，采用异步调用可以避免页面因长时间等待后端响应而出现的卡顿现象，此时用户可以继续与页面的其他部分交互，而不会感受到延迟。高并发场景下，例如大量用户同时访问，异步调用函数又可以分散请求压力，防止服务过载。

延迟调用

针对某些场景，您提交一次异步调用后，需要函数计算对其进行延迟触发。您可以通过调用API（SDK）实现延迟调用函数。

在代码中添加HTTP请求头x-fc-async-delay，取值范围为(0,3600)，单位为秒。函数计算将从您触发执行开始计算，延迟x-fc-async-delay设置的时间后触发函数调用。

重试策略

异步调用机制提供错误处理和重试机制，如果某个步骤失败，可以重新调度该任务而不影响整个流程。当函数异步调用执行失败后，函数计算会自动进行错误重试。

重试机制

对于常见错误，系统默认的重试策略如下表所示。

配置重试策略

函数计算支持自定义重试次数和消息最大存活时长。

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

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

3. 在函数详情页面，选择配置页签，然后在左侧导航栏，选择异步配置，在异步配置区域，单击编辑。

4. 在异步配置面板，设置以下配置项，然后单击部署。

   配置项	解释说明
   任务模式	是否开启异步任务模式，请参见异步任务。
   最大重试次数	用于配置异步调用流程中的消息最大重试次数，取值范围为[0,8]。 函数计算在默认情况下，对异步触发失败的消息进行3次重试，您可以根据业务需求减少或增加对异步调用的重试。
   消息最大存活时长	用于配置异步调用流程中的消息最大存活时长，取值范围[1,604800]，默认为86400，单位为秒。 该时长从触发异步调用时开始计算，如果超过配置的消息最大存活时长，该条消息将被丢弃。未被消费的消息将计入云监控异步调用触发事件（次）指标。关于指标详情，请参见监控指标。

结果回调

函数计算接收异步调用请求后，将请求持久化后会立即返回响应，无需等待请求执行完成。如您需要保留执行失败且超过最大重试次数被丢弃的请求，或通知下游异步调用结果，可以通过配置结果回调功能实现。配置异步目标服务后，异步调用请求执行完成，函数计算根据执行结果自动回调对应的服务。

功能原理

结果回调流程如下图所示。

适用场景

• 保存丢弃的事件供后续使用

  当异步请求执行失败，并且按照指定的策略重试后仍然失败，函数计算将丢弃该请求。如果您配置了失败目标，函数计算将自动把失败请求的上下文信息推送到消息队列 RocketMQ 版等消息服务中，以便后续处理。您也可以将目标服务设置为另一个函数，函数计算将自动把失败请求的上下文信息推送到该函数，执行您自定义的错误处理逻辑。

• 自动通知下游服务执行结果

  请求执行成功后，如果您配置了成功目标，函数计算系统会自动将成功请求的上下文信息推送到下游目标服务。例如，您配置了使用函数计算实现自动解压上传到OSS的ZIP文件，解压完成后想要接收消息通知，可采用为目标函数配置异步调用结果回调目标服务。

支持的异步调用目标服务

异步调用目标服务的配置说明如下：

• 异步调用目标的事件内容

  消息服务 MNS、函数计算或消息队列 RocketMQ 版作为函数异步调用目标时，事件内容示例如下。

  {
    "timestamp": 1660120276975,
    "requestContext": {
      "requestId": "xxx",
      "functionArn": "acs:fc:{regionid}:{accountid}:functions/xxxx",
         "condition": "FunctionResourceExhausted", 
          "approximateInvokeCount": 3
    },
    "requestPayload": "",
    "responseContext": {
      "statusCode": 200,
      "functionError": ""
    },
    "responsePayload": ""
  }

  表 1. 参数说明

  参数	说明
  timestamp	调用时间戳。
  requestContext	请求上下文。
  requestContext.requestId	异步调用的请求ID。
  requestContext.functionArn	异步执行的函数ARN。
  requestContext.condition	调用错误码。
  requestContext.approximateInvokeCount	异步调用的执行次数。当该值大于1时，说明函数计算对您的函数进行了重试。
  requestPayload	请求函数的原始负载。
  responseContext	返回上下文。
  responseContext.statusCode	调用函数的返回码（系统）。当该返回码不为200时，说明出现了系统错误。
  responseContext.functionError	调用错误信息。
  responsePayload	执行函数返回的原始负载。

  事件总线 EventBridge作为函数异步调用目标时，事件示例如下。具体信息，请参见事件概述。

  {
      "datacontenttype": "application/json",
      "aliyunaccountid": "143xxxx",
      "data": {
          "requestContext": {
              "condition": "",
              "approximateInvokeCount": 1,
              "requestId": "0fcb7f0c-xxxx",
              "functionArn": "acs:fc:{regionid}:{accountid}:functions/xxxx"
          },
          "requestPayload": "",
          "responsePayload": "",
          "responseContext": {
              "functionError": "",
              "statusCode": 200
          },
          "timestamp": 1660120276975
      },
      "subject": "acs:fc:{regionid}:{accountid}:functions/xxxx",
      "source": "acs:fc",
      "type": "fc:AsyncInvoke:succeeded",
      "aliyunpublishtime": "2021-01-03T09:44:31.233Asia/Shanghai",
      "specversion": "1.0",
      "aliyuneventbusname": "xxxxxxx",
      "id": "ecc4865xxxxxx",
      "time": "2021-01-03T01:44:31Z",
      "aliyunregionid": "cn-shanghai-vpc",
      "aliyunpublishaddr": "199.99.xxx.xxx"
  }

• 负载限制

  支持的异步调用目标服务负载的最大限制如下：

  • 消息服务 MNS：64 KB

  • 函数计算：128 KB

  • 事件总线 EventBridge：64 KB

  • 消息队列 RocketMQ 版：4 MB

• 避免循环调用

  当您在配置异步执行目标时，请确保不要出现循环调用的情况。例如，您为函数A配置了成功调用时的异步目标为函数B，为函数B配置了成功调用时的异步目标为函数A。当您异步触发函数A并且执行成功后，则可能出现A到B，再到A的循环调用的情况。

常见问题

如何触发函数的异步调用？

您可以通过以下方式对函数计算的函数发起一次异步调用。

• 登录函数计算控制台，找到目标函数，然后在测试页签，勾选我想通过异步的方式进行调用。

  

• 调用InvokeFunction - 调用函数接口，设置参数x-fc-invocation-type的值为Async。

• 使用Serverless Devs工具配置异步调用，设置参数invocation-type的值为Async，详情请参见调用函数。

• 创建支持异步调用的触发器异步触发函数，详情请参见事件触发。

后续操作

如果您希望获得函数异步请求各个阶段的状态，可通过开启任务模式来实现，具体信息，请参见异步任务。