MongoDB (versión 2)

El conector de MongoDB te permite realizar operaciones de inserción, eliminación, actualización y lectura en una base de datos de MongoDB.

Versiones compatibles

  • Versiones de MongoDB de la 3.6 a la 6.1
  • Mongo Atlas desplegado en Google Cloud.

Antes de empezar

Antes de usar el conector de MongoDB, haz lo siguiente:

  • En tu proyecto de Google Cloud:
    • Asegúrate de que la conectividad de red esté configurada. Para obtener información sobre los patrones de red, consulta Conectividad de red. Para obtener información sobre cómo configurar la conectividad de red para un clúster de MongoDB Atlas, consulta Conectividad privada para un clúster de MongoDB Atlas.
    • Concede el rol de gestión de identidades y accesos roles/connectors.admin al usuario que configure el conector.
    • Concede los siguientes roles de gestión de identidades y accesos a la cuenta de servicio que quieras usar para el conector:
      • roles/secretmanager.viewer
      • roles/secretmanager.secretAccessor

      Una cuenta de servicio es un tipo especial de cuenta de Google diseñada para representar a un usuario no humano que necesita autenticarse y disponer de autorización para acceder a los datos de las APIs de Google. Si no tienes una cuenta de servicio, debes crearla. El conector y la cuenta de servicio deben pertenecer al mismo proyecto. Para obtener más información, consulta el artículo Crear una cuenta de servicio.

    • Habilita los siguientes servicios:
      • secretmanager.googleapis.com (API Secret Manager)
      • connectors.googleapis.com (API Connectors)

      Para obtener información sobre cómo habilitar servicios, consulta Habilitar servicios.

      Si estos servicios o permisos no se han habilitado en tu proyecto anteriormente, se te pedirá que los habilites al configurar el conector.

    • Restringe el acceso a la red de tu clúster de Atlas con un cortafuegos:

      Para restringir el acceso de red a tu clúster de Atlas, configura el conector de MongoDB para que use un conjunto de direcciones IP estáticas para el tráfico procedente de las conexiones. Para saber cómo permitir que tu conexión se conecte a través de un cortafuegos, consulta Conectarse a una aplicación backend pública a través de un cortafuegos.

Configurar el conector

