MongoDB (version 2)

Le connecteur MongoDB permet d'effectuer des opérations d'insertion, de suppression, de mise à jour et de lecture sur une base de données MongoDB.

Versions compatibles

MongoDB versions 3.6 à 6.1
Mongo Atlas déployé sur Google Cloud

Avant de commencer

Avant d'utiliser le connecteur MongoDB, effectuez les tâches suivantes :

Dans votre projet Google Cloud :
- Assurez-vous que la connectivité réseau est configurée. Pour en savoir plus sur les schémas de réseau, consultez Connectivité réseau. Pour savoir comment configurer la connectivité réseau pour un cluster MongoDB Atlas, consultez Connectivité privée pour un cluster MongoDB Atlas.
- Attribuez le rôle IAM roles/connectors.admin à l'utilisateur qui configure le connecteur.
- Attribuez les rôles IAM suivants au compte de service que vous souhaitez utiliser pour le connecteur :
  - roles/secretmanager.viewer
  - roles/secretmanager.secretAccessor
  Un compte de service est un type spécial de compte Google destiné à représenter un utilisateur non humain qui doit s'authentifier et obtenir les autorisations permettant d'accéder aux données des API Google. Si vous ne possédez pas de compte de service, vous devez en créer un. Pour plus d'informations, consultez Créer un compte de service.
- Activez les services suivants :
  - secretmanager.googleapis.com (API Secret Manager)
  - connectors.googleapis.com (API Connectors)
  Pour savoir comment activer des services, consultez Activer des services.
Si ces services ou autorisations n'ont pas encore été activés pour votre projet, vous êtes invité à les activer au moment de configurer le connecteur.

Configurer le connecteur

Une connexion est propre à une source de données. Cela signifie que si vous disposez de nombreuses sources de données, vous devez créer une connexion distincte pour chacune d'elles. Pour créer une connexion, procédez comme suit :

Dans la console Cloud, accédez à la page Connecteurs d'intégration > Connexions, puis sélectionnez ou créez un projet Google Cloud.
Accéder à la page "Connexions"
Cliquez sur + Créer pour ouvrir la page Créer une connexion.
Dans la section Emplacement, choisissez l'emplacement de la connexion.
1. Région : sélectionnez un emplacement dans la liste déroulante.
  Pour obtenir la liste de toutes les régions disponibles, consultez Emplacements.
2. Cliquez sur Suivant.
Dans la section Détails de connexion, procédez comme suit :
1. Connecteur : sélectionnez MongoDB dans la liste déroulante des connecteurs disponibles.
2. Version du connecteur : sélectionnez la version 2 dans la liste des versions.
3. Dans le champ Nom de connexion, indiquez le nom de l'instance de connexion.
  Les noms de connexion doivent répondre aux critères suivants :
  - Ils peuvent contenir des lettres, des chiffres ou des traits d'union.
  - Les lettres doivent être en minuscules.
  - Ils doivent commencer par une lettre et se terminer par une lettre ou un chiffre.
  - Ils ne peuvent pas dépasser 49 caractères.
4. (Facultatif) Saisissez une description de l'instance de connexion.
5. (Facultatif) Activez Cloud Logging, puis sélectionnez un niveau de journalisation. Par défaut, le niveau de journalisation est défini sur Error.
6. Compte de service : sélectionnez un compte de service disposant des rôles requis.
7. (Facultatif) Configurez les paramètres de nœuds de connexion :
  - Nombre minimal de nœuds : saisissez le nombre minimal de nœuds de connexion.
  - Nombre maximal de nœuds : saisissez le nombre maximal de nœuds de connexion.
  Un nœud est une unité (ou instance répliquée) de connexion qui traite des transactions. Pour traiter davantage de transactions pour une connexion, vous devez disposer de plus de nœuds. À l'inverse, moins de nœuds sont nécessaires si une connexion traite moins de transactions. Pour comprendre comment les nœuds affectent la tarification de votre connecteur, consultez Tarifs des nœuds de connexion. Si vous ne saisissez aucune valeur, le nombre minimal de nœuds est défini par défaut sur 2 (pour améliorer la disponibilité) et le nombre maximal de nœuds sur 50.
