Function Compute:Asynchronous invocation

Casos de uso

A continuación se muestran algunos ejemplos de casos de uso para la invocación asíncrona:

• Procesamiento de audio y video

  Cuando utiliza Function Compute para cargas de trabajo de audio y video, es común ejecutar tareas que consumen mucho tiempo, como la codificación, decodificación y transcodificación. Al invocar estas tareas de forma asíncrona, se ejecutan en segundo plano sin bloquear el frontend, lo cual mejora la experiencia del usuario. Si un proyecto es grande, también puede dividirlo en varias tareas para procesarlo en paralelo. Otra opción es convertir un video a múltiples formatos mediante la invocación asíncrona de varias funciones. De esta manera se reduce el tiempo total de procesamiento.

• Procesamiento de datos ETL

  En un pipeline de extracción, transformación y carga (ETL), el proceso de extraer datos de un origen, transformarlos y cargarlos en un sistema de destino suele implicar varias operaciones independientes. Por ejemplo, consultas a bases de datos, operaciones de entrada y salida de archivos o limpieza de datos. La invocación asíncrona permite ejecutar estas operaciones en paralelo, lo que reduce el tiempo de procesamiento y mejora el rendimiento del sistema. Para tareas de larga duración, como el procesamiento de grandes conjuntos de datos o transformaciones complejas, la invocación asíncrona permite ejecutarlas en segundo plano. Así se evita bloquear el frontend y se mejora la experiencia del usuario.

• Desarrollo de aplicaciones web

  Puede usar Function Compute junto con otros servicios en la nube para construir aplicaciones web rápidamente. Cuando los usuarios envían formularios, ejecutan consultas de búsqueda o cargan páginas con mucho contenido, la invocación asíncrona evita que la página se congele por esperas prolongadas de respuestas del backend. Los usuarios pueden seguir interactuando con otras partes de la página sin notar latencia. En escenarios de alta concurrencia, donde muchos usuarios acceden a la aplicación al mismo tiempo, la invocación asíncrona distribuye la carga de solicitudes y previene la sobrecarga del servicio.

Invocación diferida

Puede configurar Function Compute para desencadenar una invocación asíncrona después de un retraso específico.

Agregue el encabezado de solicitud HTTP x-fc-async-delay a su código. El valor debe estar en segundos y dentro del rango de (0, 3600). Function Compute inicia un temporizador cuando se desencadena la ejecución e invoca la función después del retraso especificado en x-fc-async-delay.

Política de reintentos

El mecanismo de invocación asíncrona incluye manejo de errores y reintentos integrados. Si un paso falla con errores, el sistema puede reprogramar la tarea sin afectar el flujo de trabajo general. Cuando una invocación de función asíncrona falla, Function Compute reintenta automáticamente la invocación.

Mecanismo de reintentos

La siguiente tabla describe la política de reintentos predeterminada para los errores más comunes.

Configurar la política de reintentos

Function Compute le permite personalizar el número máximo de reintentos y el tiempo de vida máximo del mensaje.

1. Inicie sesión en la consola de Function Compute. En el panel de navegación izquierdo, elija Function Management > Functions.

2. En la barra de navegación superior, seleccione una región. En la página Functions, haga clic en la función de destino.

3. En la página de detalles de la función, haga clic en la pestaña Tasks y luego haga clic en Task Mode a la derecha de Modify. En el panel Task Mode, establezca los siguientes parámetros. Una vez completada la configuración, haga clic en Deploy.

   Parámetro	Descripción
   Task Mode	Especifica si se habilita Task Mode para una tarea asíncrona. Para obtener más información, consulte Asynchronous tasks.
   Maximum Retries	Número máximo de reintentos para una invocación asíncrona. El valor debe ser un número entero de 0 a 8. De forma predeterminada, Function Compute reintenta 3 veces una invocación asíncrona fallida. Puede ajustar la cantidad de reintentos según sus necesidades de negocio.
   Maximum Message Lifetime	Tiempo de vida máximo de un mensaje en una cola de invocación asíncrona. El valor debe ser un número entero de 1 a 604,800. El valor predeterminado es 86,400. Unidad: segundos. Esta duración se calcula desde el momento en que se desencadena la invocación asíncrona. Si el tiempo de vida del mensaje supera el valor configurado, el mensaje se descarta. Los mensajes descartados se registran mediante la métrica de monitoreo Asynchronous Invocation Events en CloudMonitor. Para obtener más información sobre las métricas, consulte Monitoring metrics.

Devolución de llamada de resultado

Cuando Function Compute recibe una solicitud de invocación asíncrona, la almacena y devuelve una respuesta de inmediato sin esperar a que se ejecute. Para conservar las solicitudes que se descartan tras agotar todos los reintentos, o para notificar a un servicio posterior el resultado de la invocación asíncrona, configure la función de devolución de llamada de resultado. Después de configurar un servicio de destino, Function Compute llama automáticamente al servicio correspondiente según el resultado de ejecución cuando finaliza la invocación asíncrona.

Cómo funciona