Una conexión es específica de una fuente de datos. Esto significa que, si tiene muchas fuentes de datos, debe crear una conexión independiente para cada una de ellas. Para crear una conexión, sigue estos pasos:

  1. En la consola de Cloud, ve a la página Integration Connectors > Connections (Conectores de integración > Conexiones) y, a continuación, selecciona o crea un proyecto de Google Cloud.

    Ve a la página Conexiones.

  2. Haga clic en + Crear para abrir la página Crear conexión.
  3. En la sección Ubicación, elige la ubicación de la conexión.
    1. Región: selecciona una ubicación de la lista desplegable.

      Para ver la lista de todas las regiones admitidas, consulta Ubicaciones.

    2. Haz clic en Siguiente.
  4. En la sección Detalles de la conexión, haz lo siguiente:
    1. Conector: selecciona MongoDB en la lista desplegable de conectores disponibles.
    2. Versión del conector: selecciona la versión 2 en la lista de versiones.
    3. En el campo Connection Name (Nombre de conexión), introduce un nombre para la instancia de conexión.

      Los nombres de las conexiones deben cumplir los siguientes criterios:

      • Los nombres de conexión pueden contener letras, números o guiones.
      • Las letras deben estar en minúsculas.
      • Los nombres de conexión deben empezar por una letra y terminar por una letra o un número.
      • Los nombres de conexión no pueden tener más de 49 caracteres.
    4. Si quiere, puede introducir una Descripción para la instancia de conexión.
    5. También puedes habilitar Registro en la nube y, a continuación, seleccionar un nivel de registro. De forma predeterminada, el nivel de registro es Error.
    6. Cuenta de servicio: selecciona una cuenta de servicio que tenga los roles necesarios.
    7. Si quieres, configura los ajustes del nodo de conexión:

      • Número mínimo de nodos: introduce el número mínimo de nodos de conexión.
      • Número máximo de nodos: introduce el número máximo de nodos de conexión.

      Un nodo es una unidad (o réplica) de una conexión que procesa transacciones. Se necesitan más nodos para procesar más transacciones en una conexión y, a la inversa, se necesitan menos nodos para procesar menos transacciones. Para saber cómo influyen los nodos en el precio de tu conector, consulta la sección Precios de los nodos de conexión. Si no introduces ningún valor, de forma predeterminada, el número mínimo de nodos se establece en 2 (para mejorar la disponibilidad) y el máximo en 50.

    8. Base de datos: el nombre de la base de datos de MongoDB a la que conectarse.
    9. Tiempo de espera de la conexión: especifica el tiempo en segundos que se debe esperar a que se complete una operación antes de cancelarla.
    10. Tamaño máximo del grupo de conexiones: especifica el número máximo de conexiones permitidas en el grupo de conexiones.
    11. Tamaño mínimo del grupo de conexiones: especifica el número mínimo de conexiones que se mantienen en el grupo de conexiones.
    12. Tiempo de inactividad de la conexión (en segundos): especifica el tiempo máximo de inactividad que puede tener una conexión en el grupo antes de cerrarse.
    13. Tiempo de vida de la conexión (en segundos): especifica el tiempo de vida máximo de una conexión en segundos. Una vez transcurrido este tiempo, la conexión se cierra.
    14. Usar SSL: especifica si SSL está habilitado o no.
    15. Nombre de la aplicación: nombre de la aplicación personalizada de Mongo.
    16. Max Staleness Seconds: tiempo en segundos que puede estar obsoleto un secundario antes de que el cliente deje de usarlo para las operaciones de lectura.
    17. Confirmación de escritura(opción w): opción para solicitar confirmación de que la operación de escritura se ha propagado a un número específico de instancias con etiquetas concretas.
    18. Confirmación de escritura(opción wtimeoutMS): especifica un límite de tiempo, en milisegundos, para la confirmación de escritura.
    19. Confirmación de escritura(opción de registro): solicita a MongoDB que confirme que la operación de escritura se ha registrado.
    20. Preferencia de lectura: define una estrategia para leer de un conjunto de réplicas. Los valores aceptados son primary, primaryPreferred, secondary, secondaryPreferred y nearest.
    21. Tipo de clúster: especifica el tipo de clúster de MongoDB.
    22. Habilitar cifrado: especifica si el cifrado está habilitado.
    23. Tipo de cifrado: especifica el tipo de cifrado habilitado. Actualmente, solo se admite el tipo Local Encryption.
    24. Esquema de cifrado: especifica la información del esquema de cifrado, incluidos los campos y el algoritmo de cifrado, el nombre alternativo de la clave, el tipo de consulta y el factor de contención. Por ejemplo: 
      {
  "database.collection": {
    "encryptMetadata": {
      "algorithm": "parentAlgo"
    },
    "properties": {
      "passportId": {},
      "medicalRecords": {
        "encryptMetadata": {
          "algorithm": "medicalRecordParentAlgo"
        },
        "properties": {
          "medicalRecord1": {},
          "medicalRecord2": {
            "encrypt": {
              "algorithm": "medicalRecord2Algo",
              "keyAltName": "medicalRecord2Altkey",
              "queryType": "equality",
              "contentionFactor": 3
            }
          }
        }
      },
      "insuranceProperties": {
        "properties": {
          "policyNumber": {},
          "insuranceRecord1": {
            "encrypt": {
              "algorithm": "insuranceRecord1Algo",
              "keyAltName": "insuranceRecord1AltKey"
            }
          },
          "insuranceRecord2": {
            "encrypt": {
              "algorithm": "insuranceRecord2Algo",
              "keyAltName": "insuranceRecord2AltKey",
              "contentionFactor": 5
            }
          }
        }
      }
    }
  }
}
    25. encryption_master_key: secreto de Secret Manager que contiene la clave maestra de cifrado.
    26. encryption_key_vault: valor del almacén de claves de cifrado.
    27. Base de datos de autenticación: especifica el nombre de la base de datos de MongoDB para la autenticación.
    28. También puedes hacer clic en + AÑADIR ETIQUETA para añadir una etiqueta a la conexión en forma de par clave-valor.
    29. Haz clic en SIGUIENTE.
  5. En la sección Destinations (Destinos), introduce los detalles del host remoto (sistema backend) al que quieras conectarte.
    1. Tipo de destino: puede especificar los detalles del destino como una dirección de host, que puede ser cualquiera de los siguientes:
      • Cadena SRV de Mongo única. Por ejemplo, mongodb+srv://cluster2.2f.mongodb.net
      • Réplicas individuales. Por ejemplo, dasdsf.2f.mongodb01.net
      • Dirección IP. Por ejemplo,10.23.123.12

      El prefijo mongodb:// se añadirá a la URL final después de combinar todas las réplicas de la cadena de conexión si no se especifica mongodb+srv.

      • Dirección de host: especifica el nombre de host o la dirección IP del destino.

        Si quieres establecer una conexión privada con tu backend, haz lo siguiente:

      Para introducir más destinos, haga clic en +AÑADIR DESTINO.

    2. Haz clic en SIGUIENTE.
  6. En la sección Autenticación, introduce los detalles de autenticación.
    1. Seleccione un Tipo de autenticación e introduzca los detalles pertinentes.

      La conexión de MongoDB admite los siguientes tipos de autenticación:

      • Nombre de usuario y contraseña

      2. Para saber cómo configurar estos tipos de autenticación, consulta Configurar la autenticación.

    2. Haz clic en SIGUIENTE.
  7. Revisar: revisa los detalles de la conexión y la autenticación.
  8. Haz clic en Crear.