8. Base de données : nom de la base de données MongoDB à laquelle vous devez vous connecter.
9. Délai d'inactivité de la connexion : spécifiez le délai d'attente en secondes pour qu'une opération soit terminée avant de l'annuler.
10. Taille maximale du pool de connexions : spécifiez le nombre maximal de connexions autorisées dans le pool de connexions.
11. Taille minimale du pool de connexions : spécifiez le nombre minimal de connexions maintenues dans le pool de connexions.
12. Durée d'inactivité de la connexion en secondes : spécifiez la durée maximale d'inactivité en secondes pendant laquelle une connexion peut exister dans le pool avant d'être fermée.
13. Durée de vie de la connexion en secondes : spécifiez la durée de vie maximale d'une connexion en secondes. Passé ce délai, la connexion est fermée.
14. Connexion SSL : indique si SSL est activé ou non.
15. Nom de l'application : nom de l'application personnalisée pour Mongo.
16. Obsolescence maximale en secondes : durée en secondes pendant laquelle une connexion secondaire peut être obsolète avant que le client cesse de l'utiliser pour les opérations de lecture.
17. WriteConcern (option "w") : option permettant de demander confirmation que l'opération d'écriture a été propagée à un nombre donné d'instances avec des tags spécifiés.
18. WriteConcern (option "wtimeoutMS") : option permettant de spécifier une limite de temps, en millisecondes, pour le niveau de durabilité des écritures.
19. WriteConcern (option "journal") : option permettant de demander à MongoDB de confirmer que l'opération d'écriture a été écrite dans le journal.
20. Préférences de lecture : définissez cette option sur une stratégie de lecture à partir d'un ensemble d'instances répliquées. Les valeurs acceptées sont "primary", "primaryPreferred", "secondary", "secondaryPreferred" et "nearest".
21. Type de cluster : spécifiez le type de cluster MongoDB.
22. Activer le chiffrement : indiquez si le chiffrement est activé.
23. Type de chiffrement : spécifiez le type de chiffrement activé. Pour le moment, seul le type Local Encryption est pris en charge.
24. Schéma de chiffrement : spécifiez les informations du schéma de chiffrement, y compris les champs et l'algorithme de chiffrement, le nom alternatif de la clé, le type de requête et le facteur de contention. Exemple :
```
{
  "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 : secret Secret Manager contenant la clé principale de chiffrement.
26. encryption_key_vault : valeur du coffre de clés de chiffrement.
27. Base de données d'authentification : spécifiez le nom de la base de données MongoDB pour l'authentification.
28. (Facultatif) Cliquez sur + AJOUTER UNE ÉTIQUETTE pour ajouter une étiquette à la connexion sous la forme d'une paire clé/valeur.
29. Cliquez sur SUIVANT.
Dans la section Destinations, saisissez des informations sur l'hôte distant (système backend) auquel vous souhaitez vous connecter.
1. Type de destination : vous pouvez spécifier les détails de destination sous la forme d'une adresse hôte, qui peut être l'une des suivantes :
  - Chaîne SRV Mongo unique (exemple : mongodb+srv://cluster2.2f.mongodb.net)
  - Instances répliquées individuelles (exemple : dasdsf.2f.mongodb01.net)
  - Adresse IP. (exemple : 10.23.123.12)
  Le préfixe mongodb:// est ajouté à l'URL finale une fois que toutes les instances répliquées sont combinées dans la chaîne de connexion si mongodb+srv n'est pas spécifié.
  - Adresse de l'hôte : spécifiez le nom d'hôte ou l'adresse IP de la destination.
    Si vous souhaitez établir une connexion privée à votre backend, procédez comme suit :
    - Créez un rattachement de service PSC.
    - Créez un rattachement de point de terminaison, puis saisissez les détails du rattachement de point de terminaison dans le champ Adresse de l'hôte.
    Remarque : Si vous souhaitez vous connecter à un cluster MongoDB Atlas exécuté sur un réseau privé dans Google Cloud, consultez Connectivité privée pour un cluster Atlas.
  Pour saisir d'autres destinations, cliquez sur + AJOUTER UNE DESTINATION.
2. Cliquez sur SUIVANT.
Dans la section Authentification, saisissez les informations d'authentification.
1. Sélectionnez un type d'authentification, puis saisissez les informations appropriées.
  Les types d'authentification suivants sont compatibles avec la connexion MongoDB :
  - Nom d'utilisateur et mot de passe
2. Cliquez sur SUIVANT.
Vérifier : vérifiez vos informations de connexion et d'authentification.
Cliquez sur Créer.

Configurer l'authentification

Saisissez les informations en fonction de l'authentification que vous souhaitez utiliser.

Nom d'utilisateur et mot de passe
- Nom d'utilisateur : nom d'utilisateur pour le connecteur
- Mot de passe : secret Secret Manager contenant le mot de passe de l'utilisateur
- Schéma d'authentification : schéma utilisé pour l'authentification
  Les schémas d'authentification suivants sont compatibles avec la connexion MongoDB :
  - Plain
  - SCRAM-SHA-1
  - SCRAM-SHA-256

Entités, opérations et actions

Tous les connecteurs Integration Connectors fournissent une couche d'abstraction pour les objets de l'application connectée. Vous ne pouvez accéder aux objets d'une application que par le biais de cette abstraction. L'abstraction vous est présentée en tant qu'entités, opérations et actions.

Entité : une entité peut être considérée comme un objet ou un ensemble de propriétés dans l'application ou le service connectés. La définition d'une entité diffère d'un connecteur à l'autre. Par exemple, dans un connecteur de base de données, les tables sont les entités, alors que dans un connecteur de serveur de fichiers, ce sont les dossiers, et dans un connecteur de système de messagerie, ce sont les files d'attente.
Toutefois, il est possible qu'un connecteur n'accepte ou ne possède aucune entité. Dans ce cas, la liste Entities est vide.
Opération : une opération est l'activité que vous pouvez effectuer sur une entité. Voici les opérations possibles :
- List
- Get
- Create
- Update
- Delete
Lorsque vous sélectionnez une entité dans la liste proposée, cela génère une liste d'opérations disponibles pour l'entité. Pour obtenir une description détaillée des opérations, consultez les opérations d'entité de la tâche "Connecteurs". Cependant, si un connecteur n'accepte pas l'une des opérations d'entité, cette opération non compatible ne figure pas dans la liste Operations.
Action : une action est une fonction de première classe mise à la disposition de l'intégration par le biais de l'interface du connecteur. Une action vous permet de modifier une ou plusieurs entités, et varie d'un connecteur à l'autre. Normalement, une action comporte des paramètres d'entrée et un paramètre de sortie. Toutefois, il est possible qu'un connecteur n'accepte aucune action, auquel cas la liste Actions est vide.

Limites du système

Le connecteur MongoDB peut traiter au maximum 70 transactions par seconde et par nœud, et limite les transactions qui dépassent cette limite. Par défaut, Integration Connectors alloue deux nœuds (pour améliorer la disponibilité) à une connexion.

Pour en savoir plus sur les limites applicables à Integration Connectors, consultez Limites.

Remarque : L'autoscaling du nombre de nœuds Integration Connectors s'effectue de manière dynamique en fonction de votre utilisation. Toutefois, si vous souhaitez réserver de la capacité pour de gros volumes sans attendre l'autoscaling, vous pouvez ajuster le nombre minimal de nœuds pour une connexion. Pour traiter davantage de transactions pour une connexion, vous devez disposer de plus de nœuds. À l'inverse, moins de nœuds sont nécessaires si une connexion traite moins de transactions. Pour configurer les valeurs de nœuds, procédez comme suit :

Si vous avez opté pour le paiement à l'usage, configurez le nombre minimal et le nombre maximal de nœuds sur la page "Modifier la connexion".
Si vous avez souscrit un abonnement, contactez l'assistance.

Le nombre maximal de transactions qu'un nœud peut traiter dépend de plusieurs facteurs. Par conséquent, avant que vous ajustiez le nombre minimal de nœuds pour améliorer le débit, nous vous recommandons de vérifier si vos systèmes backend sont configurés de manière optimale pour gérer le trafic requis.

Types de données acceptés

Voici les types de données acceptés pour ce connecteur :

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

Configuration pour le cluster MongoDB Atlas

La configuration de l'authentification pour un cluster MongoDB Atlas diffère légèrement de celle décrite précédemment. Pour vous authentifier auprès d'un cluster Atlas, vous devez d'abord obtenir la chaîne de connexion Atlas. Pour obtenir la chaîne de connexion Atlas, procédez comme suit :

Dans la vue "Clusters", cliquez sur le cluster auquel vous souhaitez vous connecter.
Cliquez sur "Connecter votre application".
Sélectionnez l'une des options de pilote pour afficher une chaîne de connexion.

Pour vous authentifier auprès d'un cluster Atlas, utilisez la configuration suivante :

Base de données d'authentification : définissez la valeur sur admin, comme tous les utilisateurs de MongoDB Atlas sont associés à la base de données admin.
Connexion SSL : définissez la valeur sur true.
Serveur : définissez la valeur sur mongodb+srv://MongoDB INSTANCE SERVER NAME sans inclure le nom d'utilisateur ni le mot de passe.

Actions

Cette section liste toutes les actions compatibles avec la connexion MongoDB.

Remarque : Les résultats de toutes les actions seront disponibles sous forme de réponse JSON dans le paramètre de réponse connectorOutputPayload de la tâche Connectors une fois l'intégration exécutée.

Action AggregatePipeline

Cette action regroupe les modifications du pipeline dans une collection.

Paramètres d'entrée de l'action AggregatePipeline

Nom du paramètre	Type de données	Obligatoire	Description
collection	STRING	Oui	Nom de la collection MongoDB.
pipeline	STRING	Oui	Pipeline d'agrégation contenant des étapes de champ sous forme de liste de chaînes.
page_size	INTEGER	Non	Nombre d'éléments à inclure sur chaque page de l'ensemble de résultats.
page_no	INTEGER	Non	Index de la page à récupérer dans l'ensemble de résultats. L'index commence à 0.

Pour obtenir des exemples de configuration de l'action AggregatePipeline, consultez Exemples.

Action CountDocuments

Cette action compte tous les documents qui répondent à une condition donnée dans une collection.

Paramètres d'entrée de l'action CountDocuments

Nom du paramètre	Type de données	Obligatoire	Description
collection	STRING	Oui	Nom de la collection MongoDB.
filter	STRING	Non	Condition de filtre exprimée au format de requête MongoDB. Cette condition peut contenir des champs chiffrés si le schéma de chiffrement est activé pour l'égalité de type de requête.

Paramètres de sortie de l'action CountDocuments

Cette action renvoie le nombre de documents qui remplissent une condition donnée.

Pour obtenir des exemples de configuration de l'action CountDocuments, consultez Exemples.

Action DeleteDocuments

Cette action supprime les documents d'une collection.

Paramètres d'entrée de l'action DeleteDocuments

Nom du paramètre	Type de données	Obligatoire	Description
collection	STRING	Oui	Nom de la collection MongoDB.
filter	STRING	Non	Condition de filtre exprimée au format de requête MongoDB. Cette condition peut contenir des champs chiffrés si le schéma de chiffrement est activé pour l'égalité de type de requête.

Paramètres de sortie de l'action DeleteDocuments

Cette action renvoie le nombre de documents supprimés.

Pour obtenir des exemples de configuration de l'action DeleteDocuments, consultez Exemples.

Action DistinctValues

Cette action renvoie les valeurs distinctes d'un champ dans une collection.

Paramètres d'entrée de l'action DistinctValues

Nom du paramètre	Type de données	Obligatoire	Description
collection	STRING	Oui	Nom de la collection MongoDB.
field	STRING	Oui	Nom du champ à interroger pour obtenir des valeurs distinctes.
filter	STRING	Non	Condition de filtre exprimée au format de requête MongoDB. Cette condition peut contenir des champs chiffrés si le schéma de chiffrement est activé pour l'égalité de type de requête.

Pour obtenir des exemples de configuration de l'action DistinctValues, consultez Exemples.

Action InsertDocument

Cette action insère un document dans une collection.

Les tableaux suivants décrivent les paramètres d'entrée et de sortie de l'action InsertDocument.

Paramètres d'entrée de l'action InsertDocument

Nom du paramètre	Type de données	Obligatoire	Description
collection	STRING	Oui	Nom de la collection MongoDB.
document	STRING	Non	Document à ajouter à une collection MongoDB.

Paramètres de sortie de l'action InsertDocument

Cette action renvoie l'identifiant du document inséré.

Pour obtenir des exemples de configuration de l'action InsertDocument, consultez Exemples.

Action ListDocuments

Les tableaux suivants décrivent les paramètres d'entrée et de sortie de l'action ListDocuments.

Paramètres d'entrée de l'action ListDocuments

Nom du paramètre	Type de données	Obligatoire	Description
collection	STRING	Oui	Nom de la collection MongoDB.
filter	STRING	Non	Condition de filtre exprimée au format de requête MongoDB. Cette condition peut contenir des champs chiffrés si le schéma de chiffrement est activé pour l'égalité de type de requête.
page_size	INTEGER	Non	Nombre d'éléments à inclure sur chaque page de l'ensemble de résultats.
page_no	INTEGER	Non	Index de la page à récupérer dans l'ensemble de résultats. L'index commence à 0.
projection	STRING	Non	Ensemble de champs ou de propriétés à inclure dans la projection de requête au format Mongo.
sort_by	STRING	Non	Spécification de l'ordre des résultats de la requête au format BSON (Binary JSON) de MongoDB.

Paramètres de sortie de l'action ListDocuments

Cette action affiche la liste des documents qui répondent à la condition de filtre en fonction de la taille de la page. La taille de page par défaut est de 25 et la taille de page maximale est de 50 000.

Pour obtenir des exemples de configuration de l'action ListDocuments, consultez Exemples.

Action UpdateDocuments

Les tableaux suivants décrivent les paramètres d'entrée et de sortie de l'action UpdateDocuments.

Paramètres d'entrée de l'action UpdateDocuments

Nom du paramètre	Type de données	Obligatoire	Description
collection	STRING	Oui	Nom de la collection MongoDB.
values	STRING	Non	Valeurs à mettre à jour au format Mongo.
filter	STRING	Non	Condition de filtre exprimée au format de requête MongoDB. Cette condition peut contenir des champs chiffrés si le schéma de chiffrement est activé pour l'égalité de type de requête.
upsert	BOOLEAN	Non	L'opération est une opération d'upsert ou non.

Paramètres de sortie de l'action UpdateDocuments

Cette action renvoie le nombre de documents mis à jour.

Pour obtenir des exemples de configuration de l'action UpdateDocuments, consultez Exemples.

Action UpdateDocumentsWithEncryption

Cette action permet à l'utilisateur de mettre à jour les valeurs chiffrées. Les tableaux suivants décrivent les paramètres d'entrée et de sortie de l'action UpdateDocumentsWithEncryption.

Paramètres d'entrée de l'action UpdateDocumentsWithEncryption

Nom du paramètre	Type de données	Obligatoire	Description
collection	STRING	Oui	Nom de la collection MongoDB.
document	STRING	Non	Document contenant les valeurs à mettre à jour. Les valeurs peuvent contenir des champs qui seront chiffrés à l'aide de CSFLE.
filter	STRING	Non	Condition de filtre exprimée au format de requête MongoDB. Cette condition peut contenir des champs chiffrés si le schéma de chiffrement est activé pour l'égalité de type de requête.
upsert	BOOLEAN	Non	Indique si l'opération est `upsert`.

Paramètres de sortie de l'action UpdateDocumentsWithEncryption

Cette action renvoie le nombre de documents mis à jour.

Pour obtenir des exemples de configuration de l'action UpdateDocumentsWithEncryption, consultez Exemples.

Exemples

Cette section explique comment effectuer certaines opérations et actions d'entité dans ce connecteur.

Exemple : Modifier le pipeline agrégé

Dans la boîte de dialogue Configure connector task, cliquez sur Actions.
Sélectionnez l'action AggregatePipeline, puis cliquez sur OK.

Dans la section Entrée de la tâche de la tâche Connecteurs, cliquez sur connectorInputPayload, puis saisissez une valeur semblable à la suivante dans le champ Default Value :

{
  "collection": "restaurants",
  "pipeline": {
    "stages": [
      "{$addFields: { \"new_menu_item\": \"tea\"}}"
    ]
  },
  "page_size": 1,
  "page_no": 0
}

Cet exemple ajoute un nouvel élément de menu à tous les documents de la collection restaurant et affiche la première page du résultat.

Exemple : Compter des documents

Dans la boîte de dialogue Configure connector task, cliquez sur Actions.
Sélectionnez l'action CountDocuments, puis cliquez sur OK.
Dans la section Entrée de la tâche de la tâche Connecteurs, cliquez sur connectorInputPayload, puis saisissez une valeur semblable à la suivante dans le champ Default Value :
```
{
"collection":"restaurants",
"filter": "{\"name\": \"CarvelIceCream1\"}"
}
```

Cet exemple affiche le nombre de documents correspondant aux critères de filtrage. Si l'action aboutit, le paramètre de réponse connectorOutputPayload de la tâche Connectors aura une valeur semblable à la suivante :

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

Exemple : Supprimer des documents

Dans la boîte de dialogue Configure connector task, cliquez sur Actions.
Sélectionnez l'action DeleteDocuments, puis cliquez sur OK.
Dans la section Entrée de la tâche de la tâche Connecteurs, cliquez sur connectorInputPayload, puis saisissez les informations suivantes dans le champ Default Value :
```
{
  "collection": "Insurancedocuments",
  "filter": "{\"insurance.provider\":\"ABC\"}"}
