Descripción general de OpenEvent - DataWorks - Centro de documentación de Alibaba Cloud

OpenEvent para DataWorks envía mensajes de cambio de estado a EventBridge, lo que le permite suscribirse y responder en tiempo real. Por ejemplo, suscríbase a cambios en tablas para monitorear tablas clave, o a cambios en tareas para crear paneles de monitoreo personalizados.

Descripción general

DataWorks envía mensajes de cambio de estado desde sus procesos principales a OpenEvent. Use el módulo OpenEvent para gestionar el envío de mensajes de su espacio de trabajo y use EventBridge to filter and consume event messages.

Ventajas:

Bajo costo de operación y mantenimiento: Habilite la suscripción de mensajes en Open Platform de DataWorks para suscribirse a mensajes de eventos.
Desarrollo más rápido: Configure las suscripciones en la consola de DataWorks sin necesidad de configurar manualmente el envío de mensajes. Prepare el SDK y suscríbase.
Respuestas personalizables: Suscríbase a tipos específicos de eventos para detectar cambios en el negocio y activar respuestas personalizadas.

Notas de uso

Edition: DataWorks Enterprise Edition only.
Regiones: Compatible con China (Beijing), China (Hangzhou), China (Shenzhen), China (Shanghai), China (Zhangjiakou), China (Chengdu), EE. UU. (Silicon Valley), EE. UU. (Virginia), Alemania (Frankfurt), Japón (Tokio), China (Hong Kong) y Singapur.
Control de acceso: Solo el Open Platform Administrator, el Tenant Administrator, las cuentas de Alibaba Cloud o los usuarios de RAM con Aliyundataworksfullaccess tienen permisos de lectura y escritura en la consola de desarrollador. Open Platform administrator. Grant the AliyunDataWorksFullAccess permission to a RAM user.
Dependencia: OpenEvent usa EventBridge para la suscripción y el consumo de mensajes. Active EventBridge antes de empezar.

Conceptos relacionados

DataWorks clasifica los mensajes de eventos en eventos regulares y eventos de punto de extensión según si crean puntos de control de proceso.

Regular Events: Desarrolle un programa local para recibir estos mensajes y crear respuestas personalizadas.
Extension Point Events: Estos eventos admiten todas las capacidades de los eventos regulares. También puede registrar un programa local como una extensión de DataWorks to implement custom logic and behavior controls such as intercepting or blocking user operations.

Los eventos también se clasifican por alcance en eventos de espacio de trabajo y eventos de inquilino.

Eventos de espacio de trabajo: Generados por módulos de espacio de trabajo, como Data Studio (ejecución de nodos) y Operation Center (cambios de estado de instancias programadas).
Eventos de inquilino: Generados por módulos de inquilino, como la eliminación de espacios de trabajo desde la consola. Las siguientes tablas de eventos enumeran el tipo, la categoría y el formato de mensaje para cada módulo.

Tipos de eventos compatibles

Las siguientes tablas enumeran los eventos de punto de extensión y los eventos regulares de espacio de trabajo e inquilino.

Eventos de inquilino

Consola

Formatos de mensajes de la consola: Console event message formats.

Tipo de evento	Evento	Evento regular	Evento de punto de extensión	Ejemplo (operaciones que generan mensajes de evento)
Eliminar un espacio de trabajo	Evento previo a la eliminación del espacio de trabajo	No compatible	Compatible	Este evento se activa antes de que un usuario elimine un espacio de trabajo. El Pre-delete Workspace Event activa la extensión correspondiente para crear un punto de control de proceso.
Eliminar un espacio de trabajo	Posterior a la eliminación del espacio de trabajo	Compatible	No compatible

Carga y descarga de datos

Formatos de mensajes: Data Upload & Download event message formats.

Tipo de evento	Evento	Evento regular	Evento de punto de extensión	Ejemplo (operaciones que generan mensajes de evento)
Descarga y carga de datos	Evento previo a la descarga de datos - Generación de archivo	No compatible	Compatible	Un usuario descarga datos desde el centro de descargas. Antes de la descarga, el Pre-data Download Event captura información sobre la operación.
	Evento previo a la descarga de datos - Descarga de archivo	No compatible	Compatible
	Evento previo a la carga de datos	No compatible	Compatible

Eventos de espacio de trabajo

Data Studio

Formatos de mensajes: Data Studio event message formats.

Tipo de evento	Evento	Evento regular	Evento de punto de extensión	Ejemplo (operaciones que generan mensajes de evento)
Cambios en nodos	Agregar un nodo	Compatible	No compatible	Crear un nodo y desplegarlo en producción
Cambios en nodos	Actualizar un nodo	Compatible	No compatible	Modificar un nodo en el entorno de desarrollo Desplegar la modificación en producción
Cambios en archivos Nodo Recurso Función	Evento previo a la eliminación de archivo	No compatible	Compatible	Eliminar un archivo en el entorno de desarrollo. El archivo eliminado se mueve a la papelera de reciclaje.
	Evento previo al envío de archivo	No compatible	Compatible	Enviar un nodo, recurso o función en Data Studio.
	Evento previo al despliegue de archivo	No compatible	Compatible	Desplegar un nodo, recurso o función enviado en Data Studio.
	Evento previo a la ejecución de código	No compatible	Compatible	Ejecutar código de nodo en Data Studio.