Configurar la autenticación

Introduce los detalles en función de la autenticación que quieras usar.

  • Nombre de usuario y contraseña
    • Nombre de usuario: nombre de usuario del conector.
    • Contraseña: secreto de Secret Manager que contiene la contraseña del usuario.
    • Esquema de autenticación: el esquema usado para la autenticación.

      La conexión de MongoDB admite los siguientes esquemas de autenticación:

      • Lisos
      • SCRAM-SHA-1
      • SCRAM-SHA-256

Entidades, operaciones y acciones

Todos los conectores de integración proporcionan una capa de abstracción para los objetos de la aplicación conectada. Solo puedes acceder a los objetos de una aplicación a través de esta abstracción. La abstracción se te muestra como entidades, operaciones y acciones.

  • Entidad: una entidad se puede considerar como un objeto o un conjunto de propiedades en la aplicación o el servicio conectados. La definición de una entidad varía de un conector a otro. Por ejemplo, en un conector de base de datos, las tablas son las entidades; en un conector de servidor de archivos, las carpetas son las entidades; y en un conector de sistema de mensajería, las colas son las entidades.

    Sin embargo, es posible que un conector no admita o no tenga ninguna entidad. En ese caso, la lista Entities estará vacía.

  • Operación: una operación es la actividad que puedes realizar en una entidad. Puedes realizar cualquiera de las siguientes operaciones en una entidad:

    Al seleccionar una entidad de la lista disponible, se genera una lista de operaciones disponibles para la entidad. Para ver una descripción detallada de las operaciones, consulta las operaciones de entidades de la tarea Connectors. Sin embargo, si un conector no admite ninguna de las operaciones de entidad, esas operaciones no admitidas no se mostrarán en la lista Operations.

  • Acción: una acción es una función de primera clase que se pone a disposición de la integración a través de la interfaz del conector. Una acción te permite hacer cambios en una o varias entidades y varía de un conector a otro. Normalmente, una acción tendrá algunos parámetros de entrada y un parámetro de salida. Sin embargo, es posible que un conector no admita ninguna acción, en cuyo caso la lista Actions estará vacía.

Limitaciones del sistema

El conector de MongoDB puede procesar un máximo de 70 transacciones por segundo por nodo y limita las transacciones que superen este límite. De forma predeterminada, Integration Connectors asigna 2 nodos (para mejorar la disponibilidad) a una conexión.

Para obtener información sobre los límites aplicables a Integration Connectors, consulta Límites.

Tipos de datos admitidos

Estos son los tipos de datos admitidos por este conector:

  • BIGINT
  • BINARY
  • BIT
  • BOOLEAN
  • CHAR
  • FECHA
  • DECIMAL
  • DOUBLE
  • FLOAT
  • INTEGER
  • LONGN VARCHAR
  • LONG VARCHAR
  • NCHAR
  • NUMERIC
  • NVARCHAR
  • REAL
  • SMALL INT
  • HORA
  • TIMESTAMP
  • TINY INT
  • VARBINARY
  • VARCHAR

