Paramétrez Openflow Connector for Box¶

Définir le connecteur¶

En tant qu’ingénieur des données, effectuez les tâches suivantes pour installer et configurer le connecteur :

Exécutez le flux¶

1. Cliquez avec le bouton droit de la souris sur l’avion et sélectionnez Enable all Controller Services.

2. Cliquez avec le bouton droit de la souris sur le groupe de processus importé et sélectionnez Start. Le connecteur démarre l’ingestion des données.

Après avoir démarré le connecteur, il récupère tous les fichiers du dossier spécifié, puis consomme les événements admin_logs_streaming survenus au cours des 14 derniers jours. Cette opération a pour but de capturer des données qui auraient pu être omises au cours du processus d’initialisation. Pendant ce temps, des erreurs not found peuvent se produire, causées par des fichiers qui apparaissent dans les événements mais qui ne sont plus présents.

Définir le connecteur¶

En tant qu’ingénieur des données, effectuez les tâches suivantes pour installer et configurer le connecteur :

Exécutez le flux¶

1. Cliquez avec le bouton droit de la souris sur l’avion et sélectionnez Enable all Controller Services.

2. Cliquez avec le bouton droit de la souris sur le groupe de processus importé et sélectionnez Start. Le connecteur démarre l’ingestion des données.

Après avoir démarré le connecteur, il récupère tous les fichiers du dossier spécifié, puis consomme les événements admin_logs_streaming survenus au cours des 14 derniers jours. Cette opération a pour but de capturer toutes les données qui ont pu être omises au cours du processus d’initialisation. Pendant ce temps, des erreurs not found peuvent se produire, causées par les fichiers qui apparaissent dans les événements mais qui ne sont plus présents.

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

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

Une fois que vous avez installé et configuré le connecteur et qu’il commence à ingérer le contenu de Box, 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 Box, vous pouvez spécifier un filtre contenant l’ID ou l’e-mail de l’utilisateur lorsque vous effectuez une requête auprès de 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 site Box.

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 1 000 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 Box.

