Paramétrer le connecteur Openflow pour Google Drive¶

Installer le connecteur¶

1. Naviguez jusqu’à la page d’aperçu d’Openflow. Dans la section Featured connectors, sélectionnez View more connectors.

2. Sur la page des connecteurs Openflow, trouvez le connecteur et sélectionnez Add to runtime.

3. Dans la boîte de dialogue Select runtime, sélectionnez votre environnement d’exécution dans la liste déroulante Available runtimes.

4. Sélectionnez Add.

   Note

   Avant d’installer le connecteur, assurez-vous que vous avez créé une base de données et un schéma dans Snowflake pour que le connecteur puisse stocker les données ingérées.

5. Authentifiez-vous au déploiement avec les identifiants de votre compte Snowflake et sélectionnez Allow lorsque vous êtes invité à autoriser l’application d’exécution à accéder à votre compte Snowflake. Le processus d’installation du connecteur prend quelques minutes.

6. Authentifiez-vous auprès de l’environnement d’exécution avec les identifiants de votre compte Snowflake.

Le canevas Openflow apparaît avec le groupe de processus du connecteur ajouté.

Configuration du connecteur¶

1. Cliquez avec le bouton droit de la souris sur le groupe de processus importé et sélectionnez Paramètres.

2. Saisissez les valeurs des paramètres requises comme indiqué dans Paramètres de la source Google Drive, Paramètres de la destination Google Drive et Paramètres de l’ingestion Google Drive.

Installer le connecteur¶

1. Naviguez jusqu’à la page d’aperçu d’Openflow. Dans la section Featured connectors, sélectionnez View more connectors.

2. Sur la page des connecteurs Openflow, trouvez le connecteur et sélectionnez Add to runtime.

3. Dans la boîte de dialogue Select runtime, sélectionnez votre environnement d’exécution dans la liste déroulante Available runtimes.

4. Sélectionnez Add.

   Note

   Avant d’installer le connecteur, assurez-vous que vous avez créé une base de données et un schéma dans Snowflake pour que le connecteur puisse stocker les données ingérées.

5. Authentifiez-vous au déploiement avec les identifiants de votre compte Snowflake et sélectionnez Allow lorsque vous êtes invité à autoriser l’application d’exécution à accéder à votre compte Snowflake. Le processus d’installation du connecteur prend quelques minutes.

6. Authentifiez-vous auprès de l’environnement d’exécution avec les identifiants de votre compte Snowflake.

Le canevas Openflow apparaît avec le groupe de processus du connecteur ajouté.

Configuration du connecteur¶

1. Cliquez avec le bouton droit de la souris sur le groupe de processus importé et sélectionnez Paramètres.

2. Saisissez les valeurs de paramètre requises comme décrit dans Google Drive Cortex Connect Source Parameters, Google Drive Cortex Connect Destination Parameters et Google Drive Cortex Connect Ingestion Parameters.

Installer le connecteur¶

1. Naviguez jusqu’à la page d’aperçu d’Openflow. Dans la section Featured connectors, sélectionnez View more connectors.

2. Sur la page des connecteurs Openflow, trouvez le connecteur et sélectionnez Add to runtime.

3. Dans la boîte de dialogue Select runtime, sélectionnez votre environnement d’exécution dans la liste déroulante Available runtimes.

4. Sélectionnez Add.

   Note

   Avant d’installer le connecteur, assurez-vous que vous avez créé une base de données et un schéma dans Snowflake pour que le connecteur puisse stocker les données ingérées.

5. Authentifiez-vous au déploiement avec les identifiants de votre compte Snowflake et sélectionnez Allow lorsque vous êtes invité à autoriser l’application d’exécution à accéder à votre compte Snowflake. Le processus d’installation du connecteur prend quelques minutes.

6. Authentifiez-vous auprès de l’environnement d’exécution avec les identifiants de votre compte Snowflake.

Le canevas Openflow apparaît avec le groupe de processus du connecteur ajouté.

Configuration du connecteur¶

1. Personnaliser la définition du connecteur.

   1. Supprimer les groupes de processus suivants :

      • Vérifier si le contenu est dupliqué

      • Zone de préparation et d’analyse du PDF Snowflake

      • Mise à jour du Snowflake Cortex

   2. Attachez tout traitement client à la sortie du groupe de processus Traiter les métadonnées Google Drive. Chaque fichier de flux représente une seule modification de fichier Google Drive. Les attributs des fichiers de flux peuvent être consultés dans la documentation Fetch Google Drive Metadata.

