Google Antigravity エージェントと CData Connect AI を連携してリアルタイム Spark データにアクセス
Antigravity は、自律型および半自律型エージェント向けに設計された AI ネイティブ開発環境です。開発者はエディター内で直接エージェント駆動のワークフローを実行でき、計画、実行、ツール使用を単一のインターフェースで組み合わせることができます。
Antigravity と CData Connect AI を組み込みの MCP（Model Context Protocol）Server 経由で連携させることで、エージェントはリアルタイムの Spark のデータ に対して、ガバナンスを維持しながらリアルタイムでアクセスできるようになります。これにより、Antigravity エージェントは手動でのデータ移行やカスタム API の配線なしで、スキーマの探索、データのクエリ、アクションの実行を行えます。
この記事では、Connect AI での Spark 接続の設定、必要なアクセストークンの生成、Antigravity での CData MCP Server の登録、そしてエージェント駆動のワークフローからリアルタイムの Spark のデータ にクエリを実行して連携を検証するまでの手順を説明します。
Step 1: Antigravity 向けに Spark の接続を設定
Antigravity から Spark への接続は、CData Connect AI の Remote MCP Server によって実現されます。Antigravity から Spark のデータ を操作するには、まず CData Connect AI で Spark 接続を作成・設定します。
- Connect AI にログインし、Sources をクリックしてから Add Connection をクリックします。
- Add Connection パネルから Spark を選択します。
-
Spark への接続に必要な認証プロパティを入力します。
SparkSQL への接続
SparkSQL への接続を確立するには以下を指定します。
- Server：SparkSQL をホストするサーバーのホスト名またはIP アドレスに設定。
- Port：SparkSQL インスタンスへの接続用のポートに設定。
- TransportMode：SparkSQL サーバーとの通信に使用するトランスポートモード。有効な入力値は、BINARY およびHTTP です。デフォルトではBINARY が選択されます。
- AuthScheme：使用される認証スキーム。有効な入力値はPLAIN、LDAP、NOSASL、およびKERBEROS です。デフォルトではPLAIN が選択されます。
Databricks への接続
Databricks クラスターに接続するには、以下の説明に従ってプロパティを設定します。Note：必要な値は、「クラスター」に移動して目的のクラスターを選択し、 「Advanced Options」の下にある「JDBC/ODBC」タブを選択することで、Databricks インスタンスで見つけることができます。
- Server：Databricks クラスターのサーバーのホスト名に設定。
- Port：443
- TransportMode：HTTP
- HTTPPath：Databricks クラスターのHTTP パスに設定。
- UseSSL：True
- AuthScheme：PLAIN
- User：'token' に設定。
- Password：パーソナルアクセストークンに設定（値は、Databricks インスタンスの「ユーザー設定」ページに移動して「アクセストークン」タブを選択することで取得できます）。
- Save & Test をクリックします。
- Permissions タブに移動し、ユーザーベースの権限を更新します。
Personal Access Token の追加
Personal Access Token（PAT）は、Antigravity から Connect AI への接続を認証するために使用されます。アクセス制御を細かく管理するために、連携ごとに個別の PAT を作成することをお勧めします。
- Connect AI アプリの右上にある歯車アイコン（）をクリックして Settings を開きます。
- Settings ページで Access Tokens セクションに移動し、 Create PAT をクリックします。
- PAT にわかりやすい名前を付けて Create をクリックします。
- トークンが表示されたらコピーして安全に保管してください。再度表示されることはありません。
Spark 接続の設定と PAT の生成が完了したら、CData MCP Server 経由で Antigravity から Spark のデータ に接続する準備が整いました。
Step 2: Antigravity で CData MCP Server を設定
次に、Antigravity で CData MCP Server を登録します。Antigravity は Raw 設定ファイルから MCP サーバーの定義を読み込み、エージェントが Connect AI によって公開されるソースを動的に検出して呼び出せるようにします。
- Antigravity デスクトップアプリケーションをダウンロードし、Google アカウントでサインインします。
-
初期セットアップの画面で、プロンプトが表示されたら Agent-driven development を選択します。このモードにより、ツール実行機能を持つ自律エージェントが有効になります。
- Antigravity のセットアップが完了し IDE が開いたら、組み込みのエージェントインターフェースから MCP サーバーを管理できます。上部メニューから Toggle Agent をクリックするか、Ctrl + Alt + B を押してエージェントパネルを開きます。
-
エージェントパネルが開いたら、「...」をクリックしてドロップダウンから MCP Servers を選択します。
-
MCP Store から Manage MCP Servers を選択し、View raw config をクリックして MCP 設定ファイルを開きます。
-
以下の JSON をファイルに貼り付けます。
{ "mcpServers": { "cdata-mcp": { "serverUrl": "https://mcp.cloud.cdata.com/mcp", "headers": { "Authorization": "Basic your_base64_encoded_email_PAT", "Content-Type": "application/json" } } } }注意：Antigravity は Connect AI との認証に Basic 認証を使用します。Connect AI ユーザーのメールアドレスと先ほど作成した PAT を組み合わせて Base64 エンコードします。たとえば、ユーザー名と PAT が [email protected]:ABC123...XYZ789 の場合、Authorization ヘッダーの値は次のようになります：Basic dXNlckBteWRvbWFpbjphSzkvbVB4Mi9Rcjd2TjQvTHc4Qi96WTZqQzMvRnQ1SGcxL0RzMFVlL01iWHdKdg==
- 設定ファイルを保存します。
-
Manage MCP Servers ビューに戻り、Refresh をクリックして新しい MCP サーバーを読み込みます。
Step 3: Antigravity エージェントからリアルタイムの Spark のデータ にクエリ
MCP サーバーが登録されると、Antigravity エージェントは Connect AI によって公開されるリアルタイムのデータソースと対話し、スキーマの探索やクエリの実行が可能になります。
- Toggle Agent を使用して再度エージェントパネルを開きます。
- エージェントチャットで新しい会話を開始します。
-
以下のようなプロンプトを入力してエージェントと対話を開始します。
- List all catalogs in my cdata-mcp connection.
- Show schemas and tables available for Spark.
- Query the top 3 records from a table in Spark のデータ.
これで、Antigravity エージェントは CData Connect AI MCP Server と通信し、リモート MCP ツールを通じてリアルタイムの Spark のデータ を取得できるようになりました。
CData Connect AI の詳細
300 以上の SaaS、ビッグデータ、NoSQL ソースにクラウドアプリケーションから直接アクセスするには、CData Connect AI をぜひお試しください。