Configuración del clúster de MongoDB Atlas

La configuración de autenticación de un clúster de MongoDB Atlas difiere ligeramente de los pasos documentados anteriormente. Para autenticarte en un clúster de Atlas, primero debes obtener la cadena de conexión de Atlas. Para obtener la cadena de conexión de Atlas, sigue estos pasos:

  1. En la vista Clústeres, haga clic en Conectar en el clúster al que quiera conectarse.
  2. Haz clic en Conectar tu aplicación.
  3. Selecciona una de las opciones de controlador para mostrar una cadena de conexión.

Para autenticarte en un clúster de Atlas, usa la siguiente configuración:

  • Base de datos de autenticación: asigna el valor admin, ya que todos los usuarios de MongoDB Atlas están asociados a la base de datos admin.
  • Usar SSL: asigna el valor true.
  • Servidor: asigna el valor mongodb+srv://MongoDB INSTANCE SERVER NAME sin incluir el nombre de usuario ni la contraseña.

Acciones

En esta sección se enumeran todas las acciones admitidas por la conexión de MongoDB.

Acción AggregatePipeline

Esta acción agrega los cambios de la canalización en una colección.

Parámetros de entrada de la acción AggregatePipeline

Nombre del parámetro Tipo de datos Obligatorio Descripción
colección Cadena Sí Nombre de la colección de MongoDB.
flujo de procesamiento Cadena Sí Pipeline de agregación que contiene fases de campo como una lista de cadenas.
page_size Entero No Número de elementos que se incluirán en cada página del conjunto de resultados.
page_no Entero No Índice de la página que se va a obtener del conjunto de resultados. El índice empieza por 0.

Para ver un ejemplo de cómo configurar la acción AggregatePipeline, consulta Ejemplos.

Acción CountDocuments

Esta acción cuenta todos los documentos que cumplen una condición determinada en una colección.

Parámetros de entrada de la acción CountDocuments

Nombre del parámetro Tipo de datos Obligatorio Descripción
colección Cadena Sí Nombre de la colección de MongoDB.
filtrar Cadena No Condición de filtro expresada en formato de consulta de MongoDB. Esta condición puede contener campos cifrados si el esquema de cifrado está habilitado para la igualdad de querytype.

Parámetros de salida de la acción CountDocuments

Esta acción devuelve el número de todos los documentos que cumplen una condición determinada.

Para ver un ejemplo de cómo configurar la acción CountDocuments, consulta Ejemplos.

Acción DeleteDocuments

Esta acción elimina documentos de una colección.

Parámetros de entrada de la acción DeleteDocuments

Nombre del parámetro Tipo de datos Obligatorio Descripción
colección Cadena Sí Nombre de la colección de MongoDB.
filtrar Cadena No Condición de filtro expresada en formato de consulta de MongoDB. Esta condición puede contener campos cifrados si el esquema de cifrado está habilitado para la igualdad de tipo de consulta.

Parámetros de salida de la acción DeleteDocuments

La acción devuelve el número de documentos que se han eliminado.

Para ver un ejemplo de cómo configurar la acción DeleteDocuments, consulta Ejemplos.

Acción DistinctValues

Esta acción devuelve los valores distintos de un campo de una colección.

Parámetros de entrada de la acción DistinctValues

Nombre del parámetro Tipo de datos Obligatorio Descripción
colección Cadena Sí Nombre de la colección de MongoDB.
campo Cadena Sí Nombre del campo para consultar valores distintos.
filtrar Cadena No Condición de filtro expresada en formato de consulta de MongoDB. Esta condición puede contener campos cifrados si el esquema de cifrado está habilitado para la igualdad de querytype.

Para ver un ejemplo de cómo configurar la acción DistinctValues, consulta Ejemplos.

Acción InsertDocument

Esta acción inserta un documento en una colección.

En las siguientes tablas se describen los parámetros de entrada y salida de la acción InsertDocument.

Parámetros de entrada de la acción InsertDocument

Nombre del parámetro Tipo de datos Obligatorio Descripción
colección Cadena Sí Nombre de la colección de MongoDB.
documento Cadena No Documento que se va a añadir a una colección de MongoDB.

