Por lo general, las fallas de publicación se deben a cuellos de botella del cliente, como CPU de servicio insuficientes, mal estado de los subprocesos o la congestión de la red. La política de reintentos del publicador define la cantidad de veces que Pub/Sub intenta entregar un mensaje y el tiempo entre cada intento.
En este documento, se proporciona información sobre el uso de las solicitudes de reintento con mensajes publicados en un tema.
Antes de comenzar
Antes de configurar el flujo de trabajo de publicación, asegúrate de haber completado las siguientes tareas:
- Obtén más información sobre los temas y el flujo de trabajo de publicación.
- Crea un tema.
Funciones obligatorias
Para obtener los permisos que necesitas para reintentar las solicitudes de mensajes a un tema, pídele a tu administrador que te otorgue el rol de IAM Publicador de Pub/Sub (roles/pubsub.publisher
) en el tema.
Para obtener más información sobre cómo otorgar roles, consulta Administra el acceso.
Es posible que también puedas obtener los permisos necesarios a través de los roles personalizados o de otros roles predefinidos.
Necesitas permisos adicionales para crear o actualizar temas y suscripciones.
Acerca de las solicitudes de reintento
La configuración de reintento controla cómo las bibliotecas cliente de Pub/Sub reintentan las solicitudes de publicación. Las bibliotecas cliente tienen cualquiera de las siguientes configuraciones de reintento:
- Tiempo de espera de solicitud inicial: La cantidad de tiempo antes de que una biblioteca cliente deja de esperar a que se complete la solicitud de publicación inicial.
- Retraso de reintentos: La cantidad de tiempo que una biblioteca cliente espera para reintentar una solicitud después de que se agota el tiempo de espera de la solicitud.
- Tiempo de espera total: La cantidad de tiempo después de que una biblioteca cliente deje de reintentar las solicitudes de publicación.
Para reintentar las solicitudes de publicación, el tiempo de espera de la solicitud inicial debe ser menor que el tiempo de espera total. Por ejemplo, si usas la retirada exponencial, las bibliotecas cliente calculan el tiempo de espera de la solicitud y la demora en el reintento de la siguiente manera:
- Después de cada solicitud de publicación, el tiempo de espera de la solicitud aumenta según el multiplicador de tiempo de espera de la solicitud, hasta el tiempo máximo de espera de la solicitud.
- Después de cada reintento, la demora de reintentos aumenta según el multiplicador de demora en reintentos, hasta el retraso máximo de reintentos.
Vuelve a intentar una solicitud de mensaje
Durante el proceso de publicación, es posible que se produzcan errores transitorios o permanentes. En el caso de los errores transitorios, por lo general, no es necesario realizar ninguna acción especial, ya que Pub/Sub vuelve a intentar los mensajes de forma automática.
También puede ocurrir un error cuando una operación de publicación es exitosa, pero el cliente publicador no recibe a tiempo la respuesta de publicación. En este caso también, se reintenta la operación de publicación. Por lo tanto, puedes tener dos mensajes idénticos con diferentes ID de mensaje.
En caso de errores persistentes, considera implementar las acciones adecuadas fuera del proceso de publicación para evitar sobrecargar a Pub/Sub.
Las fallas de publicación se vuelven a intentar de forma automática, excepto los errores que no garantizan reintentos. En este código, se muestra cómo crear un publicador con opciones de configuración de reintento personalizadas (ten en cuenta que no todas las bibliotecas cliente admiten la configuración de reintento personalizada; consulta la documentación de referencia de la API para el lenguaje que elegiste):
C++
Antes de probar esta muestra, sigue las instrucciones de configuración de C++ en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para C++.
C#
Antes de probar esta muestra, sigue las instrucciones de configuración de C# en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para C#.
Go
Antes de probar esta muestra, sigue las instrucciones de configuración de Go en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Go.
Java
Antes de probar esta muestra, sigue las instrucciones de configuración de Java en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Java.
Node.js
Antes de probar esta muestra, sigue las instrucciones de configuración de Node.js en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Node.js.
Node.js
Antes de probar esta muestra, sigue las instrucciones de configuración de Node.js en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Node.js.
Python
Antes de probar esta muestra, sigue las instrucciones de configuración de Python en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Python.
Cómo reintentar solicitudes con claves de ordenamiento
Supongamos que tienes un solo cliente publicador. Usas las bibliotecas cliente de Pub/Sub a fin de publicar los mensajes 1, 2 y 3 para la misma clave de ordenamiento A. Ahora, imagina que el cliente publicador no recibe la respuesta publicada para el mensaje 1 antes de que venza el plazo de RPC. Se debe volver a publicar el mensaje 1. La secuencia de mensajes que recibe el cliente suscriptor se convierte en 1, 1, 2 y 3, si supones que el mensaje 2 se publica solo después de que el mensaje 1 se completa correctamente. Cada mensaje publicado tiene su propio ID. Desde la perspectiva del cliente suscriptor, se publicaron cuatro mensajes y los dos primeros tienen contenido idéntico.
Volver a intentar las solicitudes de publicación con claves de pedido también puede resultar complicado debido a la configuración por lotes. La biblioteca cliente agrupa los mensajes en lotes para una publicación más eficiente. Continúa con el ejemplo anterior y supone que los mensajes 1 y 2 están agrupados en lotes. Este lote se envía al servidor como una solicitud única. Si el servidor no muestra una respuesta a tiempo, el cliente publicador vuelve a intentar este lote de dos mensajes. Por lo tanto, es posible que el cliente suscriptor reciba los mensajes 1, 2, 1, 2 y 3. Si usas una biblioteca cliente de Pub/Sub para publicar mensajes en orden y falla una operación de publicación, el servicio falla en las operaciones de publicación de todos los mensajes restantes con la misma clave de orden. Un cliente publicador puede decidir seguir cualquiera de las siguientes operaciones:
Volver a publicar todos los mensajes con errores en orden
Volver a publicar un subconjunto de los mensajes con errores en orden
Publica un nuevo conjunto de mensajes
Si se produce un error que no se puede reintentar, la biblioteca cliente no publica el mensaje y deja de publicar otros mensajes con la misma clave de ordenamiento. Por ejemplo, cuando un publicador envía un mensaje a un tema que no existe, se produce un error que no se puede reintentar. Para continuar publicando mensajes con la misma clave de ordenamiento, llama a un método para reanudar la publicación y comienza a realizar publicaciones nuevamente.
En el siguiente ejemplo, se muestra cómo reanudar la publicación de mensajes con la misma clave de ordenamiento.
C++
Antes de probar esta muestra, sigue las instrucciones de configuración de C++ en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para C++.
C#
Antes de probar esta muestra, sigue las instrucciones de configuración de C# en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para C#.
Go
Antes de probar esta muestra, sigue las instrucciones de configuración de Go en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Go.
Java
Antes de probar esta muestra, sigue las instrucciones de configuración de Java en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Java.
Node.js
Antes de probar esta muestra, sigue las instrucciones de configuración de Node.js en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Node.js.
Python
Antes de probar esta muestra, sigue las instrucciones de configuración de Python en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Python.
Rita
Antes de probar esta muestra, sigue las instrucciones de configuración de Ruby en la guía de inicio rápido sobre el uso de bibliotecas cliente. Si quieres obtener más información, consulta la documentación de referencia de la API de Pub/Sub para Ruby.
¿Qué sigue?
Para aprender a configurar las opciones de publicación avanzada, consulta lo siguiente: