Einrichten von Openflow Connector for Box¶

Einrichten des Konnektors¶

Als Data Engineer führen Sie die folgenden Aufgaben aus, um den Konnektor zu installieren und zu konfigurieren:

Führen Sie den Ablauf aus¶

1. Klicken Sie mit der rechten Maustaste auf die Ebene, und wählen Sie Enable all Controller Services.

2. Klicken Sie mit der rechten Maustaste auf die importierte Prozessgruppe und wählen Sie Start. Der Konnektor startet die Datenaufnahme.

Nach dem Start des Konnektors ruft dieser alle Dateien aus dem angegebenen Ordner ab und verarbeitet dann admin_logs_streaming-Ereignisse der letzten 14 Tage. Dies geschieht, um Daten zu erfassen, die während des Initialisierungsvorgangs möglicherweise übersehen wurden. Während dieser Zeit können not found-Fehler auftreten, die durch Dateien verursacht werden, die in den Ereignissen erscheinen, aber nicht mehr vorhanden sind.

Einrichten des Konnektors¶

Als Data Engineer führen Sie die folgenden Aufgaben aus, um den Konnektor zu installieren und zu konfigurieren:

Führen Sie den Ablauf aus¶

1. Klicken Sie mit der rechten Maustaste auf die Ebene, und wählen Sie Enable all Controller Services.

2. Klicken Sie mit der rechten Maustaste auf die importierte Prozessgruppe und wählen Sie Start. Der Konnektor startet die Datenaufnahme.

Nach dem Start des Konnektors ruft dieser alle Dateien aus dem angegebenen Ordner ab und verarbeitet dann admin_logs_streaming-Ereignisse der letzten 14 Tage. Dies geschieht, um alle Daten zu erfassen, die während des Initialisierungsvorgangs möglicherweise übersehen wurden. Während dieser Zeit können not found-Fehler auftreten, die durch Dateien verursacht werden, die in den Ereignissen erscheinen, aber nicht mehr vorhanden sind.

Abfrage des Cortex Search Service¶

Sie können den Cortex Search Service nutzen, um Chat- und Suchanwendungen zu erstellen, mit denen Sie mit Ihren Dokumenten in Box chatten oder diese abfragen können.

Nachdem Sie den Konnektor installiert und konfiguriert haben und er mit der Aufnahme von Inhalten aus Box beginnt, können Sie den Cortex Search Service abfragen. Weitere Informationen zur Verwendung von Cortex Search finden Sie unter Einen Cortex Search Service abfragen.

Antworten filtern

Um die Antworten des Cortex Search Service auf Dokumente zu beschränken, auf die ein bestimmter Benutzer in Box Zugriff hat, können Sie bei der Abfrage der Cortex Search einen Filter angeben, der die Benutzer-ID oder die E-Mail-Adresse des Benutzers enthält. Beispiel: filter.@contains.user_ids oder filter.@contains.user_emails. Der Name des vom Konnektor erstellten Cortex Search Service lautet search_service im Schema Cortex.

Führen Sie den folgenden SQL-Code in einem SQL-Arbeitsblatt aus, um den Cortex Search Service mit Dateien abzufragen, die von Ihrer Box-Website aufgenommen wurden.

Ersetzen Sie Folgendes:

• application_instance_name: Name Ihrer Datenbank und der Connector-Anwendungsinstanz.

• user_emailID: E-Mail-ID des Benutzers, für den Sie die Antworten filtern möchten.

• your_question: Die Frage, auf die Sie Antworten erhalten möchten.

• number_of_results: Maximale Anzahl der Ergebnisse, die in der Antwort zurückgegeben werden sollen. Der Höchstwert ist 1.000 und der Standardwert ist 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

Hier finden Sie eine vollständige Liste der Werte, die Sie für columns eingeben können:

Beispiel: Abfrage eines AI-Assistenten zu Personalinformationen (HR)

Mit Cortex Search können Sie einen AI-Assistenten für Mitarbeiter abfragen, um mit den neuesten Versionen von HR Informationen wie Onboarding, Verhaltenskodex, Teamprozesse und Organisationsrichtlinien zu chatten. Mithilfe von Antwortfiltern können Sie auch HR-Teammitgliedern die Abfrage von Mitarbeiterverträgen gestatten, wobei die in Box konfigurierten Zugriffskontrollen eingehalten werden.

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."
  } ]
}

Eine Snowflake-Tabelle zum Speichern der Box-Metadaten erstellen¶