Parámetros de salida de la acción InsertDocument

Esta acción devuelve el ID del documento insertado.

Para ver un ejemplo de cómo configurar la acción InsertDocument, consulta Ejemplos.

Acción ListDocuments

En las siguientes tablas se describen los parámetros de entrada y salida de la acción ListDocuments.

Parámetros de entrada de la acción ListDocuments

Nombre del parámetro Tipo de datos Obligatorio Descripción
colección Cadena Sí Nombre de la colección de MongoDB.
filtrar Cadena No Condición de filtro expresada en formato de consulta de MongoDB. Esta condición puede contener campos cifrados si el esquema de cifrado está habilitado para la igualdad de querytype.
page_size Entero No Número de elementos que se incluirán en cada página del conjunto de resultados.
page_no Entero No Índice de la página que se va a obtener del conjunto de resultados. El índice empieza por 0.
proyección Cadena No Conjunto de campos o propiedades que se incluirán en la proyección de la consulta en formato Mongo.
sort_by Cadena No Especificación del orden de los resultados de la consulta mediante el formato JSON binario (BSON) de MongoDB.

Parámetros de salida de la acción ListDocuments

La acción devuelve la lista de documentos que cumplen la condición del filtro según el tamaño de página. El tamaño de página predeterminado es 25 y el máximo es 50.000.

Para ver un ejemplo de cómo configurar la acción ListDocuments, consulta Ejemplos.

Acción UpdateDocuments

En las siguientes tablas se describen los parámetros de entrada y salida de la acción UpdateDocuments.

Parámetros de entrada de la acción UpdateDocuments

Nombre del parámetro Tipo de datos Obligatorio Descripción
colección Cadena Sí Nombre de la colección de MongoDB.
valores Cadena No Valores que se van a actualizar en formato de MongoDB.
filtrar Cadena No Condición de filtro expresada en formato de consulta de MongoDB. Esta condición puede contener campos cifrados si el esquema de cifrado está habilitado para la igualdad de tipo de consulta.
Upsert Booleano No Si la operación es upsert o no.

Parámetros de salida de la acción UpdateDocuments

La acción devuelve el número de documentos que se han actualizado.

Para ver un ejemplo de cómo configurar la acción UpdateDocuments, consulta Ejemplos.

Acción UpdateDocumentsWithEncryption

Esta acción permite al usuario actualizar los valores cifrados.En las siguientes tablas se describen los parámetros de entrada y salida de la acción UpdateDocumentsWithEncryption.

Parámetros de entrada de la acción UpdateDocumentsWithEncryption

Nombre del parámetro Tipo de datos Obligatorio Descripción
colección Cadena Sí Nombre de la colección de MongoDB.
documento Cadena No Documento que contiene los valores que se van a actualizar. Los valores pueden contener campos que se cifrarán mediante CSFLE.
filtrar Cadena No Condición de filtro expresada en formato de consulta de MongoDB. Esta condición puede contener campos cifrados si el esquema de cifrado está habilitado para la igualdad de querytype.
Upsert Booleano No Especifica si la operación es upsert.

Parámetros de salida de la acción UpdateDocumentsWithEncryption

La acción devuelve el número de documentos que se han actualizado.

Para ver un ejemplo de cómo configurar la acción UpdateDocumentsWithEncryption, consulta Ejemplos.

Ejemplos

En esta sección se describe cómo realizar algunas de las operaciones y acciones de entidades en este conector.

Ejemplo: agregar cambios de la canalización

  1. En el cuadro de diálogo Configure connector task, haz clic en Actions.
  2. Seleccione la acción AggregatePipeline y, a continuación, haga clic en Hecho.
  3. En la sección Entrada de tarea de la tarea Conectores, haz clic en connectorInputPayload y, a continuación, introduce un valor similar al siguiente en el campo Default Value: 
    {
  "collection": "restaurants",
  "pipeline": {
    "stages": [
      "{$addFields: { \"new_menu_item\": \"tea\"}}"
    ]
  },
  "page_size": 1,
  "page_no": 0
}

    4. En este ejemplo se añade un nuevo elemento de menú a todos los documentos de la colección restaurant y se devuelve la primera página del resultado.

