Suscripciones para apps y escalado de apps

Las aplicaciones pueden suscribirse a varios productores de eventos, pero sólo una aplicación puede recibir eventos de cada suscripción. Tenga en cuenta que las suscripciones pueden afectar a la forma de escalado de la aplicación. Por ejemplo, si esperas que tu aplicación reciba muchos eventos al mismo tiempo y procesar cada evento lleva varios minutos, entonces podrías necesitar un valor de escala máxima más alto que si cada evento se puede procesar rápidamente. Para obtener más información, consulte Configuración del escalado de una aplicación.

Todos los sucesos que se entregan a las aplicaciones se reciben como mensajes HTTP. Los sucesos contienen determinadas cabeceras HTTP que le ayudan a determinar rápidamente los bits clave de información sobre los sucesos sin mirar el cuerpo (lógica empresarial) del suceso. Para obtener más información, consulte Ejemplo HTTP cabeceras para un evento IBM Cloud Object Storage que se envía a una aplicación.

Suscripciones para trabajos y limitaciones de ejecución de trabajos

Las suscripciones pueden afectar al número de trabajos que se inician. Por ejemplo, si el trabajo se suscribe para suprimir cambios en un grupo Object Storage y dicho grupo se suprime, se ejecuta un trabajo para cada objeto que estaba en dicho grupo y puede alcanzar rápidamente la limitación de 100 ejecuciones de trabajos. Además, debe tener en cuenta el tiempo de ejecución para cada ejecución de trabajo desencadenada por un suceso. Por ejemplo, si el generador de sucesos desencadena 10 o más sucesos por segundo y cada trabajo se ejecuta durante unos 20 segundos, el límite de ejecución del trabajo de 100 se alcanza en unos 10 segundos y las ejecuciones de trabajos posteriores se pierden hasta que se completan las ejecuciones de trabajos iniciadas anteriormente. Elija un trabajo como destino del suscriptor de eventos sólo si el número de eventos entrantes es generalmente bajo y el pico de eventos esperados en un periodo de tiempo específico es lo suficientemente bajo como para mantener el número de trabajos en ejecución por debajo del límite de cuota. Para obtener más información, consulte Límites y cuotas de Code Engine.

Después de 10 minutos, las ejecuciones de trabajo creadas por suscripciones se suprimen. Para obtener más información, consulte ¿Dónde se ejecuta mi trabajo?.

Todos los eventos que se entregan a los trabajos se reciben como variables de entorno. Para obtener más información, consulte Variables de entorno de ejemplo para un suceso IBM Cloud Object Storage que se envía a un trabajo.

Sucesos de Eventing

Los eventos gestionados por Code Engine al crear una suscripción se modifican para que se adhieran al Especificación de CloudEvents. Esta especificación define un conjunto de atributos comunes que se incluirán en cada suceso con el fin de proporcionar un conjunto común de metadatos. Al examinar los metadatos, puede detectar rápidamente las partes clave del mensaje sin analizar ni comprender la totalidad de la carga útil del suceso. Por ejemplo, cada evento que se entrega a una aplicación incluye una cabecera HTTP denominada ce-type, que indica el significado semántico (o "razón") del evento. Un suceso de una base de datos puede incluir un valor ce-type de com.example.row.deleted, que indica que el suceso se ha generado porque se ha suprimido una fila en la base de datos.

En la tabla siguiente, se muestran algunos atributos comunes clave. Cada atributo indica si es un atributo obligatorio en el suceso de entrada o si es opcional.

Para más información sobre la lista completa de atributos, consulte la especificación CloudEvents.

En Code Engine, cuando los sucesos se entregan a aplicaciones, los atributos CloudEvent aparecen como cabeceras HTTP, con el prefijo ce-. Cuando se entregan sucesos a trabajos por lotes, los atributos aparecen como variables de entorno, con el prefijo CE_ y todo el nombre de variable está en mayúsculas.

ce-id: 3fb2c04e-a660-4640-8899-b82efb8169b6
ce-source: https://cloud.ibm.com/catalog/services/cloud-object-storage/mybucket
ce-specversion: 1.0
ce-subject: object-69-144
ce-time: 2021-08-17T20:22:02.917Z
ce-type: com.ibm.cloud.cos.document.delete

CE_DATA={"bucket":"mybucket","endpoint":"","key":"Notes.rtf","notification":{"bucket_name":"mybucket","content_type":"text/rtf","event_type":"Object:Delete","format":"2.0","object_length":"4642","object_name":"Notes.rtf","request_id":"b59727ee-9c4e-446a-9261-5616f6d1283b","request_time":"2021-04-13T20:10:37.631Z"},"operation":"Object:Delete"}  
CE_ID=b59727ee-9c4e-446a-9261-5616f6d1283b  
CE_SOURCE=https://cloud.ibm.com/catalog/services/cloud-object-storage/mybucket  
CE_SPECVERSION=1.0  
CE_TIME=2021-08-17T20:22:02.917Z  
CE_TYPE=com.ibm.cloud.cos.document.delete  

¿Qué ocurre cuando creo una suscripción?

De forma predeterminada, los mandatos subscription cron create, subscription cos create y subscription kafka create comprueban primero si existe la aplicación o el trabajo de destino. Si la comprobación de destino falla porque la aplicación o el trabajo no existe en el proyecto, los mandatos para crear la suscripción devuelven un error. Si desea crear una suscripción sin crear primero la aplicación, utilice la opción --force. Mediante la opción --force, el mandato ignora la comprobación de destino. Fíjese que en el campo Ready de la suscripción se muestra false hasta que se crea la aplicación de destino. A continuación, la suscripción pasa automáticamente al estado Ready: true.

Tras crear la suscripción, se sondea repetidamente el estado de la misma para verificar su grado de disponibilidad. Este sondeo dura 15 segundos, de forma predeterminada, antes de que se exceda el tiempo de espera. Puede cambiar la cantidad de tiempo antes de que el mandato exceda el tiempo de espera utilizando la opción --wait-timeout. También puede ignorar el sondeo del estado definiendo la opción --no-wait en false.

Puede visualizar el estado de la suscripción utilizando los mandatos de CLI subscription cron get, subscription cos get o subscription kafka get.