La siguiente figura muestra el flujo de trabajo de la devolución de llamada de resultado.

Casos de uso

• Guardar eventos descartados para su procesamiento posterior

  Cuando una solicitud asíncrona falla y agota todos los reintentos según la política configurada, Function Compute descarta la solicitud. Si configuró un destino para fallos, Function Compute envía automáticamente la información de contexto de la solicitud fallida a un servicio de mensajería, como ApsaraMQ for RocketMQ, para su procesamiento posterior. También puede establecer otra función como servicio de destino. En ese caso, Function Compute envía automáticamente la información de contexto de la solicitud fallida a dicha función para ejecutar su lógica personalizada de manejo de errores.

• Notificar automáticamente los resultados de ejecución a los servicios posteriores

  Tras una ejecución exitosa, si se configuró un destino para éxitos, el sistema Function Compute envía automáticamente el contexto de la solicitud al servicio de destino posterior. Por ejemplo, si configura Function Compute para descomprimir automáticamente un archivo ZIP subido a OSS y desea recibir una notificación de mensaje al finalizar, puede configurar un servicio de destino de devolución de llamada de resultado para la función correspondiente.

Servicios de destino compatibles

La configuración de destinos de invocación asíncrona incluye lo siguiente:

• Contenido del evento para los destinos de invocación asíncrona

  Cuando Simple Message Queue (formerly MNS), Function Compute o ApsaraMQ for RocketMQ es el destino de una invocación de función asíncrona, el contenido del evento tiene el siguiente formato.

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

  Tabla 1. Descripciones de los parámetros

  Parámetro	Descripción
  timestamp	Marca de tiempo de la invocación.
  requestContext	Contexto de la solicitud.
  requestContext.requestId	ID de solicitud de la invocación asíncrona.
  requestContext.functionArn	Nombre de recurso de Alibaba Cloud (ARN) de la función invocada de forma asíncrona.
  requestContext.condition	Código de error de la invocación.
  requestContext.approximateInvokeCount	Número de veces que se ejecutó la invocación asíncrona. Un valor mayor que 1 indica que Function Compute reintentó la invocación.
  requestPayload	Carga útil original de la solicitud de la función.
  responseContext	Contexto de la respuesta.
  responseContext.statusCode	Código de estado del sistema devuelto por la invocación de la función. Si el código de estado no es 200, ocurrió un error del sistema.
  responseContext.functionError	Mensaje de error de la invocación.
  responsePayload	Carga útil original devuelta por la ejecución de la función.

  Cuando se usa EventBridge como destino de una invocación de función asíncrona, el evento tiene el siguiente formato. Para obtener más información, consulte Event Overview.

  {
      "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"
  }

• Límites de carga útil

  Los límites máximos de carga útil para los servicios de destino compatibles son los siguientes:

  • Simple Message Queue (formerly MNS): 64 KB

  • Function Compute: sujeto a los límites descritos en Function runtime resource limits.

  • EventBridge: 64 KB

  • ApsaraMQ for RocketMQ: 4 MB

• Evitar bucles de invocación

  Al configurar un destino para una ejecución asíncrona, evite crear un bucle de invocación. Por ejemplo, si configura la Función B como destino de las invocaciones exitosas de la Función A, y la Función A como destino de las invocaciones exitosas de la Función B. En este caso, si desencadena de forma asíncrona la Función A y se ejecuta correctamente, podría generarse un bucle de invocación de A hacia B y de regreso a A.

Preguntas frecuentes

¿Cómo desencadenar una invocación asíncrona?

Puede usar uno de los siguientes métodos para invocar de forma asíncrona una función en Function Compute:

• Inicie sesión en la consola de Function Compute, busque la función de destino, vaya a la pestaña Test, seleccione I want to make the call asynchronously. y luego haga clic en Test Function.

• Llame a la API InvokeFunction y establezca el parámetro x-fc-invocation-type en Async.

• Use Serverless Devs para configurar una invocación asíncrona. Establezca el parámetro invocation-type en Async. Para obtener más información, consulte Invoke a function.

• Cree un disparador compatible con la invocación asíncrona para desencadenar la función de esa manera. Para obtener más información, consulte Event-driven invocations.

• Cuando use un disparador HTTP o un dominio personalizado para una invocación, establezca el encabezado de solicitud X-Fc-Invocation-Type en Async, como se muestra en el siguiente ejemplo.

  curl -v -H "X-Fc-Invocation-Type: Async" https://example.cn-shenzhen.fcapp.run/$path

  Nota

  • Llamar a una Web Function: por ejemplo, si usa Flask y desea probar una función de Python con una ruta definida como @app.route('/test'), reemplace $path por test. Cuando pruebe una función de Python con una ruta definida como @app.route('/'), llame directamente al endpoint público del disparador HTTP.

  • Invocar una Event Function: llame directamente al endpoint público del disparador HTTP.

Pasos siguientes

Para rastrear el estado de una solicitud asíncrona en cada etapa, habilite Task Mode. Para obtener más información, consulte Asynchronous tasks.