Ejemplo: contar documentos

  1. En el cuadro de diálogo Configure connector task, haz clic en Actions.
  2. Seleccione la acción CountDocuments y, a continuación, haga clic en Hecho.
  3. En la sección Entrada de tarea de la tarea Conectores, haz clic en connectorInputPayload y, a continuación, introduce un valor similar al siguiente en el campo Default Value: 
    {
"collection":"restaurants",
"filter": "{\"name\": \"CarvelIceCream1\"}"
}

    4. En este ejemplo se devuelve el número de documentos que coinciden con los criterios del filtro. Si la acción se realiza correctamente, el parámetro de respuesta Connectors de la tarea connectorOutputPayload tendrá un valor similar al siguiente:

    {
  "results": [
   {
    "count": 5
   }
  ]
}

Ejemplo: eliminar documentos

  1. En el cuadro de diálogo Configure connector task, haz clic en Actions.
  2. Seleccione la acción DeleteDocuments y, a continuación, haga clic en Hecho.
  3. En la sección Entrada de tarea de la tarea Conectores, haga clic en connectorInputPayload y, a continuación, introduzca lo siguiente en el campo Default Value: 
    {
  "collection": "Insurancedocuments",
  "filter": "{\"insurance.provider\":\"ABC\"}"}

    4. En este ejemplo se eliminan todos los documentos cuyo proveedor de seguros sea ABC.

Ejemplo: buscar valores distintos en una colección

  1. En el cuadro de diálogo Configure connector task, haz clic en Actions.
  2. Seleccione la acción DistinctValues y, a continuación, haga clic en Hecho.
  3. En la sección Entrada de tarea de la tarea Conectores, haz clic en connectorInputPayload y, a continuación, introduce un valor similar al siguiente en el campo Default Value: 
    {"collection":"restaurants","field":"contact"}

    4. En este ejemplo se devuelven los valores distintos de la colección restaurants. Si la acción se realiza correctamente, el parámetro de respuesta Connectors de la tarea connectorOutputPayload tendrá un valor similar al siguiente:

    {
 "results": [
  {
   "DistinctValues": [
    "3217902323",
    "8747479023",
    "3492619023"
   ]
  }
 ]
}

Ejemplo: insertar un documento

  1. En el cuadro de diálogo Configure connector task, haz clic en Actions.
  2. Seleccione la acción InsertDocument y, a continuación, haga clic en Hecho.
  3. En la sección Entrada de tarea de la tarea Conectores, haz clic en connectorInputPayload y, a continuación, introduce un valor similar al siguiente en el campo Default Value: 
    { {
"collection": "Insurancedocuments",
"document": "{\"fname\":\"firstName\",
\"lname\":\"lastName\",
\"passportId\":\"ABCD1234\",
\"bloodType\":\"A\",
\"medicalRecords\":[{\"item\":\"name1\"},{\"item\":\"name2\"}],
\"insurance\":{\"policyNumber\":\"12345\",\"provider\":\"provider2\"}}"
} }

    4. En este ejemplo se inserta un documento en la colección Insurancedocuments. El contenido del documento se especifica en el campo document. Si la inserción se realiza correctamente, obtendrás el ID del documento insertado en el parámetro de respuesta connectorOutputPayload de la tarea Connectors.

Ejemplo: listar documentos

  1. En el cuadro de diálogo Configure connector task, haz clic en Actions.
  2. Seleccione la acción ListDocuments y, a continuación, haga clic en Hecho.
  3. En la sección Entrada de tarea de la tarea Conectores, haz clic en connectorInputPayload y, a continuación, introduce un valor similar al siguiente en el campo Default Value: 
    {
"collection": "Insurancedocuments",
"filter": "{\"insurance.provider\":\"ABC\"}",
"page_size": 10
}

    4. Este ejemplo devuelve documentos de la colección Insurancedocuments en los que el proveedor del seguro es ABC. El tamaño de página del conjunto de resultados se ha definido en 10 y la lista de archivos estará disponible en formato JSON en el parámetro de respuesta connectorOutputPayload de la tarea Connectors.

