Integração da API do Snowflake Cortex com fluxos de trabalho de API

Os agentes Snowflake Cortex desbloqueiam a interação de linguagem natural com seus dados, ajudando você a consultar, analisar e agir em conjuntos de dados empresariais.

Este fluxo de trabalho serve como intermediário para executar um "ORDERS_AGENT" no Snowflake. Ele aceita uma pergunta como entrada, a envia para a API do agente Snowflake Cortex e, em seguida, retorna a resposta da API diretamente como a saída do fluxo de trabalho.

Pré-requisitos

Primeiro, você precisa ter um Agente Cortex configurado na sua conta Snowflake.

1. Crie um fluxo de trabalho da API.
2. Defina entradas de fluxo de trabalho. Abra o Data Manager e adicione um novo parâmetro Entradas com a seguinte configuração:
   • Nome— Pergunta
   • Tipo— String
   • Deixe a caixa de seleção Obrigatório vazia.
3. Adicione uma atividade HTTP e configure-a da seguinte forma:
   • Método— POST
   • URL de solicitação— forneça o endpoint de execução do agente do Cortex, específico para sua conta e agente do Snowflake, por exemplo "https://{your_snowflake_env}/api/v2/databases/SNOWFLAKE_INTELLIGENCE/schemas/AGENTS/agents/ORDERS_AGENT:run"
   • Cabeçalhos—

     {
       "Content-Type": "application/json",
       "Accept": "application/json",
       "Authorization": "Bearer <Add your snowflake_token here>"
     }
     

   • Corpo da solicitação—

     {
         "messages": [
             {
                 "role": "user",
                 "content": [
                     {
                         "type": "text",
                         "text": $workflow.input.Question
                     }
                 ]
             }
         ],
         "toolChoice": {
             "type": "auto"
         }
     }
     

4. Adicione uma atividade Response e deixe-a como está. Isso captura e retorna a saída do agente do Cortex como um JSON.
5. Execute a integração. Depois de implantado, você pode invocar o fluxo de trabalho com qualquer consulta de linguagem natural. O fluxo de trabalho passa a pergunta para o Agente do Cortex, recebe a saída de streaming e retorna uma resposta JSON estruturada que pode ser usada em automações downstream.

Principais pontos:

• O streaming é perfeito — Embora a API do Cortex seja apenas de streaming, o suporte integrado do fluxo de trabalho da API implicava que nenhuma codificação adicional era necessária para analisar e coletar resultados.
• Contrato de API consistente – Todos os agentes do Cortex compartilham a mesma forma de solicitação/resposta. Sua integração não precisa ser alterada à medida que seus agentes ficam mais avançados.
• Criação rápida de protótipos : da configuração à integração de trabalho levou apenas minutos. Essa velocidade permite que as equipes validem rapidamente os casos de uso e iterem.