Cada Espacio de Trabajo de Procesamiento de Flujos almacena cada conexión configurada con una fuente o sumidero de datos de transmisión en su registro de conexiones. Los procedimientos de esta página te guían para crear y configurar tus conexiones de Atlas Stream Processing.
Requisitos previos
Para crear y configurar conexiones, debes disponer de lo siguiente:
An Atlas Proyecto
Un Atlas user con el
Project Ownero elProject Stream Processing Ownerrol para administrar un registro de conexionesNota
Aunque tanto
Project OwnercomoProject Stream Processing Ownerotorgan los privilegios para crear, ver, editar y borrar conexiones en el registro de conexiones, el rolProject Ownertambién permite a los usuarios realizar tareas como crear implementaciones de la base de datos, gestionar el acceso a Proyectos y mucho más.Consulta Roles del Proyecto para aprender más sobre las diferencias entre estos roles.
Un clúster Atlas
Considerations
Al configurar 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 (Ver nota) | 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 de Atlas | Servidor de MongoDB alojado en la nube que proporciona tanto almacenamiento permanente como basado en eventos Cambiar corrientes. | Sumidero y Fuente |
AWS S3 | Contenedor de almacenamiento de objetos alojado en AWS. | Sólo 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 suplementaria; debe seguir una etapa |
Conexiones de función externa | 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, consulta la documentación de Atlas Stream Processing External Functions. | Desencadenar |
Nota
No puedes usar colecciones de series temporales como fuente de Atlas Stream Processing. Los conjuntos de datos de series temporales no aceptan flujos de cambios.
Tip
Consulta Limitaciones de la colección de series de tiempo para obtener más información.
Añadir una Conexión al Registro de Conexiones
Cada tipo de conexión de Atlas Stream Processing tiene requisitos y procedimientos de configuración específicos. Para saber más, consulta Agregar una conexión de procesamiento de streams de Atlas.
Ver conexiones en el registro de conexiones
Para ver una conexión a tu espacio de trabajo de stream processing:
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 retornar los detalles de una conexión de procesamiento de streams que especifiques usando la CLI de Atlas, ejecutar 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, ve a Stream Processing página para 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 Stream Processing.
Ir a la página Connection Registry.
Localiza el panel de descripción general del espacio de trabajo de Stream Processing que contiene el registro de conexiones que deseas visualizar.
Haga clic en Manage.
Selecciona la pestaña Connection Registry.
Atlas Stream Processing muestra todas las conexiones disponibles en el registro de conexiones de tu 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 Conexiones
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 Stream Processing que especifiques usando la Atlas CLI, ejecuta el siguiente comando:
atlas streams connections update <connectionName> [options]
Para obtener más información sobre la sintaxis del comando y los parámetros, consulta la documentación de Atlas CLI para atlas streams connections actualizar.
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 Stream Processing.
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.
Modifica los campos que desees modificar.
Haga clic en Save changes.
La API de administración de Atlas proporciona un endpoint para editar un espacio de trabajo de stream processing.
Borrar una conexión del registro de conexiones
Para borrar una conexión de un registro de conexiones:
Para remover una conexión del espacio de trabajo de Stream Processing que especifique utilizando Atlas CLI, 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 Stream Processing.
La API de administración de Atlas proporciona un endpoint para editar un espacio de trabajo de stream processing.
Probar una conexión desde el registro de conexiones
Para verificar que una conexión desde un registro de conexiones esté funcionando correctamente en la interfaz de usuario 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 Stream Processing.
Probar la conexión.
Para la conexión que desea probar en la tabla, haga clic en el icono de enlace en la columna Actions de esa entrada.
Para las conexiones a la base de datos Atlas, ingrese el Database Name y el Collection Name para probar la conexión a una base de datos y colección específicas.
Para las conexiones de Kafka, introduce el Topic Name para probar la conexión a un tema específico.
Para otros tipos de conexión, no se necesita información adicional.
Haga clic en Test Connection.
Lista de conexiones de enlace privadas
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 endpoint para ver los detalles de una conexión privada configurada para Atlas Stream Processing dentro de un proyecto especificado.
Borrar 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.