• DRIFT
  • SCHEMA
  • LOGIC
  • HUMAN

Déboguer vos pipelines de streaming avec votre IA

Connectez votre IA à RisingWave pour inspecter vos flux de données en direct et vérifier la précision de vos agrégats. Une fois la connexion établie, votre agent s'occupe de l'analyse des schémas et des états.

Demandez à l'IA à propos de cette page

Réponse rapide

Comment l'IA peut-elle m'aider à déboguer mes pipelines RisingWave ?

Votre client IA utilise des outils spécifiques pour lister vos sources et vos vues matérialisées, puis exécute des requêtes SQL pour comparer les données brutes à vos agrégats. Cela vous permet de détecter immédiatement tout écart ou erreur de logique dans vos calculs en temps réel. Vous identifierez précisément l'origine de l'erreur de calcul.

Chaque problème est répertorié.

Résultats du débogage

Votre IA catégorise les anomalies détectées dans votre instance RisingWave.

DRIFT

Écart d'agrégation

L'IA compare les données sources à vos vues matérialisées. Vous recevez un rapport indiquant où les totaux en temps réel divergent des données brutes.

SCHEMA

Erreurs de structure

L'agent vérifie vos sources et vos vues pour s'assurer que les types et les colonnes correspondent à vos attentes. Il signale les champs manquants ou les erreurs de type.

LOGIC

Validation de requête

Votre IA exécute des requêtes SQL de test pour vérifier que votre logique de fenêtrage ou de jointure produit les résultats attendus. Elle identifie les erreurs de logique d'agrégation.

HUMAN

Intervention manuelle

Si l'IA détecte une erreur logique qu'elle ne peut pas corriger, elle vous fournit le SQL spécifique pour réparer la vue. C'est à vous de décider comment appliquer la correction.

Le flux

Ce que fait votre IA lors de la requête.

L'IA passe de la phase de découverte à l'inspection approfondie grâce aux outils RisingWave.

  1. Cartographier le pipeline

    L'agent identifie toutes les entrées de données actives et les vues qui en dépendent pour comprendre le flux de données.

    list_sourceslist_materialized_views

  2. Inspecter les données brutes

    Il extrait des échantillons de vos sources pour établir une base de comparaison avec la réalité des données.

    execute_sql

  3. Vérifier les agrégats

    L'IA exécute des requêtes ciblées sur vos vues matérialisées pour vérifier si les calculs sont cohérents avec les données sources.

    execute_sql

  4. Signaler les écarts

    L'agent résume les différences trouvées entre la source et la vue, en mettant en évidence les lignes ou les valeurs erronées.

    execute_sql

Essayez

Copiez ces exemples pour commencer.

Utilisez ces prompts pour lancer votre session de débogage.

Points de départ

Ceci sont des exemples. Remplacez les noms de vues ou de sources par les vôtres.

RisingWave Connector

Tout est prêt. Choisissez votre client MCP et suivez les instructions de configuration.

Lien du connecteurhttps://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp

Claude Desktop

Suivez les étapes ci-dessous pour vous connecter en quelques secondes.

  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.
Configuration · claude_desktop_config.jsonCopier
{
  "mcpServers": {
    "risingwave-streaming-database-mcp": {
      "url": "https://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp"
    }
  }
}
Copiez dans le chat04

  • Liste toutes mes vues matérialisées et indique-moi celles qui servent à l'analyse en temps réel.

  • Vérifie la vue matérialisée 'user_activity_counts' par rapport à la source 'web_events' pour voir si les totaux correspondent.

  • Exécute une requête pour trouver les valeurs nulles dans ma source 'sensor_data'.

  • Compare la somme agrégée de ma vue 'daily_sales' avec les données brutes de ma source 'transactions'.

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

Commencez ici

Connectez RisingWave une fois, puis interrogez.

Liez votre instance une seule fois. Vos identifiants restent chiffrés et vous pouvez immédiatement demander à votre IA d'interroger vos données.

Connecter RisingWave à votre IA

FAQ

Fonctionnement de la tâche

  • 01

    L'IA peut-elle modifier mes définitions de vues matérialisées ?

    Non. L'IA peut uniquement lire le schéma et exécuter des requêtes. Vous devez mettre à jour vos instructions DDL manuellement.

  • 02

    L'IA peut-elle supprimer mes sources de données ?

    Non. Les outils fournis permettent uniquement de lister et d'interroger. L'IA ne peut effectuer aucune action destructive.

  • 03

    L'IA a-t-elle accès à toutes mes données ?

    L'IA ne voit que les données auxquelles vous l'autorisez via les requêtes SQL que vous lui demandez d'exécuter.

  • 04

    Comment sait-elle si un agrégat est incorrect ?

    Elle utilise l'outil execute_sql pour lancer une requête de comparaison entre les données sources et les résultats de la vue matérialisée.

  • 05

    Puis-je l'utiliser pour réparer mon pipeline automatiquement ?

    Non. L'IA identifie les erreurs et suggère le SQL pour les corriger, mais vous devez exécuter la correction vous-même.

  • D'autres questions sur RisingWave ? Voir toutes les capacités du connecteur RisingWave

Connectez RisingWave à Claude, Cursor, ChatGPT et d'autres