AIクライアントでRisingWaveへのデータ取り込みをテストする方法

AIクライアントがJSONイベントのペイロードをRisingWaveのテーブルに投入し、ストリーミングクエリをトリガーします。これにより、特定のイベントパターンに対してロジックが正しく動作するかを即座に検証できます。データが流れるにつれて、マテリアライズドビューの結果が更新される様子を確認できます。

1. 01

   スキーマの確認

   AIは現在のRisingWaveの設定を確認し、イベントの適切な送り先を探します。データを送信する前に、どのテーブルが存在するかを把握する必要があります。

   list_tables
2. 02

   イベントの送信

   AIがJSONイベントペイロードを受け取り、対象テーブルに直接書き込みます。これにより、リアルタイムのデータストリームをシミュレートできます。

   ingest_events
3. 03

   取り込みの検証

   AIは取り込みツールを使用して、データベースがデータを正常に受け付けたかを確認します。ストリームが動いているかをチェックします。

   ingest_events
4. 04

   テーブル状態の確認

   AIは再度テーブルリストを確認し、次のテストイベントのバッチに備えて環境が整っているかを確認します。

   list_tables

RisingWave Connector

準備完了です。MCPクライアントを選択し、セットアップ手順に従ってください。

コネクタリンクhttps://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcpコピー

Claude Desktop

以下の手順で数秒で接続できます。

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.

設定 · claude_desktop_config.jsonコピー

{
  "mcpServers": {
    "risingwave-streaming-database-mcp": {
      "url": "https://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp"
    }
  }
}

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

アカウントの連携は一度だけで完了します。認証情報は暗号化されて保持されるため、すぐにAIクライアントからデータを送信できるようになります。

• 01

  AIが既存のRisingWaveテーブルを削除することはありますか？

  いいえ。AIが持っているツールはテーブルのリスト表示とイベントの取り込みのみです。テーブル構造を削除したり変更したりすることはできません。

• 02

  AIがSQLクエリの実行まで行いますか？

  いいえ。AIはデータをテーブルに移動するための専用ツールを使用します。取り込みの結果を確認するには、RisingWave上でご自身でSQLクエリを実行する必要があります。

• 03

  複雑なネスト構造を持つJSONオブジェクトを送信できますか？

  はい。JSONの構造が、ターゲットとなるテーブルのスキーマと一致していれば可能です。

• 04

  取り込みに失敗した場合、AIがSQLロジックを自動的に修正してくれますか？

  いいえ。AIはデータの投入は行えますが、ストリーミングSQLクエリを書き換えることはできません。

• 05

  AIはどのテーブルが利用可能であることをどのように判断しますか？

  AIは list_tables ツールを使用してRisingWaveインスタンスをスキャンし、有効なターゲットを特定します。

• RisingWaveについて他に質問がありますか？ RisingWave Connectorの全機能を見る