2. Renseignez les paramètres du groupe de processus. Suivez le même processus que pour Cas d’utilisation 1 : Utilisez la définition du connecteur pour ingérer uniquement des fichiers. Notez qu’après avoir modifié la définition du connecteur, il se peut que tous les paramètres ne soient pas nécessaires.

Requête auprès du service Cortex Search Service¶

Vous pouvez utiliser le service Cortex Search pour créer des applications de chat et de recherche permettant de dialoguer avec vos documents dans Google Drive ou d’y effectuer des requêtes.

Une fois que vous avez installé et configuré le connecteur et qu’il commence à ingérer du contenu depuis Google Drive, vous pouvez lancer une requête auprès du service Cortex Search. Pour plus d’informations sur l’utilisation de Cortex Search, voir Requête à un service de Cortex Search.

Réponses des filtres

Pour limiter les réponses du service Cortex Search aux documents auxquels un utilisateur spécifique a accès dans Google Drive, vous pouvez spécifier un filtre contenant l’ID ou l’adresse e-mail de l’utilisateur lorsque vous effectuez une requête sur Cortex Search. Par exemple, filter.@contains.user_ids ou filter.@contains.user_emails. Le nom du service Cortex Search créé par le connecteur est search_service dans le schéma Cortex.

Exécutez le code SQL suivant dans une feuille de calcul SQL pour interroger le service Cortex Search avec des fichiers ingérés depuis votre Google Drive.

Remplacez les éléments suivants :

• application_instance_name: Nom de votre base de données et de votre instance d’application connecteur.

• user_emailID: ID d’email de l’utilisateur pour lequel vous souhaitez filtrer les réponses.

• your_question: La question pour laquelle vous souhaitez obtenir des réponses.

• number_of_results: Nombre maximal de résultats à renvoyer dans la réponse. La valeur maximale est de 1000 et la valeur par défaut est de 10.

SELECT PARSE_JSON(
  SNOWFLAKE.CORTEX.SEARCH_PREVIEW(
    '<application_instance_name>.cortex.search_service',
      '{
        "query": "<your_question>",
         "columns": ["chunk", "web_url"],
         "filter": {"@contains": {"user_emails": "<user_emailID>"} },
         "limit": <number_of_results>
       }'
   )
)['results'] AS results

Voici la liste complète des valeurs que vous pouvez saisir pour columns:

Exemple : Requête auprès d’un assistant AI pour obtenir des informations sur les ressources humaines (HR)

Vous pouvez utiliser Cortex Search pour interroger un assistant AI à l’intention des employés afin d’obtenir les dernières versions des informations HR, telles que l’onboarding, le code de conduite, les processus d’équipe et les politiques de l’organisation. À l’aide de filtres de réponse, vous pouvez également autoriser les membres de l’équipe HR à effectuer des requêtes sur les contrats des employés tout en respectant les contrôles d’accès configurés dans Google Drive.

SELECT PARSE_JSON(
     SNOWFLAKE.CORTEX.SEARCH_PREVIEW(
          '<application_instance_name>.cortex.search_service',
          '{
             "query": "What is my vacation carry over policy?",
             "columns": ["chunk", "web_url"],
             "filter": {"@contains": {"user_emails": "<user_emailID>"} },
             "limit": 1
          }'
     )
 )['results'] AS results

import snowflake.snowpark as snowpark
from snowflake.snowpark import Session
from snowflake.core import Root

def main(session: snowpark.Session):

   root = Root(session)

   # fetch service
   my_service = (root
     .databases["<application_instance_name>"]
     .schemas["cortex"]
     .cortex_search_services["search_service"]
   )

   # query service
   resp = my_service.search(
     query="What is my vacation carry over policy?",
     columns = ["chunk", "web_url"],
     filter = {"@contains": {"user_emails": "<user_emailID>"} },
     limit=1
   )
   return (resp.to_json())

curl --location "https://<account_url>/api/v2/databases/<application_instance_name>/schemas/cortex/cortex-search-services/search_service" \
     --header 'Content-Type: application/json' \
     --header 'Accept: application/json' \
     --header "Authorization: Bearer <CORTEX_SEARCH_JWT>" \
     --data '{
         "query": "What is my vacation carry over policy?",
         "columns": ["chunk", "web_url"],
         "limit": 1
     }'