Cambios en tablas	Evento previo al envío de tabla a desarrollo	No compatible	Compatible	Evento de punto de extensión de envío de tabla: Por ejemplo, enviar una tabla en la gestión de tablas.
Cambios en tablas	Evento previo al envío de tabla a producción	No compatible	Compatible	Evento de punto de extensión de despliegue de tabla: Por ejemplo, desplegar una tabla en la gestión de tablas. Nota Solo los espacios de trabajo en modo estándar admiten el despliegue de tablas en la gestión de tablas. Por lo tanto, el evento de punto de extensión de despliegue de tabla solo existe en el modo estándar.

Data Integration

Formatos de mensajes: Data Integration event message formats.

Tipo de evento	Evento	Evento regular	Evento de punto de extensión	Ejemplo (operaciones que generan mensajes de evento)
Eventos de cambio de nodo	Iniciar una tarea en tiempo real	No compatible	Compatible	Iniciar una tarea en tiempo real en Data Integration.
Eventos de cambio de nodo	Inicio por lotes de tareas en tiempo real	No compatible	Compatible	Iniciar tareas en tiempo real por lotes en Data Integration.

Operation Center

Formatos de mensajes: Operation Center event message formats.

Tipo de evento	Evento	Evento regular	Evento de punto de extensión	Ejemplo (operaciones que generan mensajes de evento)
Cambios en nodos	Eliminar un nodo	Compatible	No compatible	Desplegar la operación de eliminación en producción para retirar el nodo de producción Eliminar un nodo de la papelera de reciclaje
	Evento previo al retiro de nodo	No compatible	Compatible	Retirar directamente un nodo de las tareas programadas en el entorno de producción. Nota Esta operación también elimina el nodo en Data Studio y lo mueve a la papelera de reciclaje.
	Evento previo a la congelación de nodo	No compatible	Compatible	Congelar una tarea en la página de tareas programadas.
	Evento previo a la descongelación de nodo	No compatible	Compatible	Descongelar una tarea en la página de tareas programadas.
Relleno de datos de nodo	Evento previo al relleno de datos	No compatible	Compatible	Rellenar datos para el nodo actual de una tarea programada. Rellenar datos para el nodo actual y los nodos descendentes de una tarea programada. Rellenar datos en modo de nodos masivos. Rellenar datos en modo avanzado.
Cambios de estado de tarea	Cambio de estado de tarea programada	Compatible	No compatible	Los siguientes escenarios activan un evento de cambio de estado de tarea programada: Una tarea programada se envía a Data Quality para validación de datos. Una tarea programada valida condiciones de rama. Una tarea se activa por programación, manualmente o mediante un evento. El estado de la tarea cambia de Pending Resource a Running. Una tarea programada finaliza su ejecución (exitosa o con errores). El estado de la tarea cambia de Running a Succeeded. Después de que una tarea programada falla, usted elige volver a ejecutarla. El estado de la tarea cambia de Failed a Running. Una tarea programada se configura para ejecutarse a una hora específica. El estado de la tarea cambia a espera de la hora programada (DueTime o cycleTime).
Cambios en instancias	Congelar una instancia	Compatible	No compatible	Los siguientes eventos se activan después de realizar estas operaciones en una instancia de la lista de instancias programadas en Operation Center. Congelar una instancia. Descongelar una instancia. Finalizar una instancia. Volver a ejecutar una instancia. Marcar una instancia como exitosa. Quitar una dependencia ascendente específica de una instancia.
	Descongelar una instancia	Compatible	No compatible
	Finalizar una instancia	Compatible	No compatible
	Volver a ejecutar una instancia Volver a ejecutar Volver a ejecutar descendientes	Compatible	No compatible
	Marcar una instancia como exitosa	Compatible	No compatible
	Quitar una dependencia ascendente específica de una instancia	Compatible	No compatible
	Evento previo a la congelación de instancia	No compatible	Compatible	Cuando realiza una operación en una instancia de la lista de instancias programadas en Operation Center, se activa el evento previo correspondiente. Congelar una instancia. Descongelar una instancia. Volver a ejecutar una instancia. Marcar una instancia como exitosa. Finalizar una instancia.
	Evento previo a la descongelación de instancia	No compatible	Compatible
	Evento previo a la reejecución de instancia	No compatible	Compatible
	Evento previo a marcar instancia como exitosa	No compatible	Compatible
	Evento previo a la finalización de instancia	No compatible	Compatible
	Eliminar instancias caducadas	Compatible	No compatible
Cambios de estado de flujo de trabajo	Cambio de estado de flujo de trabajo Instancias de relleno de datos Flujos de trabajo manuales	Compatible	No compatible	Monitoreo de estado de flujo de trabajo generado al realizar una operación de relleno de datos. Monitoreo de estado de flujo de trabajo generado al ejecutar un flujo de trabajo manual.
Alertas de monitoreo	Alerta de monitoreo	Compatible	No compatible	Ejemplo de alerta de línea base: Una tarea en una línea base tiene una hora estimada de finalización demasiado tardía, lo que activa una alerta de línea base. Ejemplo de alerta de evento: Una tarea en una línea base falla, lo que activa una alerta de evento. Ejemplo de alerta de regla: Después de crear una regla de monitoreo para nodos huérfanos, aparece un nodo huérfano en un flujo de trabajo, lo que activa esta alerta de regla.

