Defina o Openflow Connector para o Google Drive¶

Instalação do conector¶

1. Navegue até a página Visão geral do Openflow. Na seção Featured connectors, selecione View more connectors.

2. Na página de conectores do Openflow, localize o conector e selecione Add to runtime.

3. Na caixa de diálogo Select runtime, selecione seu tempo de execução na lista suspensa Available runtimes.

4. Selecione Add.

   Nota

   Antes de instalar o conector, verifique se você criou um banco de dados e um esquema no Snowflake para que o conector armazene os dados ingeridos.

5. Autentique-se na implementação com as credenciais de sua conta Snowflake e selecione Allow quando solicitado para permitir que o aplicativo de tempo de execução acesse sua conta Snowflake. O processo de instalação do conector leva alguns minutos para ser concluído.

6. Autentique-se no tempo de execução com as credenciais de sua conta Snowflake.

A tela do Openflow é exibida com o grupo de processos do conector adicionado a ela.

Configuração do conector¶

1. Clique com o botão direito do mouse no grupo de processos importado e selecione Parâmetros.

2. Digite os valores dos parâmetros necessários, conforme descrito em Parâmetros de origem do Google Drive, Parâmetros de destino do Google Drive e Parâmetros de ingestão do Google Drive.

Instalação do conector¶

1. Navegue até a página Visão geral do Openflow. Na seção Featured connectors, selecione View more connectors.

2. Na página de conectores do Openflow, localize o conector e selecione Add to runtime.

3. Na caixa de diálogo Select runtime, selecione seu tempo de execução na lista suspensa Available runtimes.

4. Selecione Add.

   Nota

   Antes de instalar o conector, verifique se você criou um banco de dados e um esquema no Snowflake para que o conector armazene os dados ingeridos.

5. Autentique-se na implementação com as credenciais de sua conta Snowflake e selecione Allow quando solicitado para permitir que o aplicativo de tempo de execução acesse sua conta Snowflake. O processo de instalação do conector leva alguns minutos para ser concluído.

6. Autentique-se no tempo de execução com as credenciais de sua conta Snowflake.

A tela do Openflow é exibida com o grupo de processos do conector adicionado a ela.

Configuração do conector¶

1. Clique com o botão direito do mouse no grupo de processos importado e selecione Parâmetros.

2. Digite os valores dos parâmetros necessários, conforme descrito em Parâmetro de origem do Google Drive Cortex Connect, Parâmetro de destino do Google Drive Cortex Connect e Parâmetro de ingestão do Google Drive Cortex Connect.

Instalação do conector¶

1. Navegue até a página Visão geral do Openflow. Na seção Featured connectors, selecione View more connectors.

2. Na página de conectores do Openflow, localize o conector e selecione Add to runtime.

3. Na caixa de diálogo Select runtime, selecione seu tempo de execução na lista suspensa Available runtimes.

4. Selecione Add.

   Nota

   Antes de instalar o conector, verifique se você criou um banco de dados e um esquema no Snowflake para que o conector armazene os dados ingeridos.

5. Autentique-se na implementação com as credenciais de sua conta Snowflake e selecione Allow quando solicitado para permitir que o aplicativo de tempo de execução acesse sua conta Snowflake. O processo de instalação do conector leva alguns minutos para ser concluído.

6. Autentique-se no tempo de execução com as credenciais de sua conta Snowflake.

A tela do Openflow é exibida com o grupo de processos do conector adicionado a ela.

Configuração do conector¶

1. Personalize a definição do conector.

   1. Remova os seguintes grupos de processos:

      • Verifique se há conteúdo duplicado

      • Preparo e análise de PDF no Snowflake

      • Atualização do Snowflake Cortex

   2. Anexe qualquer processamento personalizado à saída do grupo de processos Processar metadados do Google Drive. Cada FlowFile representa uma única alteração de arquivo do Google Drive. Os atributos do FlowFile podem ser vistos na documentação de Fetch Google Drive Metadata.

2. Preencha os parâmetros do grupo de processos. Siga o mesmo processo de Caso de uso 1: use a definição do conector para ingerir apenas arquivos. Observe que, após modificar a definição do conector, talvez nem todos os parâmetros sejam necessários.

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 Google Drive.

Após instalar e configurar o conector e ele começar a ingerir conteúdo do Google Drive, 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 Google Drive, você pode especificar um filtro que contenha o ID de usuário ou o endereço de e-mail de 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 Google Drive.

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 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
     }'