```

Cet exemple supprime tous les documents dont l'assurance santé est ABC.

Exemple : Rechercher des valeurs distinctes dans une collection

Dans la boîte de dialogue Configure connector task, cliquez sur Actions.
Sélectionnez l'action DistinctValues, puis cliquez sur OK.
Dans la section Entrée de la tâche de la tâche Connecteurs, cliquez sur connectorInputPayload, puis saisissez une valeur semblable à la suivante dans le champ Default Value :
```
{"collection":"restaurants","field":"contact"}
```

Cet exemple renvoie les valeurs distinctes de la collection restaurants. Si l'action aboutit, le paramètre de réponse connectorOutputPayload de la tâche Connectors aura une valeur semblable à la suivante :

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

Exemple : Insérer un document

Dans la boîte de dialogue Configure connector task, cliquez sur Actions.
Sélectionnez l'action InsertDocument, puis cliquez sur OK.

Dans la section Entrée de la tâche de la tâche Connecteurs, cliquez sur connectorInputPayload, puis saisissez une valeur semblable à la suivante dans le champ Default Value :

{ {
"collection": "Insurancedocuments",
"document": "{\"fname\":\"firstName\",
\"lname\":\"lastName\",
\"passportId\":\"ABCD1234\",
\"bloodType\":\"A\",
\"medicalRecords\":[{\"item\":\"name1\"},{\"item\":\"name2\"}],
\"insurance\":{\"policyNumber\":\"12345\",\"provider\":\"provider2\"}}"
} }

Cet exemple insère un document dans la collection Insurancedocuments. Le contenu du document est spécifié dans le champ document. Si l'insertion aboutit, vous obtiendrez l'ID du document inséré dans le paramètre de réponse connectorOutputPayload de la tâche Connectors.

Exemple : Lister des documents

Dans la boîte de dialogue Configure connector task, cliquez sur Actions.
Sélectionnez l'action ListDocuments, puis cliquez sur OK.
Dans la section Entrée de la tâche de la tâche Connecteurs, cliquez sur connectorInputPayload, puis saisissez une valeur semblable à la suivante dans le champ Default Value :
```
{
"collection": "Insurancedocuments",
"filter": "{\"insurance.provider\":\"ABC\"}",
"page_size": 10
}
```

Cet exemple affiche les documents de la collection Insurancedocuments dans lesquels l'assurance santé est ABC. La taille de page de l'ensemble des résultats est définie sur 10, et la liste des fichiers est disponible au format JSON dans le paramètre de réponse connectorOutputPayload de la tâche Connectors.

Exemple : Mettre à jour des documents

Dans la boîte de dialogue Configure connector task, cliquez sur Actions.
Sélectionnez l'action UpdateDocuments, puis cliquez sur OK.
Dans la section Entrée de la tâche de la tâche Connecteurs, cliquez sur connectorInputPayload, puis saisissez une valeur semblable à la suivante dans le champ Default Value :
```
{"collection":"Insurancedocuments",
"values":" {$set: { lname:\"Smith\" }}",
"filter":"{\"insurance.provider\":\"ABC\"}"}
```

Cet exemple remplace le nom de famille par Smith dans les documents qui correspondent aux critères de filtrage. Si la mise à jour aboutit, vous obtiendrez le nombre de documents mis à jour. La réponse sera disponible dans le paramètre de réponse connectorOutputPayload de la tâche Connectors.

Exemple : Mettre à jour des documents avec le chiffrement

Dans la boîte de dialogue Configure connector task, cliquez sur Actions.
Sélectionnez l'action UpdateDocumentsWithEncryption, puis cliquez sur OK.
Dans la section Entrée de la tâche de la tâche Connecteurs, cliquez sur connectorInputPayload, puis saisissez les informations suivantes dans le champ Default Value :
```
{ {"collection":"Insurancedocuments",
"document":" { \"insurance.provider\":\"XYZ\" }",
"filter":"{\"insurance.provider\":\"ABC\"}"}
```

Cet exemple met à jour l'assurance santé pour qu'elle corresponde à XYZ dans tous les documents où l'assurance santé est ABC.

Utiliser Terraform pour créer des connexions

Vous pouvez utiliser la ressource Terraform pour créer une connexion.

Pour savoir comment appliquer ou supprimer une configuration Terraform, consultez Commandes Terraform de base.

Pour afficher un exemple de modèle Terraform permettant de créer une connexion, consultez Exemple de modèle.

Lorsque vous créez cette connexion à l'aide de Terraform, vous devez définir les variables suivantes dans votre fichier de configuration Terraform :

Nom du paramètre	Type de données	Obligatoire	Description
database	STRING	True	Nom de la base de données MongoDB.
timeout	INTEGER	False	Délai avant expiration de la connexion en secondes.
enable_ssl	BOOLEAN	False	Ce champ indique si SSL est activé.
app_name	STRING	False	Nom d'application personnalisé pour MongoDB.
max_staleness_seconds	INTEGER	False	Durée en secondes pendant laquelle une connexion secondaire peut être obsolète avant que le client cesse de l'utiliser pour les opérations de lecture.
write_concern	STRING	False	Option permettant de demander confirmation que l'opération d'écriture a été propagée à un nombre donné d'instances avec des tags spécifiés.
write_concern_timeout	INTEGER	False	Spécifie un délai en millisecondes pour write_concern.
write_concern_journal	BOOLEAN	False	Demande à MongoDB de confirmer que l'opération d'écriture a été écrite dans le journal.
read_preference	ENUM	False	Préférences de lecture pour cette connexion. Valeurs acceptées : "primary", "primaryPreferred", "secondary", "secondaryPreferred" et "nearest".
cluster_type	ENUM	False	Spécifie le type de cluster MongoDB. Valeurs acceptées : REPLICA_SET, STANDALONE, SHARDED et UNKNOWN.
enable_encryption	BOOLEAN	False	Ce champ définit si le chiffrement est activé.
encryption_type	ENUM	False	Ce champ définit le type de chiffrement activé. La valeur acceptée est "local".
encryption_schema	STRING	False	Informations sur le schéma de chiffrement, y compris les champs et l'algorithme de chiffrement utilisés.
encryption_master_key	SECRET	False	Secret Secret Manager contenant la clé principale de chiffrement.
encryption_key_vault	STRING	False	Valeur du coffre de clés de chiffrement.
auth_database	STRING	True	Nom de la base de données MongoDB pour l'authentification.

Utiliser la connexion MongoDB dans une intégration

Une fois la connexion créée, elle devient disponible dans Apigee Integration et Application Integration. Vous pouvez utiliser la connexion dans une intégration au moyen de la tâche "Connecteurs".

Pour savoir comment créer et utiliser la tâche "Connecteurs" dans Apigee Integration, consultez Tâche "Connecteurs".
Pour savoir comment créer et utiliser la tâche "Connecteurs" dans Application Integration, consultez Tâche "Connecteurs".

Demander de l'aide à la communauté Google Cloud

Vous pouvez publier vos questions et discuter de ce connecteur sur les forums Cloud de la communauté Google Cloud.

Étapes suivantes

Découvrez comment suspendre et reprendre une connexion.
Découvrez comment surveiller l'utilisation des connecteurs.
Découvrez comment afficher les journaux des connecteurs.