1. Stellen Sie sicher, dass Box-AI aktiviert ist, damit die Extraktion von Metadaten erfolgen kann. Weitere Informationen finden Sie unter Box-AI konfigurieren.

2. Erstellen Sie eine Snowflake-Tabelle, an die die Metadaten gesendet werden sollen.

   Damit der Konnektor weiß, welche Art von Metadaten er extrahieren soll, müssen Sie eine Snowflake-Tabelle in Ihrer Datenbank und Ihrem Schema mit den Spaltennamen der zu extrahierenden Felder erstellen. Fügen Sie Beschreibungen zu jeder Spalte hinzu, um die Leistung des Modells zu verbessern, das zum Extrahieren der Metadaten aus den Dateien verwendet wird.

3. Stellen Sie sicher, dass in der im vorherigen Schritt erstellten Tabelle eine Spalte vorhanden ist, in der die Box-Datei-ID gespeichert wird, und dass sie vom Typ VARCHAR ist.

   Der Name dieser Spalte muss in späteren Schritten als Parameter „Box File Identifier Column“ eingegeben werden. Die Liste der unterstützten Spaltentypen für die Metadatentabelle lautet VARCHAR, STRING, TEXT, FLOAT, DOUBLE und DATE.

Hier sehen Sie ein Beispiel für eine Tabelle, die Sie für diesen Konnektor erstellen können:

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)'
);

Einrichten des Konnektors¶

Als Data Engineer führen Sie die folgenden Aufgaben aus, um den Konnektor zu installieren und zu konfigurieren:

Führen Sie den Ablauf aus¶

1. Klicken Sie mit der rechten Maustaste auf die Ebene, und wählen Sie Enable all Controller Services.

2. Klicken Sie mit der rechten Maustaste auf die importierte Prozessgruppe und wählen Sie Start. Der Konnektor startet die Datenaufnahme.

Nach dem Start des Konnektors ruft dieser alle Dateien aus dem angegebenen Ordner ab und verarbeitet dann admin_logs_streaming-Ereignisse der letzten 14 Tage. Dies geschieht, um alle Daten zu erfassen, die während des Initialisierungsvorgangs möglicherweise übersehen wurden. Während dieser Zeit können not found-Fehler auftreten, die durch Dateien verursacht werden, die in den Ereignissen erscheinen, aber nicht mehr vorhanden sind.

Erstellen Sie einen Snowflake-Stream zum Speichern der Box-Metadaten¶

1. Erstellen Sie einen Snowflake-Stream für die Metadatentabelle, die Sie verwenden möchten. Der Stream wird verwendet, um alle Änderungen an der Tabelle zu überwachen, mit der Sie Ihre Box-Dateien synchronisieren möchten. Wie Sie eine Tabelle zum Speichern von Box-Metadaten erstellen, erfahren Sie unter Eine Snowflake-Tabelle zum Speichern der Box-Metadaten erstellen. Wenn der Konnektor über die Datenaufbewahrungsdauer hinaus gestoppt wird und der Stream veraltet ist, müssen Sie einen neuen Stream erstellen und den vorherigen ersetzen. Weitere Informationen zu Verwaltung von Streams finden Sie unter Verwalten von Streams.

   Hier ist ein Beispiel für einen Stream, den Sie für diesen Konnektor erstellen können:

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

   Copy

2. Stellen Sie sicher, dass in der Metadatentabelle eine Spalte zum Speichern der Box-Datei-ID vorhanden ist und dass diese vom Typ VARCHAR ist.

   Der Name dieser Spalte muss in späteren Schritten als Parameter „Box File Identifier Column“ eingegeben werden. Die Liste der unterstützten Spaltentypen für die Metadatentabelle lautet VARCHAR, STRING, TEXT, FLOAT, DOUBLE und DATE.

Einrichten des Konnektors¶

Als Data Engineer führen Sie die folgenden Aufgaben aus, um den Konnektor zu installieren und zu konfigurieren:

Führen Sie den Ablauf aus¶

1. Klicken Sie mit der rechten Maustaste auf die Ebene, und wählen Sie Enable all Controller Services.

2. Klicken Sie mit der rechten Maustaste auf die importierte Prozessgruppe und wählen Sie Start. Der Konnektor startet die Datenaufnahme.

Nachdem Sie den Ablauf ausgeführt haben, können Sie den Cortex Search Service abfragen. Informationen zur Abfrage des Cortex Search Sevice finden Sie unter Abfrage des Cortex Search Service.