Para utilizar Realtime Compute for Apache Flink, debe activar un workspace. Cada workspace cuenta con recursos de cómputo aislados y una consola de desarrollo independiente. Este tema describe cómo activar un workspace de Flink y las consideraciones importantes durante el proceso.
Requisitos previos
Debe tener una cuenta de Alibaba Cloud. Si aún no dispone de una, regístrese primero.
Si accede al servicio mediante un usuario o rol de Resource Access Management (RAM), debe contar con los permisos necesarios para la consola de Realtime Compute. Para obtener más información, consulte Permission Management.
Consideraciones importantes
La creación de un workspace de Flink involucra otros servicios en la nube, incluidos VPC, OSS y servicios relacionados con el monitoreo. Para conocer los detalles de precios, consulte Billing items.
-
Realtime Compute for Apache Flink utiliza una arquitectura de desacoplamiento entre almacenamiento y cómputo al vincular un OSS Bucket, tenga en cuenta lo siguiente:
Si no ha activado OSS, consulte Activate OSS para comenzar. El bucket de OSS debe encontrarse en la misma región que su workspace de Flink y utilizar la clase de almacenamiento Standard.
-
No aplique ninguna política —como control de versiones o retención por cumplimiento normativo— al bucket de OSS vinculado. Estas políticas podrían interrumpir la ejecución normal de los trabajos de Flink.
Si el control de versiones está habilitado en su bucket de OSS, un exceso de marcadores de eliminación puede ralentizar las operaciones de listado. Si habilita el control de versiones, configure una regla de ciclo de vida para purgar periódicamente los marcadores de eliminación y las versiones históricas innecesarias. Esto reduce los costos de almacenamiento y mejora el rendimiento de OSS. Para obtener instrucciones sobre cómo purgar marcadores de eliminación, consulte Use lifecycle rules based on last modified time with versioning to reduce storage costs.
AvisoSi el control de versiones está deshabilitado en su bucket de OSS y configura una regla de ciclo de vida, no aplique una política de purga a los directorios relacionados con Flink, incluidos artifacts, flink-jobs, flink-savepoints, sql-artifacts, plan y flink-sessionclusters. Una política de purga podría eliminar archivos esenciales de Flink y provocar fallos en los trabajos.
-
Si selecciona OSS Bucket como tipo de almacenamiento durante la activación del workspace, asegúrese de que el bucket vinculado utilice zone-redundant storage para lograr alta disponibilidad a nivel de zona en su workspace de Flink. (Para consultar los pasos de configuración, véase Change the storage redundancy type of a bucket.) De lo contrario, si una zona deja de estar disponible, no se podrá acceder correctamente a los datos de estado y Flink no podrá garantizar la recuperación de trabajos con estado.
NotaSi un workspace contiene espacios de proyecto tanto redundantes entre zonas como de zona única, actualizar el bucket vinculado a almacenamiento redundante entre zonas podría incrementar los costos de almacenamiento. Para equilibrar costo y confiabilidad, cree un workspace separado dedicado a cargas de trabajo redundantes entre zonas y vincúlelo a un bucket de OSS con redundancia entre zonas. Para obtener detalles sobre los precios de almacenamiento de OSS, consulte Storage fees.
Si selecciona OSS Bucket como tipo de almacenamiento, asegúrese de que la detección de archivos maliciosos esté deshabilitada en Security Center. Habilitar esta función podría activar la limitación de tráfico de OSS y provocar que los trabajos de Flink se detengan durante la inicialización. Para obtener más información, consulte Malicious file detection.
Activar un workspace de suscripción
Inicie sesión en la Consola de administración de Realtime Compute.
Haga clic en Purchase junto a Streaming Compute Flink.
-
En su primera compra, otorgue permiso a Flink para acceder a los recursos en la nube necesarios.
Haga clic en Go to RAM for Authorization. En la página Cloud Resource Access Authorization, haga clic en Agree to Authorize. Esto completa la autorización automatizada y concede acceso a los servicios en la nube requeridos.
-
En la página de compra, introduzca los detalles de configuración.
Categoría
Elemento de configuración
Descripción
Ejemplo
Configuración básica
Billing method
Seleccione subscription. Para obtener detalles de facturación, consulte Subscription.
Subscription
Duration
Seleccione la duración de suscripción que necesite.
1 month
Auto-renewal
Si no marca Enable, podrá modificar posteriormente su política de renovación en la Alibaba Cloud Management Console, en .
-
Processor architecture
Elija entre las arquitecturas Intel X86 y YiTian ARM según sus necesidades.
NotaLa arquitectura YiTian ARM actualmente solo está disponible para workspaces de suscripción en China (Beijing), China (Ulanqab) y China (Hangzhou). La disponibilidad está sujeta a lo que se muestre en la página de compra de la consola.
Intel X86 architecture
Region
Se recomienda seleccionar la misma region que utilizan sus sistemas de almacenamiento ascendentes y descendentes.
Beijing
Configuración de red
Deployment mode
Esta opción solo está disponible para workspaces Intel X86 en regiones específicas con el método de facturación subscription. Los deployment modes compatibles incluyen los siguientes:
Single zone (rentable): Flink asigna automáticamente la zona de cómputo óptima en la región seleccionada, agrupa el inventario entre zonas y programa recursos sin interrupciones para mejorar la capacidad de carga elástica.
Cross-zone (alta disponibilidad): Habilita la alta disponibilidad a nivel de zona. Si la zona que aloja un espacio de proyecto cross-zone falla, los trabajos se reprograman automáticamente en otra zona estable de la misma región. Esto evita interrupciones del servicio causadas por fallos en una sola zona y garantiza la continuidad de los trabajos y la alta disponibilidad.
ImportanteLa alta disponibilidad de extremo a extremo requiere que sus sistemas ascendentes y descendentes también admitan alta disponibilidad.
Si no seleccionó Cross-zone para el Deployment Mode al activar el servicio, podrá habilitar posteriormente la alta disponibilidad en la misma región mediante otros métodos, pero debe asegurarse de que su workspace cuente con suficientes recursos CU cross-zone. Para obtener más información, consulte los métodos 2 y 3 en same-region high availability.
-
CU information
Si el modo de despliegue es Single Zone: solo necesita configurar recursos de cómputo de Single Zone.
Cuando el modo de despliegue es Multi-zone, puede desmarcar la opción Enable Single-zone Hybrid Purchase según sea necesario.
Si no se selecciona: Configure únicamente recursos de cómputo cross-zone.
Si se selecciona: Establezca compute resource quotas separadas para single zone y cross-zone.
NotaCada consola de desarrollo de Realtime Compute y sus componentes esenciales requieren 2 CUs de recursos de gestión. Estos se configuran automáticamente y no requieren acción manual. Para más detalles, consulte Billing items.
-
Virtual private cloud (VPC)
Seleccione una VPC en la región destino. No podrá cambiar la VPC después de la activación. Para crear una VPC, consulte Create a VPC and vSwitch.
Si su almacenamiento ascendente o descendente reside en una VPC, su workspace de Flink debe utilizar la misma VPC.
Solo se admiten los bloques CIDR privados estándar RFC 192.168.0.0/16, 172.16.0.0/12 y 10.0.0.0/8, así como sus subredes.
flink-test-vpc
Virtual switch
Si el deployment mode es cross-zone, seleccione dos virtual switches en zonas diferentes.
Seleccione al menos un virtual switch por zona. Tras la actualización de la arquitectura de red, cada workspace consume solo una pequeña cantidad de direcciones IP. Se recomienda reservar entre 6 y 10 direcciones IP por vSwitch en cada zona. No es necesario reservar direcciones IP adicionales según la cantidad de trabajos.
NotaSolo se muestran los virtual switches existentes en la VPC destino y en las zonas compatibles con Flink. Después de la activación, puede modify virtual switches.
Las zonas de los switches seleccionados no están relacionadas con las zonas donde se ejecutan los trabajos. Se utilizan únicamente para la conectividad de red y garantizar que sus trabajos puedan acceder a los recursos de red.
No modifique ni elimine estas configuraciones de switch arbitrariamente, ya que esto podría interrumpir la conectividad de red y la ejecución de trabajos.
flinktest
Configuración del workspace
Workspace name
Debe comenzar con una letra minúscula. Utilice únicamente letras minúsculas, dígitos y guiones (-). No debe terminar con un guion. La longitud debe ser de 1 a 60 caracteres.
ImportanteEl workspace name debe ser globalmente único (incluidos los workspaces creados por otros usuarios). Si el nombre ya existe, el sistema mostrará Workspace name already exists. Modifique el nombre en consecuencia. Tras una activación exitosa, no podrá cambiar el nombre del workspace.
flinktestnamespace
Configuración de almacenamiento
OSS storage
El bucket de OSS almacena puntos de control de trabajos, instantáneas, registros, paquetes JAR y otros datos. Para obtener detalles sobre los directorios, consulte File management.
ImportanteAl vincular un bucket de OSS, revise la Important considerations.
Si el deployment mode es cross-zone, el sistema valida la configuración de OSS y muestra únicamente buckets con zone-redundant storage.
No podrá modificar el bucket de OSS después de crear el workspace de Flink.
flink-test-oss
Clave y valor de etiqueta
Las etiquetas consisten en una clave y un valor de etiqueta, y sirven como identificadores para los recursos en la nube. Ayudan a categorizar, buscar y agrupar recursos con características comunes en distintas dimensiones, lo que simplifica la gestión de recursos. Gestione las etiquetas de forma centralizada en Tag Management.
-
Servicio de monitoreo
Storage type
Elija entre el fully managed storage o el OSS Bucket (para conocer las diferencias de funciones, consulte Feature comparison between Cloud Monitor and ARMS alerting):
Free monitoring service: Tras crear un workspace de Flink, Cloud Monitor proporciona capacidades básicas de monitoreo y alertas. Para más detalles, consulte Free usage.
Prometheus monitoring service: Tras crear un workspace de Flink, ARMS se activa automáticamente para proporcionar monitoreo y alertas Prometheus de grado comercial. Para obtener detalles de facturación, consulte Prometheus billing.
Free monitoring service
-
Seleccione Fully managed storage, haga clic en Monitoring service y complete el pago para activar el servicio.
Después del pago, haga clic en Management Console para ver el workspace que se está creando. La creación del workspace suele completarse entre 5 y 10 minutos después del pago.
Activar un workspace pay-as-you-go
Para activar más de 1,000 CUs a la vez, envíe un ticket.
Inicie sesión en la Consola de administración de Realtime Compute.
Haga clic en Purchase junto a Streaming Compute Flink.
-
(Opcional) En su primera compra, otorgue permiso a Flink para acceder a los recursos en la nube necesarios.
Haga clic en Go to RAM for Authorization. En la página Cloud Resource Access Authorization, haga clic en Agree to Authorize. Esto completa la autorización automatizada y concede acceso a los servicios en la nube requeridos.
NotaSi no es su primera compra, omita este paso.
-
En la página de compra, introduzca los detalles de configuración.
Configure el workspace name (no se puede cambiar después de la creación; cada workspace tiene recursos de cómputo aislados y una consola de desarrollo independiente), el quota limit (por ejemplo, 1,000 CUs) y el storage type (OSS Bucket o fully managed storage para almacenar puntos de control de trabajos, registros, paquetes JAR y otros datos).
Categoría
Elemento de configuración
Descripción
Ejemplo
Configuración básica
Billing method
Seleccione pay-as-you-go. Para obtener detalles de facturación, consulte Pay-as-you-go.
Pay-as-you-go
Region
Se recomienda seleccionar la misma region que utilizan sus sistemas de almacenamiento ascendentes y descendentes.
Beijing
Configuración de red
Virtual private cloud (VPC)
Seleccione una VPC en la región destino. No podrá cambiar la VPC después de la activación. Para crear una VPC, consulte Create a VPC and vSwitch.
Si su almacenamiento ascendente o descendente reside en una VPC, su workspace de Flink debe utilizar la misma VPC.
Solo se admiten los bloques CIDR privados estándar RFC 192.168.0.0/16, 172.16.0.0/12 y 10.0.0.0/8, así como sus subredes.
flink-test-vpc
Virtual switch
Si el deployment mode es cross-zone, seleccione dos virtual switches en zonas diferentes.
Seleccione al menos un virtual switch por zona. Tras la actualización de la arquitectura de red, cada workspace consume solo una pequeña cantidad de direcciones IP. Se recomienda reservar entre 6 y 10 direcciones IP por vSwitch en cada zona. No es necesario reservar direcciones IP adicionales según la cantidad de trabajos.
NotaSolo se muestran los virtual switches existentes en la VPC destino y en las zonas compatibles con Flink. Después de la activación, puede modify virtual switches.
Las zonas de los switches seleccionados no están relacionadas con las zonas donde se ejecutan los trabajos. Se utilizan únicamente para la conectividad de red y garantizar que sus trabajos puedan acceder a los recursos de red.
No modifique ni elimine estas configuraciones de switch arbitrariamente, ya que esto podría interrumpir la conectividad de red y la ejecución de trabajos.
flinktest
Configuración del workspace
Resource deduction plan
Debe comenzar con una letra minúscula. Utilice únicamente letras minúsculas, dígitos y guiones (-). No debe terminar con un guion. La longitud debe ser de 1 a 60 caracteres.
ImportanteEl workspace name debe ser globalmente único (incluidos los workspaces creados por otros usuarios). Si el nombre ya existe, el sistema mostrará Workspace name already exists. Modifique el nombre en consecuencia. Tras una activación exitosa, no podrá cambiar el nombre del workspace.
flinktestnamespace
quota limit de recursos de cómputo
La cuota predeterminada es de 1,000 CUs. Puede modificarla hasta un máximo de 9,999,999.
NotaCada consola de desarrollo de Realtime Compute y sus componentes esenciales requieren 2 CUs de recursos de gestión. Estos se configuran automáticamente y no requieren acción manual. Para más detalles, consulte Billing items.
100
Configuración de almacenamiento
OSS storage
El bucket de OSS almacena puntos de control de trabajos, instantáneas, registros, paquetes JAR y otros datos. Para obtener detalles sobre los directorios, consulte File management.
ImportanteAl vincular un bucket de OSS, revise la Important considerations.
Si el Workspace name es cross-zone, el sistema valida la configuración de OSS y muestra únicamente buckets con zone-redundant storage.
No podrá modificar el bucket de OSS después de crear el workspace de Flink.
flink-test-oss
Clave y valor de etiqueta
Las etiquetas consisten en una clave y un valor de etiqueta, y sirven como identificadores para los recursos en la nube. Ayudan a categorizar, buscar y agrupar recursos con características comunes en distintas dimensiones, lo que simplifica la gestión de recursos. Gestione las etiquetas de forma centralizada en Tag Management.
-
Servicio de monitoreo
Monitoring service
Elija entre el free monitoring service o el pay-as-you-go Prometheus monitoring service (para conocer las diferencias de funciones, consulte Feature comparison between Cloud Monitor and ARMS alerting):
Free monitoring service: Tras crear un workspace de Flink, Cloud Monitor proporciona capacidades básicas de monitoreo y alertas. Para más detalles, consulte Free usage.
Prometheus monitoring service: Tras crear un workspace de Flink, ARMS se activa automáticamente para proporcionar monitoreo y alertas Prometheus de grado comercial. Para obtener detalles de facturación, consulte Prometheus billing.
Free monitoring service
-
Seleccione Terms of Service, haga clic en Purchase y complete el pago para activar el servicio.
Después del pago, haga clic en Storage type para ver el workspace que se está creando. La creación del workspace suele completarse entre 5 y 10 minutos después del pago.
Siguientes pasos
Después de activar su espacio de trabajo de Flink, realice las siguientes tareas según sea necesario.
Función | Ruta de acceso |
Consultar detalles del espacio de trabajo | En la Realtime Compute Management Console, haga clic en Fully managed storage para el espacio de trabajo deseado y consulte el nombre del espacio de trabajo, el ID del espacio de trabajo, el bucket de OSS, el nombre y el ID de la VPC, los switches virtuales. |
Habilitar y usar recursos de cómputo elásticos | Configure recursos de cómputo elásticos además de un plan de suscripción. Este modelo de facturación híbrido combina la flexibilidad de pay-as-you-go con la rentabilidad de los planes de suscripción. Para obtener más información, consulte Hybrid billing. |
Comprenda la jerarquía de conceptos básicos en Realtime Compute for Apache Flink para orientar el desarrollo, despliegue, operación y gestión de seguridad de trabajos. | |
Los usuarios de RAM y los roles de RAM requieren permisos de RAM (por ejemplo, visualización y compra de espacios de trabajo) y permisos de espacio de proyecto (por ejemplo, desarrollo y operación de trabajos) para acceder a la consola de Flink. | |
El espacio de proyecto es la unidad básica para gestionar trabajos de Flink. Todas sus configuraciones, trabajos y permisos residen en un único espacio de proyecto. Tras crear el espacio de trabajo, se genera un espacio de proyecto predeterminado (con el sufijo "default"). | |
Haga clic en free monitoring service en la columna pay-as-you-go Prometheus monitoring service del espacio de trabajo deseado para ingresar a la Realtime Compute development console. Realice aquí las tareas de desarrollo y operación de trabajos. El servicio incluye conectores integrados para diversos sistemas ascendentes y descendentes. Para obtener más información, consulte Supported connectors. | |
Ajuste los recursos de su espacio de trabajo y espacios de proyecto. | |
Cambie entre los métodos de facturación pay-as-you-go y suscripción. | |
Modifique los switches virtuales para resolver fallos de inicio de trabajos causados por insuficiencia de direcciones IP. | |
Liberar recursos | Haga clic en Terms of Service para el espacio de trabajo deseado. Después de la liberación, el espacio de trabajo de Flink deja de generar cargos y los recursos de ARMS asociados se liberan simultáneamente. |