• DONNÉES
  • LOGIQUE
  • SCHÉMA
  • HUMAIN

Tester l'ingestion de données avec votre client IA

Connectez RisingWave à votre client IA pour envoyer des événements JSON directement dans vos tables de streaming. Observez ensuite comment votre logique réagit aux nouvelles données en temps réel.

Demandez à l'IA à propos de cette page

Réponse rapide

Comment tester ma logique de streaming avec de nouvelles données ?

Votre client IA injecte des payloads JSON dans les tables RisingWave pour déclencher vos requêtes de streaming. Cela vous permet de valider immédiatement la réaction de votre logique face à des schémas d'événements précis. Vous verrez les résultats de vos vues matérialisées au fur et à mesure de l'arrivée des données.

Les résultats.

Où arrivent vos données.

L'IA gère le transfert de données pour que vous puissiez vous concentrer sur les résultats des requêtes.

DONNÉES

Mise à jour des tables

L'IA injecte les événements JSON dans vos tables cibles. Vos vues matérialisées se mettent à jour instantanément selon les nouvelles données.

LOGIQUE

Validation des règles

Vérifiez si votre logique de fenêtrage ou d'agrégation fonctionne. L'IA confirme que les données sont arrivées et que les requêtes ont réagi.

SCHÉMA

Vérification des tables

L'IA analyse votre schéma RisingWave pour s'assurer que le JSON entrant correspond à vos définitions de tables. Cela évite les erreurs d'ingestion.

HUMAIN

Ajustement manuel

Vous décidez quand ajuster votre logique SQL ou modifier la structure des événements. L'IA fournit les données, mais vous maîtrisez la logique de streaming.

Le flux

Ce que fait votre IA à l'arrivée des données.

L'IA sert de pont entre vos payloads d'événements bruts et votre base de données de streaming.

  1. Inspecter le schéma

    L'IA examine votre configuration RisingWave pour trouver la destination de vos événements. Elle doit identifier les tables existantes avant d'envoyer les données.

    list_tables

  2. Envoyer les événements

    L'IA prend vos payloads JSON et les écrit directement dans les tables cibles. Cela simule un flux de données en temps réel.

    ingest_events

  3. Vérifier l'ingestion

    L'IA utilise l'outil d'ingestion pour confirmer que la base de données a accepté les données et que le flux est actif.

    ingest_events

  4. Confirmer l'état des tables

    L'IA vérifie à nouveau la liste des tables pour s'assurer que l'environnement est prêt pour le prochain lot de tests.

    list_tables

Essayez

Copiez ces commandes pour commencer.

Utilisez ces prompts pour tester vos flux de données.

Points de départ

Remplacez les noms de tables et les payloads JSON par les détails réels de votre schéma RisingWave.

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 tables RisingWave pour que je puisse en choisir une pour mes tests.

  • Injecte cet événement JSON dans la table 'user_activity' : {"user_id": 123, "action": "click"}.

  • Vérifie mes tables pour voir si la table 'sensor_data' est prête pour l'ingestion.

  • Envoie un lot de cinq événements JSON dans la table 'web_logs' pour tester ma logique de fenêtrage.

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

Commencez ici

Connectez RisingWave une fois, puis demandez.

Liez votre compte une seule fois. Vos identifiants restent chiffrés et vous pouvez immédiatement envoyer des données via votre client IA.

Connecter RisingWave à votre IA

FAQ

Fonctionnement de cette tâche.

  • 01

    L'IA peut-elle supprimer mes tables RisingWave existantes ?

    Non. L'IA dispose uniquement d'outils pour lister les tables et injecter des événements. Elle ne peut ni supprimer ni modifier la structure de vos tables.

  • 02

    L'IA gère-t-elle l'exécution des requêtes SQL ?

    Non. L'IA utilise des outils spécifiques pour déplacer les données vers les tables. Vous devez exécuter vos propres requêtes SQL dans RisingWave pour voir les résultats de l'ingestion.

  • 03

    Puis-je envoyer des objets JSON imbriqués complexes ?

    Oui, à condition que la structure JSON corresponde au schéma de la table cible.

  • 04

    L'IA corrigera-t-elle automatiquement ma logique SQL en cas d'échec ?

    Non. L'IA peut injecter les données, mais elle ne peut pas réécrire vos requêtes SQL de streaming à votre place.

  • 05

    Comment l'IA sait-elle quelles tables sont disponibles ?

    L'IA utilise l'outil list_tables pour scanner votre instance RisingWave et identifier les cibles valides.

  • D'autres questions sur RisingWave ? La page du connecteur y répond. Voir toutes les capacités du connecteur RisingWave

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