• DRIFT
  • SCHEMA
  • LOGIC
  • HUMAN

Como depurar pipelines de streaming com sua IA

Conecte sua IA ao RisingWave para inspecionar fluxos de dados ao vivo e verificar a precisão dos agregados. Após a conexão, seu agente cuida de toda a parte pesada de consultar esquemas e estados.

Pergunte à IA sobre esta página

Resposta rápida

Como posso usar IA para depurar meus pipelines no RisingWave?

Seu cliente de IA utiliza ferramentas específicas para listar suas fontes e views materializadas, executando consultas SQL para comparar os dados brutos com seus agregados. Isso permite identificar desvios ou erros de lógica nos cálculos em tempo real imediatamente. Você verá exatamente onde o cálculo falhou.

Onde cada problema é identificado.

Resultados da depuração

Sua IA categoriza os achados com base no que encontra em sua instância do RisingWave.

DRIFT

Divergência de agregados

A IA compara os dados de origem com suas views materializadas. Você recebe um relatório indicando onde os totais em tempo real divergem dos dados brutos.

SCHEMA

Erros de estrutura

O agente verifica suas fontes e views para garantir que tipos e colunas correspondam ao esperado, sinalizando campos ausentes ou incompatibilidade de tipos.

LOGIC

Validação de consultas

Sua IA executa SQL de teste para verificar se a lógica de janelamento ou joins produz os resultados esperados, identificando falhas na agregação.

HUMAN

Intervenção manual

Quando a IA encontra um erro de lógica que não pode corrigir, ela entrega o SQL específico necessário para reparar a view. Você decide como aplicar a correção.

O fluxo

O que sua IA faz quando recebe o comando.

A IA passa da descoberta para a inspeção profunda usando suas ferramentas do RisingWave.

  1. Mapear o pipeline

    O agente identifica todas as entradas de dados ativas e as views construídas sobre elas para entender o fluxo de dados.

    list_sourceslist_materialized_views

  2. Inspecionar dados brutos

    Ele extrai amostras de suas fontes para estabelecer uma base do que os dados realmente representam.

    execute_sql

  3. Verificar agregados

    A IA executa consultas específicas em suas views materializadas para checar se os cálculos batem com os dados de origem.

    execute_sql

  4. Relatar discrepâncias

    O agente resume as diferenças encontradas entre a origem e a view, destacando linhas ou valores específicos que estão incorretos.

    execute_sql

Teste

Copie estes comandos para começar.

Use estes prompts para iniciar sua sessão de depuração.

Pontos de partida

Estes são apenas exemplos. Substitua os nomes de views ou fontes pelos seus próprios.

RisingWave Connector

Tudo pronto. Escolha seu cliente MCP e siga as instruções de configuração.

Link do conectorhttps://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp

Claude Desktop

Siga os passos abaixo para conectar em segundos.

  1. 1In Claude Desktop, open Settings → Connectors.
  2. 2Click “Add custom connector” and paste the connector link above as the remote MCP server URL.
  3. 3Click Add and start a new chat — RisingWave capabilities are ready to use.
Configuração · claude_desktop_config.jsonCopiar
{
  "mcpServers": {
    "risingwave-streaming-database-mcp": {
      "url": "https://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp"
    }
  }
}
Copie no chat04

  • Liste todas as minhas views materializadas e me diga quais são para análise em tempo real.

  • Verifique a view materializada 'user_activity_counts' contra a fonte 'web_events' para ver se os totais coincidem.

  • Execute uma consulta para encontrar valores nulos na minha fonte 'sensor_data'.

  • Compare a soma agregada na minha view 'daily_sales' com os dados brutos na minha fonte 'transactions'.

  • Claude
  • ChatGPT
  • Cursor
  • VS Code
  • Windsurf
  • Claude Code
  • JetBrains
  • Cline

Comece aqui

Conecte o RisingWave uma vez e comece a perguntar.

Basta vincular sua instância uma única vez. Suas credenciais ficam criptografadas e você pode começar imediatamente a pedir que sua IA consulte seus dados.

Conectar RisingWave à sua IA

FAQ

Como funciona esta tarefa

  • 01

    A IA pode alterar as definições das minhas views materializadas?

    Não. A IA só pode ler o esquema e executar consultas. Você deve atualizar seus comandos DDL manualmente.

  • 02

    A IA pode excluir minhas fontes de dados?

    Não. As ferramentas fornecidas permitem apenas listar e consultar. A IA não pode realizar ações destrutivas.

  • 03

    A IA vê todos os meus dados?

    A IA só consegue ver os dados que você permitir o acesso por meio das consultas SQL que você solicitar.

  • 04

    Como ela sabe se um agregado está errado?

    Ela utiliza a ferramenta execute_sql para rodar uma consulta de comparação entre os dados de origem e os resultados da view materializada.

  • 05

    Posso usar isso para corrigir meu pipeline automaticamente?

    Não. A IA identifica os erros e sugere o SQL para corrigi-los, mas você precisa executar a correção por conta própria.

  • Mais dúvidas sobre o RisingWave? Veja tudo o que o RisingWave Connector pode fazer

Conecte RisingWave ao Claude, Cursor, ChatGPT e outros