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:
Un proyectoAtlas
Un usuario de Atlas con el rol
Project Ownero el rolProject Stream Processing Ownerpara 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 |
|---|---|---|
Kafka Broker | Servidor configurable que recibe y almacena flujos de eventos, organizándolos en temas particionados. | Sumidero y Fuente |
Clústeres de Atlas | Servidor de MongoDB en la nube que proporciona almacenamiento permanente y Change Streamsorientados a eventos. | Sumidero y Fuente |
AWSS3 | 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, proporcionando varias herramientas integradas. | Sumidero y Fuente |
Almacenamiento de blobs de Azure | Contenedor de almacenamiento de objetos alojado en Azure. | Sólo lavabo |
Google Cloud Pub/Sub | Servicio alojado en Google Cloud compatible con la transmisión asíncrona. | Sólo lavabo |
HTTPS | Solicitud HTTPS para recuperar datos a través de un punto final de API cada vez que un documento pasa. Atlas Stream Processing utiliza entonces estos datos para enriquecer el documento que activó la solicitud. | Fuente suplementaria; debe seguir una etapa |
Conexiones de función externa | Atlas Stream Processing admite la inclusión de llamadas a recursos de AWS Lambda en su pipeline de Atlas Stream Processing. Puedes ejecutar estas llamadas de forma sincrónica o asincrónica, y puedes pasar las respuestas de llamadas sincrónicas a las siguientes etapas en tu pipeline. Para obtener más información, consulta la documentación de Atlas Stream Processing External Functions. | Activador |
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 Stream Processing especificado mediante la Atlas CLI, ejecuta 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 parámetros de los comandos anteriores, consulta la documentación de Atlas CLI para atlas streams connections list y atlas streams connections describe.
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.
Ve a la Connection Registry página.
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 enumerar todas las conexiones disponibles que utilizan mongosh, se utiliza el método sp.listConnections(). Devuelve una lista de documentos que describen cada conexión en el registro de conexiones del espacio de trabajo de Stream Processing. Tiene la siguiente sintaxis:
sp.listConnections()
Modificar una Conexión desde el Registro de Conexiones
Para modificar una conexión desde un registro de conexiones:
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 deseas modificar en la tabla, haz clic en el ícono de lápiz en la columna Actions.
Solo puede editar una conexión si actualmente no está siendo utilizada por un procesador de flujo. Si desea editar una conexión en uso, detenga primero todos los procesadores de flujo que utilicen la conexión.
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 de los comandos, consulta la documentación de Atlas CLI para atlas streams connections delete.
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 Atlas Stream Processing dentro de un proyecto especificado.
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 borrar una conexión de enlace privado configurada para Atlas Stream Processing dentro de un proyecto especificado.