Security Center

Formatos de mensajes: Security Center event message formats.

Tipo de evento	Evento	Evento regular	Evento de punto de extensión	Ejemplo (operaciones que generan mensajes de evento)
Creación/aprobación de solicitud de permiso	Evento previo a la creación de solicitud de permiso	No compatible	Compatible	Por ejemplo, en Security Center, vaya a la página Data Access Control > Permission Request para crear solicitudes de permiso para Functions, Tables y Resources.
Creación/aprobación de solicitud de permiso	Completar una solicitud	Compatible	No compatible	Por ejemplo, en Security Center, vaya a la página Data Access Control > Permission Approval para aprobar permisos para tablas, recursos y funciones en todos los proyectos.
Cambios en permisos de tabla	Solicitud de permiso de tabla	No compatible	Compatible	Por ejemplo, un usuario solicita permisos de lectura, escritura o modificación para una tabla específica según sus necesidades.

Data Quality

Formatos de mensajes: Data Quality event message formats.

Tipo de evento	Evento	Evento regular	Evento de punto de extensión	Ejemplo (operaciones que generan mensajes de evento)
Validación de calidad de datos	Comentarios sobre resultados de validación	Compatible	No compatible	Comentarios sobre los resultados de validación. Por ejemplo, en Data Quality, habilite una regla que requiera que el recuento de filas de una tabla sea mayor que 0. Un usuario envía comentarios sobre un resultado de validación y el sistema envía los comentarios (ID de regla, contenido y otra información) al suscriptor.
Validación de calidad de datos	Validación completada	Compatible	No compatible	Una vez completada la validación de la regla, se envía el resultado (estado de aprobación/fallo, muestras y otra información). Por ejemplo, en Data Quality, habilite una regla que requiera que el recuento de filas de una tabla sea mayor que 0. Cuando finaliza la validación, el resultado se envía al suscriptor.
Eventos previos a reglas de calidad de datos	Evento previo a la creación por lotes de reglas de calidad de datos	No compatible	Compatible	Por ejemplo, en Data Quality, vaya a la página Rule Configuration > Configure by Table y abra la página de detalles de una tabla específica. Las siguientes operaciones en la pestaña Rule Management activan los eventos previos correspondientes. Crear varias reglas de monitoreo de calidad de datos. Modificar varias reglas de monitoreo de calidad de datos. Eliminar varias reglas de monitoreo de calidad de datos. Modificar una regla específica de monitoreo de calidad de datos.
	Evento previo a la actualización por lotes de reglas de calidad de datos	No compatible	Compatible
	Evento previo a la eliminación por lotes de reglas de calidad de datos	No compatible	Compatible
	Evento previo a la actualización de regla de calidad de datos	No compatible	Compatible
Eventos previos al monitoreo de calidad de datos	Evento previo a la creación de monitoreo de calidad de datos	No compatible	Compatible	Por ejemplo, en Data Quality, vaya a la página Rule Configuration > Configure by Table y abra la página de detalles de una tabla específica. Las siguientes operaciones en la pestaña Quality Monitoring activan los eventos previos correspondientes. Crear una configuración de monitoreo de calidad de datos. Modificar una configuración de monitoreo de calidad de datos. Clonar una configuración de monitoreo de calidad de datos. Eliminar por lotes configuraciones de monitoreo de calidad de datos.
	Evento previo a la actualización de monitoreo de calidad de datos	No compatible	Compatible
	Evento previo a la clonación de monitoreo de calidad de datos	No compatible	Compatible
	Evento previo a la eliminación por lotes de monitoreo de calidad de datos	No compatible	Compatible
Eventos previos a la suscripción de alertas de monitoreo de calidad de datos	Evento previo a la creación de suscripción de alertas de monitoreo de calidad de datos	No compatible	Compatible	Por ejemplo, en Data Quality, vaya a la página Rule Configuration > Configure by Table y abra la página de detalles de una tabla específica. En la pestaña Quality Monitoring, suscríbase a alertas para una configuración específica de monitoreo de calidad.
	Evento previo a la actualización de suscripción de alertas de monitoreo de calidad de datos	No compatible	Compatible	Por ejemplo, en Data Quality, vaya a la página Rule Configuration > Configure by Table y abra la página de detalles de una tabla específica. En la pestaña Quality Monitoring, modifique la información de suscripción de alertas de una configuración específica de monitoreo de calidad.
	Evento previo a la eliminación de suscripción de alertas de monitoreo de calidad de datos	No compatible	Compatible	Por ejemplo, en Data Quality, vaya a la página Rule Configuration > Configure by Table y abra la página de detalles de una tabla específica. En la pestaña Quality Monitoring, elimine la información de suscripción de alertas de una configuración específica de monitoreo de calidad.