Ejemplo: actualizar documentos

  1. En el cuadro de diálogo Configure connector task, haz clic en Actions.
  2. Seleccione la acción UpdateDocuments y, a continuación, haga clic en Hecho.
  3. En la sección Entrada de tarea de la tarea Conectores, haz clic en connectorInputPayload y, a continuación, introduce un valor similar al siguiente en el campo Default Value: 
    {"collection":"Insurancedocuments",
"values":" {$set: { lname:\"Smith\" }}",
"filter":"{\"insurance.provider\":\"ABC\"}"}

    4. En este ejemplo, se cambia el apellido a Smith en los documentos que coinciden con los criterios del filtro. Si la actualización se realiza correctamente, obtendrá el número de documentos que se han actualizado. La respuesta estará disponible en el parámetro de respuesta connectorOutputPayload de la tarea Connectors.

Ejemplo: actualizar documentos con cifrado

  1. En el cuadro de diálogo Configure connector task, haz clic en Actions.
  2. Seleccione la acción UpdateDocumentsWithEncryption y, a continuación, haga clic en Hecho.
  3. En la sección Entrada de tarea de la tarea Conectores, haga clic en connectorInputPayload y, a continuación, introduzca lo siguiente en el campo Default Value: 
    { {"collection":"Insurancedocuments",
"document":" { \"insurance.provider\":\"XYZ\" }",
"filter":"{\"insurance.provider\":\"ABC\"}"}

    4. En este ejemplo, se actualiza el proveedor de seguros a XYZ en todos los documentos en los que el proveedor de seguros es ABC.

Crear conexiones con Terraform

Puedes usar el recurso de Terraform para crear una conexión.

Para saber cómo aplicar o quitar una configuración de Terraform, consulta Comandos básicos de Terraform.

Para ver una plantilla de Terraform de ejemplo para crear una conexión, consulta la plantilla de ejemplo.

Cuando crees esta conexión con Terraform, debes definir las siguientes variables en el archivo de configuración de Terraform:

Nombre del parámetro Tipo de datos Obligatorio Descripción
base de datos STRING Verdadero Nombre de la base de datos de MongoDB.
Tiempo de espera INTEGER Falso Tiempo de espera de conexión en segundos.
enable_ssl BOOLEAN Falso Este campo indica si SSL está habilitado.
app_name STRING Falso Nombre de aplicación personalizado para MongoDB.
max_staleness_seconds INTEGER Falso Tiempo en segundos que puede estar obsoleto un secundario antes de que el cliente deje de usarlo para las operaciones de lectura.
write_concern STRING Falso Opción para solicitar una confirmación de que la operación de escritura se ha propagado a un número específico de instancias con etiquetas concretas.
write_concern_timeout INTEGER Falso Especifica un límite de tiempo, en milisegundos, para la confirmación de escritura.
write_concern_journal BOOLEAN Falso Solicita a MongoDB que confirme que la operación de escritura se ha escrito en el registro.
read_preference ENUM Falso Leer las preferencias de esta conexión. Los valores admitidos son: primary, primaryPreferred, secondary, secondaryPreferred y nearest.
cluster_type ENUM Falso Especifica el tipo de clúster de MongoDB. Los valores admitidos son REPLICA_SET, STANDALONE, SHARDED y UNKNOWN.
enable_encryption BOOLEAN Falso Este campo indica si el cifrado está habilitado.
encryption_type ENUM Falso En este campo se define el tipo de cifrado habilitado. Los valores admitidos son: local
encryption_schema STRING Falso Información del esquema de cifrado, incluidos los campos y el algoritmo de cifrado utilizados.
encryption_master_key SECRET Falso Secreto de Secret Manager que contiene la clave maestra de cifrado.
encryption_key_vault STRING Falso Valor de Encryption Key Vault.
auth_database STRING Verdadero Nombre de la base de datos de MongoDB para la autenticación.

Usar la conexión de MongoDB en una integración

Una vez que hayas creado la conexión, estará disponible tanto en Apigee Integration como en Application Integration. Puedes usar la conexión en una integración a través de la tarea Conectores.

  • Para saber cómo crear y usar la tarea Conectores en la integración de Apigee, consulta Tarea Conectores.
  • Para saber cómo crear y usar la tarea Conectores en Application Integration, consulta Tarea Conectores.

Obtener ayuda de la comunidad de Google Cloud

Puedes publicar tus preguntas y hablar sobre este conector en la comunidad de Google Cloud, en los foros de Cloud.

Siguientes pasos