SELECT PARSE_JSON(
     SNOWFLAKE.CORTEX.SEARCH_PREVIEW(
          '<application_instance_name>.cortex.search_service',
          '{
             "query": "What is my vacation carryover 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 carryover 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 carryover policy?",
         "columns": ["chunk", "web_url"],
         "limit": 1
     }'

{
  "results" : [ {
  "web_url" : "https://<domain>.box.com/sites/<site_name>/<path_to_file>",
  "chunk" : "Answer to the question asked."
  } ]
}

Créez une table Snowflake pour stocker les métadonnées Box¶

1. Assurez-vous que Box AI est activé pour l’extraction des métadonnées. Pour plus d’informations, voir Configuration de Box AI.

2. Créez une table Snowflake dans laquelle les métadonnées seront envoyées

   Pour que le connecteur sache quel type de métadonnées extraire, vous devez créer une table Snowflake dans votre base de données et votre schéma avec les noms des colonnes des champs que vous souhaitez extraire. Ajoutez des descriptions à chaque colonne afin d’améliorer les performances du modèle utilisé pour extraire les métadonnées des fichiers.

3. Dans la table créée à l’étape précédente, assurez-vous qu’il existe une colonne pour stocker le fichier Box ID et qu’elle est de type VARCHAR.

   Le nom de cette colonne doit être saisi en tant que paramètre de la colonne d’identification du fichier Box dans les étapes suivantes. La liste des types de colonnes pris en charge pour la table des métadonnées est la suivante : VARCHAR, STRING, TEXT, FLOAT, DOUBLE et DATE.

Voici un exemple de table que vous pouvez créer pour ce connecteur :

CREATE OR REPLACE TABLE OPENFLOW.BOX_METADATA_SCHEMA.LOAN_AGREEMENT_METADATA (
  BOX_FILE_ID               VARCHAR    COMMENT 'Box file identifier column',
  LOAN_ID                   STRING     COMMENT 'Unique loan agreement identifier (e.g. L-2025-0001)',
  BORROWER_NAME             STRING     COMMENT 'Name of the borrower entity or individual',
  LENDER_NAME               STRING     COMMENT 'Name of the lending institution',
  LOAN_AMOUNT               DOUBLE     COMMENT 'Principal amount of the loan (in USD)',
  INTEREST_RATE             FLOAT      COMMENT 'Annual interest rate (%)',
  EFFECTIVE_DATE            DATE       COMMENT 'Date on which the loan becomes effective',
  MATURITY_DATE             DATE       COMMENT 'Scheduled loan maturity date',
  LOAN_TERM_MONTHS          FLOAT      COMMENT 'Original term length in months',
  COLLATERAL_DESCRIPTION    TEXT       COMMENT 'Description of collateral securing the loan',
  CREDIT_SCORE              FLOAT      COMMENT 'Borrower credit score',
  JURISDICTION              STRING     COMMENT 'Governing law jurisdiction (e.g. NY, CA)'
);

Définir le connecteur¶

En tant qu’ingénieur des données, effectuez les tâches suivantes pour installer et configurer le connecteur :

Exécutez le flux¶

1. Cliquez avec le bouton droit de la souris sur l’avion et sélectionnez Enable all Controller Services.

2. Cliquez avec le bouton droit de la souris sur le groupe de processus importé et sélectionnez Start. Le connecteur démarre l’ingestion des données.

Après avoir démarré le connecteur, il récupère tous les fichiers du dossier spécifié, puis consomme admin_logs_streaming événements des 14 derniers jours. Cette opération a pour but de capturer toutes les données qui ont pu être omises au cours du processus d’initialisation. Pendant ce temps, des erreurs not found peuvent se produire, causées par les fichiers qui apparaissent dans les événements mais qui ne sont plus présents.

Créez un flux Snowflake pour stocker les métadonnées Box¶

1. Créez un flux Snowflake pour la table de métadonnées que vous souhaitez utiliser. Le flux est utilisé pour surveiller les modifications apportées à la table avec laquelle vous souhaitez synchroniser vos fichiers Box. Pour savoir comment créer une table pour le stockage des métadonnées Box, voir Créer une table Snowflake pour le stockage des métadonnées Box. Si le connecteur est arrêté au-delà de la durée de conservation des données et que le flux devient périmé, vous devez recréer un flux et remplacer le précédent. Pour en savoir plus sur la gestion des flux, consultez le site Gestion des flux.

   Voici un exemple de flux que vous pouvez créer pour ce connecteur :

   CREATE OR REPLACE STREAM OPENFLOW.BOX_METADATA_SCHEMA.LOAN_AGREEMENT_METADATA_STREAM
   ON TABLE OPENFLOW.BOX_METADATA_SCHEMA.LOAN_AGREEMENT_METADATA
   

   Copy

2. Dans la table des métadonnées, veillez à ce qu’une colonne stocke l’ID de fichier Box et qu’elle soit de type VARCHAR.

   Le nom de cette colonne doit être saisi en tant que paramètre de la colonne d’identification du fichier Box dans les étapes suivantes. La liste des types de colonnes pris en charge pour la table des métadonnées est la suivante : VARCHAR, STRING, TEXT, FLOAT, DOUBLE et DATE.

Définir le connecteur¶

En tant qu’ingénieur des données, effectuez les tâches suivantes pour installer et configurer le connecteur :

Exécutez le flux¶

1. Cliquez avec le bouton droit de la souris sur l’avion et sélectionnez Enable all Controller Services.

2. Cliquez avec le bouton droit de la souris sur le groupe de processus importé et sélectionnez Start. Le connecteur démarre l’ingestion des données.

Après avoir exécuté le flux, vous pouvez interroger le service Cortex Search. Pour obtenir des informations sur la manière d’interroger le service Cortex Search, consultez Requête auprès du service Cortex Search.