Cada espacio de trabajo de procesamiento de flujos almacena en su registro de conexiones todas las conexiones configuradas a una fuente o receptor de datos de flujos. Los procedimientos de esta página le guiarán en la creación y configuración de sus conexiones de procesamiento de flujos de Atlas.
Requisitos previos
Para crear y configurar conexiones, debe tener lo siguiente:
Un atlas Proyecto
Un usuario de Atlas con el
Project Ownero el rol para administrar un registro deProject Stream Processing OwnerconexiónNota
Si bien los
Project Ownerroles y otorgan privilegios para crear, ver, editar yProject Stream Processing OwnerProject Ownereliminar conexiones en el registro de conexiones, el rol también permite a los usuarios realizar tareas como crear implementaciones de bases de datos, administrar el acceso al proyecto y más.Consulte Roles del proyecto para obtener más información sobre las diferencias entre estos roles.
Un grupo Atlas
Considerations
Al configurar las conexiones de Atlas Stream Processing, asegúrese de seleccionar un tipo de conexión adecuado para su caso de uso. Atlas Stream Processing es compatible con los siguientes proveedores:
Proveedor (Vernota) | Descripción | Tipos de conexión |
|---|---|---|
Corredor de Kafka | Servidor configurable que recibe y almacena flujos de eventos, organizándolos en temas particionados. | Sumidero y fuente |
Clústeres Atlas | Servidor MongoDB alojado en la nube que proporciona almacenamiento permanente y basado en eventos. Cambiar corrientes. | Sumidero y fuente |
AWS S3 | Contenedor de almacenamiento de objetos alojado en AWS. | Solo lavabo |
AWS Kinesis | Plataforma alojada en la nube que recibe y almacena flujos de eventos y proporciona diversas herramientas integradas. | Sumidero y fuente |
HTTPS | Solicitud HTTPS para recuperar datos a través de un punto final de API cada vez que se procesa un documento. Atlas Stream Processing utiliza estos datos para enriquecer el documento que activó la solicitud. | Fuente complementaria; debe seguir una |
Conexiones de funciones externas | Atlas Stream Processing permite integrar llamadas a recursos de AWS Lambda en su pipeline de Atlas Stream Processing. Puede ejecutar estas llamadas de forma síncrona o asíncrona, y transferir las respuestas de las llamadas síncronas a las etapas posteriores de su pipeline. Para obtener más información, consulte la documentación de Funciones externas de procesamiento de secuencias de Atlas. | Desencadenar |
Nota
No se pueden utilizar colecciones de series temporales como fuente para el procesamiento de flujos de Atlas. Estas colecciones no admiten flujos de cambios.
Agregar una conexión al registro de conexiones
Cada tipo de conexión de Atlas Stream Processing tiene requisitos y procedimientos de configuración distintos. Para obtener más información,consulte Agregar una conexión de Atlas Stream Processing.
Ver conexiones en el Registro de conexiones
Para ver una conexión a su espacio de trabajo de procesamiento de flujo:
Para enumerar todas las conexiones de un espacio de trabajo de procesamiento de flujo que especifique mediante la CLI de Atlas, ejecute el siguiente comando:
atlas streams connections list [options]
Para devolver los detalles de una conexión de procesamiento de flujo que especifique mediante la CLI de Atlas, ejecute el siguiente comando:
atlas streams connections describe <streamConnectionName> [options]
Para obtener más información sobre la sintaxis y los parámetros de los comandos anteriores, consulte la documentación de Atlas CLI para obtener la lista de conexiones de flujos de Atlas y la descripción de las conexiones de flujos de Atlas.
En Atlas, vaya a la Stream Processing Página para su proyecto.
Si aún no aparece, se debe seleccionar la organización que contiene el proyecto en el menú Organizations de la barra de navegación.
Si aún no se muestra, seleccione su proyecto en el menú Projects de la barra de navegación.
En la barra lateral, haz clic en Stream Processing en la sección Streaming Data.
Se muestra la página Procesamiento de transmisión.
Ir a la página Connection Registry.
Localice el panel de descripción general del espacio de trabajo de procesamiento de flujo que contiene el registro de conexión que desea ver.
Haga clic en Configure.
Seleccione la pestaña Connection Registry.
Atlas Stream Processing muestra todas las conexiones disponibles en el registro de conexión de su instancia.
La API de administración de Atlas proporciona diferentes puntos finales para recuperar una o todas las conexiones en un registro de conexiones.
Para listar todas las conexiones disponibles usando mongosh, utilice el método sp.listConnections(). Este método devuelve una lista de documentos que describen cada conexión en el registro de conexiones del espacio de trabajo de procesamiento de flujos. Tiene la siguiente sintaxis:
sp.listConnections()
Modificar una conexión desde el Registro de conexión
Para modificar una conexión desde un registro de conexión:
Para modificar los detalles de una conexión en el espacio de trabajo de procesamiento de flujo que especifique mediante la CLI de Atlas, ejecute el siguiente comando:
atlas streams connections update <connectionName> [options]
Para obtener más información sobre la sintaxis y los parámetros del comando, consulte la documentación de la CLI de Atlas para la actualización de conexiones de flujos de Atlas.
En Atlas, ve a la página Stream Processing de tu proyecto.
Si aún no aparece, se debe seleccionar la organización que contiene el proyecto en el menú Organizations de la barra de navegación.
Si aún no se muestra, seleccione su proyecto en el menú Projects de la barra de navegación.
En la barra lateral, haz clic en Stream Processing en la sección Streaming Data.
Se muestra la página Procesamiento de transmisión.
Seleccione la Connection Registry pestaña.
Modificar la conexión.
Para la conexión que desea modificar en la tabla, haga clic en el ícono de lápiz en la columna Actions.
Solo puede editar una conexión si no está siendo utilizada por ningún procesador de flujo. Si desea editar una conexión en uso, detenga primero todos los procesadores de flujo que la utilicen.
Modifique los campos que desee modificar.
Haga clic en Save changes.
La API de administración de Atlas proporciona un punto final para editar un espacio de trabajo de procesamiento de flujo.
Eliminar una conexión del Registro de conexiones
Para eliminar una conexión de un registro de conexión:
Para eliminar una conexión del espacio de trabajo de procesamiento de flujo que especifique mediante la CLI de Atlas, ejecute el siguiente comando:
atlas streams connections delete <connectionName> [options]
Para obtener más información sobre la sintaxis y los parámetros del comando, consulte la documentación de Atlas CLI para eliminar conexiones de flujos de Atlas.
En Atlas, ve a la página Stream Processing de tu proyecto.
Si aún no aparece, se debe seleccionar la organización que contiene el proyecto en el menú Organizations de la barra de navegación.
Si aún no se muestra, seleccione su proyecto en el menú Projects de la barra de navegación.
En la barra lateral, haz clic en Stream Processing en la sección Streaming Data.
Se muestra la página Procesamiento de transmisión.
La API de administración de Atlas proporciona un punto final para editar un espacio de trabajo de procesamiento de flujo.
Lista de conexiones de enlaces privados
La API de administración de Atlas proporciona un punto final para ver todas las conexiones de enlace privado configuradas para el procesamiento de flujo de Atlas dentro de un proyecto específico.
Ver una conexión de enlace privado
La API de administración de Atlas proporciona un punto final para ver los detalles de una conexión de enlace privado configurada para el procesamiento de flujo de Atlas dentro de un proyecto específico.
Eliminar una conexión de enlace privado
La API de administración de Atlas proporciona un punto final para eliminar una conexión de enlace privado configurada para el procesamiento de flujo de Atlas dentro de un proyecto específico.