Configure o Openflow Connector for Box¶

Configuração do conector¶

Como engenheiro de dados, execute as seguintes tarefas para instalar e configurar o conector:

Execute o fluxo¶

1. Clique com o botão direito do mouse no plano e selecione Enable all Controller Services.

2. Clique com o botão direito do mouse no grupo de processos importado e selecione Start. O conector inicia a ingestão de dados.

Depois de iniciar o conector, ele recupera todos os arquivos da pasta especificada e, em seguida, consome os eventos do admin_logs_streaming nos últimos 14 dias. Isso é feito para capturar dados que, de outra forma, poderiam ter sido perdidos durante o processo de inicialização. Durante esse período, podem ocorrer erros not found, causados por arquivos que aparecem nos eventos, mas que não estão mais presentes.

Configuração do conector¶

Como engenheiro de dados, execute as seguintes tarefas para instalar e configurar o conector:

Execute o fluxo¶

1. Clique com o botão direito do mouse no plano e selecione Enable all Controller Services.

2. Clique com o botão direito do mouse no grupo de processos importado e selecione Start. O conector inicia a ingestão de dados.

Depois de iniciar o conector, ele recupera todos os arquivos da pasta especificada e, em seguida, consome os eventos do admin_logs_streaming nos últimos 14 dias. Isso é feito para capturar quaisquer dados que possam ter sido perdidos durante o processo de inicialização. Durante esse período, podem ocorrer erros not found, causados pelos arquivos que aparecem nos eventos, mas que não estão mais presentes.

Consultar o Cortex Search Service¶

Você pode usar o serviço Cortex Search para criar aplicativos de bate-papo e pesquisa para conversar ou consultar seus documentos no Box.

Após instalar e configurar o conector e ele começar a ingerir conteúdo do Box, você poderá consultar o serviço Cortex Search. Para obter mais informações sobre como usar o Cortex Search, consulte Consulta a um Cortex Search Service.

Respostas do filtro

Para restringir as respostas do serviço Cortex Search aos documentos aos quais um usuário específico tem acesso no Box, você pode especificar um filtro que contenha o ID de usuário ou endereço de e-mail do usuário ao consultar o Cortex Search. Por exemplo, filter.@contains.user_ids ou filter.@contains.user_emails. O nome do Cortex Search Service criado pelo conector é search_service no esquema Cortex.

Execute o seguinte código SQL em uma planilha SQL para consultar o serviço Cortex Search com arquivos ingeridos do site de seu Box.

Substitua o seguinte:

• application_instance_name: nome de seu banco de dados e da instância do aplicativo do conector.

• user_emailID: ID de e-mail do usuário para o qual você deseja filtrar as respostas.

• your_question: a pergunta para a qual deseja obter respostas.

• number_of_results: número máximo de resultados a serem retornados na resposta. O valor máximo é 1.000 e o valor padrão é 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

Aqui está uma lista completa de valores que você pode inserir em columns:

Exemplo: consulte um assistente de AI para obter informações sobre recursos humanos (HR)

Você pode usar o Cortex Search para consultar um assistente de AI para que os funcionários conversem com as versões mais recentes das informações de HR, como integração, código de conduta, processos de equipe e políticas da organização. Usando filtros de resposta, você também pode permitir que os membros da equipe de HR consultem os contratos dos funcionários, respeitando os controles de acesso configurados no 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."
  } ]
}

Criar uma tabela Snowflake para armazenar os metadados do Box¶

1. Certifique-se de que a Box AI esteja ativada para que a extração de metadados ocorra. Para obter mais informações, consulte Configurando a Box AI.

2. Crie uma tabela Snowflake para onde os metadados serão enviados

   Para que o conector saiba que tipo de metadados extrair, você deve criar uma tabela Snowflake em seu banco de dados e esquema com os nomes de coluna dos campos que gostaria de extrair. Adicione descrições a cada coluna para melhorar o desempenho do modelo usado para extrair os metadados dos arquivos.

3. Na tabela criada na etapa anterior, verifique se há uma coluna para armazenar o ID do arquivo Box e se ela é do tipo VARCHAR.

   O nome dessa coluna deve ser inserido como o parâmetro Coluna do identificador do arquivo Box em etapas posteriores. A lista de tipos de coluna compatíveis com a tabela de metadados é VARCHAR, STRING, TEXT, FLOAT, DOUBLE e DATE.

Aqui está um exemplo da tabela que você pode criar para esse conector:

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

Configuração do conector¶

Como engenheiro de dados, execute as seguintes tarefas para instalar e configurar o conector:

Execute o fluxo¶

1. Clique com o botão direito do mouse no plano e selecione Enable all Controller Services.

2. Clique com o botão direito do mouse no grupo de processos importado e selecione Start. O conector inicia a ingestão de dados.

Após iniciar o conector, ele recupera todos os arquivos da pasta especificada e, em seguida, consome os eventos admin_logs_streaming dos últimos 14 dias. Isso é feito para capturar quaisquer dados que possam ter sido perdidos durante o processo de inicialização. Durante esse período, podem ocorrer erros not found, causados pelos arquivos que aparecem nos eventos, mas que não estão mais presentes.

Crie um fluxo Snowflake para armazenar os metadados do Box¶

1. Crie um fluxo Snowflake para a tabela de metadados que deseja usar. O fluxo é usado para monitorar quaisquer alterações que ocorram na tabela com a qual deseja sincronizar seus arquivos Box. Para saber como criar uma tabela para armazenar os metadados do Box, consulte Crie uma tabela Snowflake para armazenar os metadados Box. Se o conector for interrompido além do tempo de retenção de dados e o fluxo se tornar obsoleto, você deverá recriar um fluxo e substituir o anterior. Para saber mais sobre o gerenciamento de fluxos, consulte Gerenciamento de fluxos.

   Aqui está o exemplo de um fluxo que você pode criar para esse conector:

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

   Copy

2. Na tabela de metadados, verifique se há uma coluna para armazenar o ID do arquivo Box e se ele é do tipo VARCHAR.

   O nome dessa coluna deve ser inserido como o parâmetro Coluna do identificador do arquivo Box em etapas posteriores. A lista de tipos de coluna compatíveis com a tabela de metadados é VARCHAR, STRING, TEXT, FLOAT, DOUBLE e DATE.

Configuração do conector¶

Como engenheiro de dados, execute as seguintes tarefas para instalar e configurar o conector:

Execute o fluxo¶

1. Clique com o botão direito do mouse no plano e selecione Enable all Controller Services.

2. Clique com o botão direito do mouse no grupo de processos importado e selecione Start. O conector inicia a ingestão de dados.

Após executar o fluxo, você pode consultar o serviço Cortex Search. Para obter informações sobre como consultar o serviço Cortex Search, consulte Consulta ao serviço Cortex Search.