Analysen mit dem Data Agent Kit und der Antigravity IDE

1. Einführung

Es ist Montagmorgen und der CFO hat Sie gerade kontaktiert. Der durchschnittliche Bestellwert ist diesen Monat um 7% gesunken, der Gesamtumsatz ist jedoch gleich geblieben. Irgendetwas stimmt nicht und der Vorstand möchte bis Freitag Antworten.

Ihr Unternehmen, Cymbal Pets, ist einer der größten Onlinehändler für Tierbedarf in den USA. Die benötigten Daten sind auf drei Google Cloud-Dienste verteilt: Verkaufs- und Bestellverlauf in BigQuery, Kunden- und Produktdatensätze in Cloud SQL und Marketingdateien in Cloud Storage. Normalerweise müssen Sie für eine dienstübergreifende Untersuchung wie diese zwischen Konsolen wechseln, Boilerplate-Code für die Verbindung schreiben und Ergebnisse manuell zusammenfügen.

In diesem Codelab verwenden Sie das Google Cloud Data Agent Kit (DAK) in der Antigravity IDE, um die Anomalie mithilfe natürlicher Sprache zu untersuchen. Sie beschreiben, wonach Sie suchen, und der KI-Agent übernimmt die Verbindungen, SQL und dienstübergreifenden Joins in BigQuery, Cloud SQL und Cloud Storage. Sobald Sie den Fall gelöst haben, bitten Sie den Agenten, eine dbt-Pipeline zu erstellen, um Ihre Ergebnisse zu operationalisieren, einen Fehler bei der Modellierung echter Daten zu beheben und dem CFO eine auf Prognosen basierende Empfehlung zu geben.

Aufgaben

  • Daten-Assets in BigQuery, Cloud SQL und Cloud Storage mit dem Knowledge Catalog ermitteln
  • Anomalien untersuchen, indem Sie mehrere Dienste in einer einzigen Unterhaltung mit MCP-Tools abfragen
  • dbt-Pipeline erstellen, um dienstübergreifende Daten mit Staging-Modellen und automatisierten Tests zu stagen und zu verknüpfen
  • Fehlerbehebung bei einem Problem mit der Datenmodellierung, bei dem der Agent einen Fan-out-Fehler selbst diagnostiziert und refaktoriert
  • Zukünftige Trends vorhersagen und eine datengestützte Empfehlung mit der AI.FORECAST von BigQuery abgeben

Voraussetzungen

  • Ein Webbrowser wie Chrome
  • Antigravity IDE
  • Ein Google Cloud-Projekt mit aktivierter Abrechnung und Zugriff auf die Google Cloud Console (wir empfehlen, für die praktischen Übungen ein neues, dediziertes Projekt zu verwenden)
  • Grundkenntnisse in SQL und der Google Cloud Console

Dieses Codelab richtet sich an fortgeschrittene Datenexperten (Analytics Engineers, Datenanalysten, Data Scientists).

Die in diesem Codelab erstellten Ressourcen sollten weniger als 5 $ kosten. Folgen Sie am Ende des Labs der Anleitung zum Bereinigen, um bereitgestellte Ressourcen zu löschen.

2. Hinweis

In diesem Abschnitt führen Sie ein Setupscript aus, mit dem Ihre gesamte Lab-Umgebung bereitgestellt wird: ein BigQuery-Dataset mit Bestelldaten, eine Cloud SQL Postgres-Instanz mit Kunden- und Produktdaten und ein Cloud Storage-Bucket mit Aufzeichnungen von Werbekampagnen. Die Ausführung des Skripts dauert etwa 8 bis 10 Minuten. Die Bereitstellung von Cloud SQL ist der Engpass.

Projekt auswählen oder erstellen

Wählen Sie in der Google Cloud Console ein vorhandenes Projekt aus oder erstellen Sie ein neues.

Abrechnung bestätigen

Die Abrechnung für das Google Cloud-Projekt muss aktiviert sein. Weitere Informationen

Cloud Shell starten

Sie verwenden Google Cloud Shell, um das Setupskript auszuführen.

  1. Öffnen Sie die Google Cloud Console und klicken Sie oben im Fenster auf Cloud Shell aktivieren.

Cloud Shell öffnen

  1. Legen Sie nach der Verbindung Ihre Projekt-ID fest und bestätigen Sie Ihre Umgebung:
gcloud config set project <<YOUR_PROJECT_ID>>
export PROJECT_ID=$(gcloud config get-value project)

Es sollte eine Meldung wie die folgende angezeigt werden:

Your active configuration is: [cloudshell-####]
Updated property [core/project]

Repository klonen

Klonen Sie das Codelab-Repository in Ihre Cloud Shell-Umgebung:

cd ~/
git clone --filter=blob:none --no-checkout https://github.com/GoogleCloudPlatform/devrel-demos.git
cd ~/devrel-demos
git sparse-checkout init --cone
git sparse-checkout set codelabs/agentic-data-labs
git checkout main
cd codelabs/agentic-data-labs/

Setupskript ausführen

Das Setupscript bereitet Ihre gesamte Lab-Umgebung automatisch vor, sodass Sie direkt mit der Untersuchung beginnen können:

cd ~/devrel-demos/codelabs/agentic-data-labs/scripts
chmod +x setup.sh setup_sql.sh
./setup.sh

Wenn der Vorgang abgeschlossen ist, wird eine Zusammenfassung der Vordergrundumgebung angezeigt:

╔══════════════════════════════════════════════════════╗
║   Base Setup complete!                               ║
╚══════════════════════════════════════════════════════╝

Your core BigQuery and GCS assets are ready.
Cloud SQL is currently provisioning in the background and will be fully ready by Step 4.

  BigQuery:   YOUR_PROJECT_ID.cymbal_pets
              ├── orders
              └── order_items

  GCS:        gs://YOUR_PROJECT_ID-cymbal-pets-raw
              └── promo_events.json

Während Sie mit den nächsten Schritten des Labs fortfahren, wird die Datenbank im Hintergrund bereitgestellt und mit Daten gefüllt. Sie können den Fortschritt jederzeit in einem separaten Terminalfenster mit dem folgenden Befehl überwachen:

tail -f /tmp/cloudsql_setup.log

Beachten Sie die Datenarchitektur: Historische Verkaufsdatensätze (Bestellungen und Bestellpositionen) befinden sich in BigQuery, während operative Anwendungsdaten (Kunden, Tierprofile und Produkte) in Cloud SQL gespeichert sind. Diese Aufteilung spiegelt die Realität in Unternehmen wider, in denen analytische Data Warehouses und operative Datenbanken unterschiedliche Teile des Puzzles enthalten.

Zusammenfassung des Abschnitts:Sie haben das Setupscript ausgeführt, um Ihre Lab-Umgebung zu starten, und die Bereitstellung der Hintergrunddatenbank wurde gestartet.

3. IDE und Data Agent Kit einrichten

Antigravity IDE öffnen

Sie müssen nicht warten, bis Cloud SQL fertig ist. Öffnen Sie die Antigravity IDE und stellen Sie eine Verbindung zu Ihrem Google Cloud-Projekt her.

  1. Falls noch nicht geschehen, laden Sie die Antigravity IDE von der Google Antigravity-Downloadseite herunter und installieren Sie sie.
  2. Starten Sie die Desktopanwendung Antigravity IDE.
  3. Erstellen Sie einen neuen, leeren Ordner auf Ihrem lokalen Computer (z.B. mit dem Namen agentic-data-labs) und öffnen Sie ihn in der IDE, indem Sie Ordner öffnen auswählen. Dieser Ordner dient als Ihr lokaler Arbeitsbereich für das Codelab.

Antigravity IDE-Projektordner konfigurieren

Data Agent Kit-Erweiterung installieren

Die Erweiterung „Google Cloud Data Agent Kit“ fügt einen Datenkatalogbrowser, Agent-Skills und MCP-Server für BigQuery, Cloud SQL und Cloud Storage hinzu, sodass Sie diese Dienste über den Editor abfragen und prüfen können.

  1. Klicken Sie in der Antigravity IDE in der Aktivitätsleiste ganz links auf dem Bildschirm auf das Symbol Erweiterungen (es sieht aus wie vier Quadrate).
  2. Geben Sie oben im Bereich „Erweiterungen“ in der Suchleiste Google Cloud Data Agent Kit ein.
  3. Suchen Sie das erste Ergebnis mit dem Namen Google Cloud Data Agent Kit (herausgegeben von googlecloudtools).
  4. Klicken Sie auf die Schaltfläche Installieren.
  5. Es kann eine Aufforderung erscheinen, mit der gefragt wird: „Vertrauen Sie dem Herausgeber ‚googlecloudtools‘ und seinen Erweiterungen?“ Klicken Sie auf Verlagen und Webpublishern vertrauen und installieren, um fortzufahren.

Data Agent Kit-Erweiterung installieren

Nach der Installation wird in der Aktivitätsleiste ganz links in der Antigravity IDE ein neues Symbol für das Google Cloud Data Agent Kit angezeigt.

Erweiterung authentifizieren und konfigurieren

Verknüpfen Sie die Erweiterung nach der Installation mit Ihrem Google Cloud-Projekt.

  1. Eine Onboarding-Seite mit dem Titel „Willkommen im Google Cloud Data Agent Kit“ sollte automatisch geöffnet werden. Wenn Sie nicht in Ihrem Cloud-Konto angemeldet sind, folgen Sie der Anleitung, um den Zugriff zu gewähren.
  2. Suchen Sie im Abschnitt Konfigurationszusammenfassung nach dem Projektfeld. Klicken Sie auf das Drop-down-Menü und wählen Sie Ihr Google Cloud-Projekt aus. Legen Sie als Region us-central1 fest. Wählen Sie dann MCP-Server konfigurieren aus.

Erste Konfiguration der Data Agent Kit-Erweiterung

  1. Klicken Sie im Bereich MCP Configuration (MCP-Konfiguration), um BigQuery und Cloud SQL zu aktivieren. Klicken Sie dann auf Jetzt starten.

MCP-Server konfigurieren

Konfigurationsoptionen ansehen

Nach Abschluss der Einrichtung werden Sie zur Seite „Erste Schritte mit dem Google Cloud Data Agent Kit“ weitergeleitet.

  1. Klicken Sie unter „Einrichtung und Konfiguration“ auf Jetzt starten.
  2. Dadurch wird der Bereich Data Agent Kit Configuration (Konfiguration des Data Agent Kit) geöffnet. Tabs ansehen:
    • Projekt und Region:Prüfen Sie die ausgewählte Projekt-ID und ob die erforderlichen APIs (Cloud Storage API, BigQuery API, Catalog API und Cloud SQL Admin API) aktiviert sind.
    • BigQuery:Konfigurieren Sie den standardmäßigen Standort für Ihre BigQuery-Abfragen. Verwenden Sie die Region us-central1.
    • MCP-Server konfigurieren:Hier können Sie die aktivierten MCP-Server (BigQuery, Notebooks, Cloud SQL usw.) ansehen, die es KI-Agenten ermöglichen, sicher mit Ihren Daten zu interagieren.
    • Skills:Vordefinierte Skills bieten Agents spezielle Funktionen für komplexe Datenaufgaben.

Bereich „Data Agent Kit-Einstellungen“

Zusammenfassung des Abschnitts:Sie haben die Antigravity IDE geöffnet, sie mit Ihrem Google Cloud-Projekt verbunden und die Remote-MCP-Server des Data Agent Kit konfiguriert.

4. Daten entdecken

Es ist an der Zeit, den Rahmen abzustecken. Der CFO sagt, dass der durchschnittliche Bestellwert im letzten Monat um 7% gesunken ist, der Gesamtumsatz aber gleich geblieben ist. Bevor Sie den Kundenservicemitarbeiter bitten, Nachforschungen anzustellen, sollten Sie sich erst einmal mit den Daten vertraut machen, mit denen Sie arbeiten.

In diesem Abschnitt sehen Sie sich das Data Agent Kit-Panel manuell an, um sich einen Überblick zu verschaffen. Bevor Sie mit dem Abfragen Ihrer Daten beginnen, ist es wichtig, dass Sie sie verstehen.

BigQuery-Tabellen untersuchen

  1. Erweitern Sie im Bereich „Data Agent Kit“ unter KATALOG Ihr Projekt → BigQuery → cymbal_pets.
  2. Klicken Sie auf die Tabelle orders. Ein neuer Tab mit den Details der Tabelle wird geöffnet.
  3. Sehen Sie sich die Tabs auf der linken Seite des Tabellen-Viewers an:
    • Daten: Hier können Sie sich die tatsächlichen Zeilen ansehen. Scrollen Sie durch das Dataset und sehen Sie sich die Spalten an.
    • Schema: Sehen Sie sich die Spaltennamen und ‑typen an. Beachten Sie Felder wie order_type und promo_code, die später wichtig werden.
    • Andere Tabs (Details, Statistiken, Datenprofil usw.): Sie können auf Metadaten, Datenherkunft und Qualitätsdetails zugreifen, die Sie normalerweise in der Google Cloud Console finden, ohne den Editor zu verlassen.

BigQuery-Tabelle für Bestellungen

  1. Klicken Sie nun auf die Tabelle order_items und sehen Sie sich ihr Schema an. Beachten Sie die Felder quantity und price.

Cloud SQL-Tabellen untersuchen

Das Setupscript hat auch Kunden-, Haustier- und Produktdaten in einer PostgreSQL-Datenbank in Cloud SQL platziert.

  1. Klicken Sie im Bereich „Data Agent Kit“ unter dem Abschnitt KATALOG auf Universelle Suche.
  2. Geben Sie pet_profiles in das Suchfeld ein und drücken Sie die Eingabetaste.
  3. Klicken Sie in den Suchergebnissen auf das PostgreSQL-Tabellenergebnis für pet_profiles (unter der Cloud SQL-Instanz Ihres Projekts). Das Akkordeon in der Seitenleiste wird automatisch maximiert und zeigt Ihnen genau, wo sich die Tabelle im Datenbankbaum befindet. Klicken Sie nun in der Baumstruktur direkt darüber auf die Tabelle customers, um die Details zu öffnen, und sehen Sie sich die Tabs Schema und Details an.

Cloud SQL-Schema

Cloud Storage-Dateien ansehen

Schließlich werden Datensätze zu Marketing- und Werbekampagnen als rohe JSON-Dateien in Cloud Storage gespeichert.

  1. Erweitern Sie im linken Bereich „Data Agent Kit“ den Abschnitt CLOUD STORAGE. Suchen Sie den Rohdaten-Bucket Ihres Projekts (YOUR_PROJECT_ID-cymbal-pets-raw).
  2. Klicken Sie auf die Datei promo_events.json im Bucket. Ein neuer Editor-Tab wird geöffnet, auf dem Sie die JSON-Rohinhalte der Marketingkampagnen direkt in der IDE ansehen können.

Cloud Storage-Vorschau für promo_events.json

Inventur

Das wissen Sie jetzt über die Daten:

Dienst

Tabellen

Was ist da?

BigQuery

orders, order_items

~1,9 Mio.Aufträge, ~4,3 Mio.Werbebuchungen, Zeitraum 2023–2025

Cloud SQL

customers, pet_profiles, products

~92.000 Kunden, ~7.600 Haustierprofile, 206 Produkte

Cloud Storage

promo_events.json

Datensätze für Werbekampagnen

Die Daten sind auf drei Dienste verteilt. In einem herkömmlichen Workflow müssten Sie Verbindungen einrichten, Integrationscode schreiben und Ergebnisse manuell zusammenführen. Im nächsten Schritt lassen Sie den KI-Agenten all das in einer einzigen Unterhaltung erledigen.

Zusammenfassung des Abschnitts:Sie haben das Data Agent Kit-Panel verwendet, um die Datenarchitektur in BigQuery, Cloud SQL und Cloud Storage manuell zu untersuchen. Sie wissen jetzt, wo sich die Daten befinden und welche Felder verfügbar sind. Sie können also mit der Untersuchung beginnen.

5. Zahlen folgen

Jetzt beginnt die Untersuchung. Sie verwenden den Chatbereich, um den KI-Agenten zu bitten, Daten zum durchschnittlichen Bestellwert aus BigQuery abzurufen. Der durchschnittliche Bestellwert ist ein Unternehmensmesswert, der den durchschnittlichen Betrag in US-Dollar angibt, der pro Bestellung ausgegeben wird. Der Agent führt in Ihrem Namen Abfragen mit MCP-Tools aus. Sie können jede SQL-Abfrage sehen, die er ausführt.

Trend des durchschnittlichen Bestellwerts abrufen

  1. Geben Sie im Chatbereich auf der rechten Seite der IDE den folgenden Prompt ein und drücken Sie die Eingabetaste:
    Calculate our monthly average order value from August 2024 through January 2025
    using the orders and order_items tables in BigQuery.
    
  2. Berechtigungen für den Datenzugriff genehmigen: Es ist gut, vorsichtig zu sein, wenn KI-Agents Abfragen für Ihre Datenbanken ausführen. Mit dem Data Agent Kit behalten Sie die Kontrolle, da Sie vor dem Zugriff auf Daten um eine ausdrückliche Genehmigung gebeten werden. Wenn Sie dazu aufgefordert werden, können Sie Folgendes auswählen:
    • Dieses Mal erlauben:Genehmigt die einmalige Verwendung (ideal für die Überprüfung von Anfragen mit hohem Risiko).
    • Immer zulassen:Genehmigt die fortlaufende Verwendung dieses bestimmten Tools für die Sitzung.
    • Nein:Die Aktion wird vollständig blockiert.

Für eine reibungslose Nutzung des Labs sollten Sie Ja, immer zulassen auswählen. Hinweis:Berechtigungen werden für jedes Tool einzeln erteilt. Wahrscheinlich werden Sie in Kürze einige weitere Aufforderungen sehen, da der Kundenservicemitarbeiter neue Tools wie list_table_ids oder execute_sql_readonly verwendet. Sie können diese auch „immer zulassen“.

Aufforderung zur Erteilung der Berechtigung für das MCP-Tool

  1. Sehen Sie sich an, wie der Agent arbeitet. Der Chatbereich dient auch als Transparenzprotokoll für alle Aktionen des Agenten. Statt einer Blackbox zeigt der KI-Agent Ihnen seine Überlegungen und Aktionen in Echtzeit.
  2. Wenn der Agent fertig ist, klicken Sie unter Ihrem Prompt auf das Drop-down-Menü Worked for Xm, um das vollständige Arbeitslog zu maximieren. Hier können Sie genau nachvollziehen, wie die Antwort zustande gekommen ist:
    • Untersucht:Wenn Sie diese Elemente maximieren, sehen Sie, wie der Agent Dateien liest, Ordner durchsucht oder MCP-Tools wie datacloud_bigquery_remote / list_table_ids und execute_sql_readonly aufruft. Sie können die genauen JSON-Argumente sehen, die an die Tools übergeben wurden, und den ausgeführten SQL-Code.
    • Ausgeführt:Wenn Sie diese Elemente maximieren, sehen Sie alle Terminalbefehle, die der Agent ausgeführt hat, z. B. gcloud config list.

Agent-Transparenzlog mit MCP-Toolaufrufen

  1. Überprüfen Sie die Ergebnisse. Der KI-Agent sollte eine Tabelle mit monatlichen durchschnittlichen Bestellwerten zurückgeben. Sehen Sie sich die Zahlen selbst an: In den Vormonaten lag der Wert bei etwa 110 $, im Januar sank er auf etwa 103 $. Das ist die Anomalie, die der CFO gemeldet hat.

Nach Channel aufschlüsseln

Der durchschnittliche Bestellwert ist gesunken. Woher kommt dieser Rückgang? Das lässt sich ganz einfach herausfinden.

  1. Geben Sie im Chatbereich Folgendes ein:
    January looks lower than the prior months. 
    Break down January's AOV by order_type to see what's going on?
    
  2. Der Agent führt eine weitere BigQuery-Abfrage aus, diesmal gruppiert nach order_type. Sehen Sie sich die Ergebnisse genau an. Sie sollten etwas Auffälliges sehen: Der durchschnittliche Bestellwert für Online und Offline bleibt bei etwa 110 $. Es gibt jedoch einen neuen Channel, B2B-Wholesale, mit einem viel niedrigeren durchschnittlichen Bestellwert (etwa 75 $). Dieser neue Channel zieht den kombinierten Durchschnitt nach unten.
  3. Der Agent kann proaktiv vorschlagen, die B2B-Kunden zu untersuchen. Wenn nicht, ist das in Ordnung. Das machen Sie im nächsten Schritt.

Zusammenfassung des Abschnitts:Sie haben den AOV-Rückgang im Januar selbst anhand eines neutralen Datenabzugs erkannt und dann nach „order_type“ aufgeschlüsselt, um B2B-Wholesale als den neuen Channel zu identifizieren, der den kombinierten Durchschnittswert senkt. Als Nächstes müssen Sie herausfinden, wer diese B2B-Kunden sind.

6. Dienstgrenze überschreiten

Sie haben B2B-Wholesale als den anomalen Channel in BigQuery identifiziert, die Kundendaten befinden sich jedoch in Cloud SQL. Mit dem Data Agent Kit können Sie die Unterhaltung fortsetzen und die Dienstgrenze wird berücksichtigt.

B2B-Kunden untersuchen

  1. Geben Sie im Chatbereich Folgendes ein:
    Who are these B2B customers? Their profiles should be in our Cloud SQL database. 
    Check for:
    - Who they are
    - When they signed up
    - Whether they're new or existing customers
    
  2. Behalten Sie den Chatbereich im Blick. Dieses Mal sollte ein anderes MCP-Tool angezeigt werden. Der Agent fragt jetzt Cloud SQL anstelle von BigQuery ab. Der Agent stellt eine Verbindung zur Cloud SQL for Postgres-Instanz cymbal-pets-ops her und führt eine Abfrage für die Tabelle customers aus. Klicken Sie auf Details anzeigen, um den SQL-Code zu sehen.
  3. Überprüfen Sie die Ergebnisse. Der Agent sollte mehrere wichtige Erkenntnisse liefern:
    • Alle B2B-Kunden haben customer_type = 'Business'
    • Sie haben sich alle innerhalb der letzten 30 Tage (Januar 2025) angemeldet.
    • Die last_name-Werte sind Unternehmensnamen wie „Pet Supply Co“, „Animal Care LLC“ und „Happy Paws Inc“.
    • Es gibt etwa 100 Nutzer in dieser Kohorte, die es vor diesem Monat noch nicht gab.

Gutscheincode verknüpfen

  1. Der Agent stellt möglicherweise von selbst fest, dass viele B2B-Bestellungen in BigQuery einen promo_code-Wert von BIGORDER25 haben. Wenn das der Fall ist, umso besser. Die Untersuchung läuft.Wenn der Kundenservicemitarbeiter den Gutscheincode nicht erwähnt, weise ihn darauf hin:
    I noticed a promo_code field on the orders table in BigQuery. 
    Check what promo codes appear on the B2B-Wholesale orders?
    
  2. Der Kundenservicemitarbeiter fragt BigQuery noch einmal ab und stellt fest, dass etwa 92% der B2B-Großhandelsbestellungen promo_code = 'BIGORDER25' haben. Fast alle B2B-Aktivitäten sind an eine einzelne Werbekampagne gebunden.Der Agent sucht möglicherweise als Nächstes an anderer Stelle in der Umgebung nach Werbedaten. (Sie befindet sich in Cloud Storage.)

Zusammenfassung des Abschnitts:Der Agent hat Cloud SQL abgefragt und festgestellt, dass es sich bei den B2B-Kunden um neue Unternehmen handelt, die sich im Januar 2025 registriert haben. In Kombination mit dem BigQuery-Ergebnis, dass etwa 92% der Bestellungen promo_code = 'BIGORDER25' enthalten, deutet die Spur nun auf eine Werbekampagne hin. Zeit, die Quelle zu finden.

7. Das fehlende Teil finden

Zwei Probleme sind behoben, eines steht noch aus. Sie wissen, was passiert ist (B2B-Bestellungen senken den durchschnittlichen Bestellwert) und wer dafür verantwortlich ist (neue Geschäftskunden aus den letzten 30 Tagen). Jetzt müssen Sie herausfinden, warum, und die Antwort finden Sie in Cloud Storage.

GCS-Bucket prüfen

  1. Geben Sie im Chatbereich Folgendes ein:
    Good catch on the promo code. 
    We might have promotional campaign data in our GCS bucket. 
    Can you check what's there?
    
  2. Der Agent hat kein vorkonfiguriertes MCP-Tool für Cloud Storage. Daher wird automatisch auf das Terminaltool umgestellt, um gcloud storage-Befehle auszuführen. Sie werden um die Berechtigung zum Ausführen von Befehlen wie gcloud storage ls gebeten. Lassen Sie diese Befehle zu und maximieren Sie dann im Chatbereich das Ausgeführt-Log, um die genauen CLI-Befehle zu sehen, die zum Lesen und Parsen der Datei promo_events.json verwendet wurden.
  3. Der Kundenservicemitarbeiter sollte drei Werbekampagnen in der Datei identifizieren:

    Kampagne

    Gutscheincode

    Rabatt

    Ziel

    Daten

    Sommer-Sale für Haustierpflege

    PETSUMMER15

    15 % Rabatt

    Alle

    Juni 2024

    B2B Wholesale Push

    BIGORDER25

    25% Rabatt

    B2B

    Januar 2025

    Urlaubsbonus für Treuemitglieder

    LOYAL10

    10% Rabatt

    Treuemitglieder

    Dez. 2024

    Das ist die Ursache. Der Gutscheincode BIGORDER25 ist einer Kampagne mit dem Namen B2B Wholesale Push zugeordnet: 25% Rabatt für B2B-Kunden bei einer Mindestbestellmenge von 50 Einheiten.

Zusammenfassung

  1. Bitten Sie den Agenten, alles zusammenzufassen, was er gefunden hat:
    Put it all together. 
    What happened to our average order value?
    
  2. Der KI-Agent liefert eine klare, strukturierte Zusammenfassung, in der alle drei Datenquellen miteinander verknüpft werden. Darin sollte Folgendes erklärt werden:
    1. Der Rückgang des durchschnittlichen Bestellwerts ist real, aber er ist nicht auf einen Rückgang des bestehenden Geschäfts zurückzuführen. Der durchschnittliche Bestellwert (AOV) bleibt online und offline bei etwa 110 $.
    2. Im Januar 2025 wurde ein neuer B2B-Großhandelschannel eingeführt, mit etwa 25.000 Bestellungen zu einem viel niedrigeren durchschnittlichen Bestellwert (ca. 75–100 $).
    3. Die B2B-Kunden sind 100 neue Geschäftskonten, die sich alle in den letzten 30 Tagen registriert haben (Cloud SQL).
    4. Die Aktivität wird durch eine Werbekampagne („B2B Wholesale Push“) ausgelöst, die 25% Rabatt auf Großbestellungen mit einer Mindestmenge von 50 Einheiten (Cloud Storage) bietet.
    5. Der Umsatz ist unverändert, da das hohe Volumen an B2B-Bestellungen die niedrigeren Preise ausgleicht. Die Margen pro Einheit werden jedoch durch den Großhandelsrabatt von 25 % stark reduziert (um etwa 65 %). Dies gefährdet die Gesamtrentabilität erheblich, wenn Versand- und Betriebskosten berücksichtigt werden.
    Das ist der Moment, in dem die Ermittlungen Fahrt aufnehmen. Die Frage des CFO lässt sich eindeutig beantworten: Der durchschnittliche Bestellwert ist gesunken, weil im Januar durch ein marketingorientiertes B2B-Programm viele Bestellungen mit geringem Preis eingegangen sind. Das bestehende Unternehmen ist fehlerfrei.

Zusammenfassung des Abschnitts:Sie haben die Ursache in Cloud Storage gefunden: eine B2B-Werbekampagne mit 25% Rabatt auf Großbestellungen. Der Agent hat die Ergebnisse aller drei Dienste in einer klaren Geschichte zusammengefasst. Die Prüfungsphase ist abgeschlossen. Als Nächstes setzen Sie diese Erkenntnisse in die Praxis um.

8. Pipeline erstellen

Du hast den Fall gelöst. Nun möchte der CFO, dass diese Analyse automatisch aktualisiert wird. In diesem Abschnitt bitten Sie den Agent, ein dbt-Projekt zu erstellen, in dem die BigQuery-Daten als Staging-Version bereitgestellt und eine Fakttabelle für die laufende Analyse des durchschnittlichen Bestellwerts erstellt wird.

Hier wechselt der Agent von Ermittler zu Entwickler. Sie sehen, wie ein komplettes dbt-Projekt erstellt und die gesamte Pipeline ausgeführt wird – alles über einen einzigen Prompt.

dbt-Projekt erstellen

  1. Geben Sie im Chatbereich den folgenden Prompt ein. Diese Anleitung ist bewusst zielorientiert und nicht schrittweise. Sie sagen dem KI-Agenten was Sie möchten, nicht wie er es erstellen soll:
    I want to productionize our AOV analysis so it updates automatically. Build a dbt project that:
    1. Creates staging models for the BigQuery tables (orders and order_items) and a mart called fct_order_analysis that calculates AOV by channel and month
    2. Add a uniqueness test on order_id and run dbt build
    
  2. Selbstkorrektur beobachten: Wenn Sie das Protokoll "Worked for Ns" erweitern, sehen Sie möglicherweise, dass der Agent nach dbt sucht und, falls er feststellt, dass es fehlt, automatisch Befehle ausführt, um eine virtuelle Python-Umgebung (.venv) zu erstellen. Er kümmert sich um die Einrichtung der Umgebung für Sie!

Agent richtet virtuelle Umgebung ein

  1. Überprüfen Sie den Implementierungsplan: Der Agent wird einen formalen Implementierungsplan erstellen. Sie können die vorgeschlagenen Dateien und die Architektur prüfen, bei Bedarf Kommentare hinzufügen und auf Weiter klicken, damit der Agent den Plan ausführt.

Implementierungsplan für KI-Agenten

  1. Beobachten Sie den Chatbereich, während der Agent seinen Plan ausführt und die erforderlichen .sql-Dateien und YAML-Konfigurationen schreibt. Wenn der Vorgang abgeschlossen ist und das Projekt erfolgreich kompiliert wurde, wird eine Zusammenfassung der Änderungen angezeigt. Klicken Sie auf Alle annehmen, um diese Dateien Ihrem Arbeitsbereich hinzuzufügen.

Änderungen am Agent-Code annehmen

  1. Sehen Sie sich das neu generierte dbt-Projekt links im Explorer an. Die Struktur sollte in etwa so aussehen:
    dbt/
    ├── models/
       ├── marts/
          └── fct_order_analysis.sql
       └── staging/
           ├── schema.yml
           ├── sources.yml
           ├── stg_order_items.sql
           └── stg_orders.sql
    ├── dbt_project.yml
    └── profiles.yml
    

dbt-Projektstruktur im Datei-Explorer

  1. Klicken Sie auf die .sql-Modelldateien, um den vom Agent generierten SQL-Code zu prüfen. Achten Sie darauf, wie es mit
      umgeht.
    • Staging-Modelle: Bereinigte, umbenannte Spalten mit Quellverweisen
    • Das Mart-Modell: Die Join-Logik und die Berechnung des durchschnittlichen Bestellwerts nach Channel
    • Gast-Check-outs: Möglicherweise sehen Sie COALESCE(customer_type, 'Guest') oder gelockerte Null-Einschränkungen. Damit werden Käufe von Einzelhandelskunden ohne Konto modelliert und gültige Bestellumsätze beibehalten, anstatt unvollständige Datensätze zu verwerfen.
  1. Prüfen Sie im Chatbereich (oder klicken Sie auf das generierte Artefakt Walkthrough), ob der Agent bestätigt, dass alle Modelle materialisiert und alle Tests bestanden wurden. Die Ergebnisse für den durchschnittlichen Bestellwert aus dem MART sollten Ihre Erkenntnisse aus der Untersuchung bestätigen:
    - Online: ~$110
    - Offline: ~$110
    - B2B-Wholesale: ~$75 to $77
    

Zusammenfassung des Abschnitts:Der Agent hat ein dbt-Projekt aus einem einzigen zielorientierten Prompt erstellt: Er hat Staging- und Mart-Modelle erstellt, dbt build erfolgreich ausgeführt und die AOV-Anomalie bestätigt. Als Nächstes stellen Sie eine komplexere Frage, um zu sehen, wie der Agent damit umgeht.

9. Wenn Tests fehlschlagen, führt der Agent das Debugging durch

Die Pipeline funktioniert, verwendet aber nur BigQuery-Daten. Das Produktteam möchte die Analyse mit Kunden- und Haustierprofildaten aus Cloud SQL anreichern, um Produkte basierend auf Ernährungsbedürfnissen empfehlen zu können. Dies bedeutet, dass der Agent die Cloud SQL-Grenze und überbrücken muss, um einen subtilen Datenmodellierungsfehler zu beheben, nämlich einen klassischen dimensionalen Modellierungs-"Fan-Out"-Join.

Je nach verwendetem Modell und seinen Reasoning-Funktionen wird der Agent diese Anfrage auf eine von zwei Arten bearbeiten: Proaktives Vermeiden des Fehlers (Option A) oder Selbstkorrektur nach einem fehlgeschlagenen Test (Option B). Sehen wir uns an, welchen Pfad Ihr KI-Agent nimmt.

Anfrage auslösen

  1. Geben Sie im Chatbereich Folgendes ein:
    Enrich fct_order_analysis with customer data and pet profile data from our Cloud SQL database. 
    Include customer type and each customer's pets and dietary needs so we can recommend products. 
    Keep the uniqueness test on order_id and run dbt build.
    
  2. Sehen Sie sich an, wie der Agent arbeitet. Dabei werden die Cloud SQL-Tabellen ermittelt, die Daten in BigQuery überbrückt (über eine föderierte Abfrage oder eine materialisierte Kopie), neue Staging-Modelle erstellt und fct_order_analysis.sql geändert.

Option A: Der proaktive Kundenservicemitarbeiter (Vermeidung von Fehlern)

Bei Verwendung eines fortgeschrittenen Modells für logisches Schlussfolgern kann der Agent die Grain-Verschiebung bevor er Code schreibt erkennen. Da ein Kunde mehrere Haustiere haben kann, werden bei einem direkten Join Bestellungen dupliziert und der von Ihnen für order_id angeforderte Eindeutigkeitstest schlägt fehl.

  1. Proaktive Aggregation beobachten: Im Chatbereich oder im Walkthrough-Artefakt kann der Agent darauf hinweisen, dass er die Tierdaten vor dem Zusammenführen vorab aggregiert hat, um einen „klassischen Fan-Out“ zu verhindern. Dazu werden in der Regel mehrere Haustiere pro Kunde mithilfe einer Aggregationsfunktion (z.B. ARRAY_AGG() oder STRING_AGG()) zusammengefasst.
  2. Ergebnisse prüfen: Der dbt build wird beim ersten Versuch erfolgreich ausgeführt und bestanden, da der Agent die Granularität der Faktenübersicht proaktiv geschützt hat. Sie können dies überprüfen, indem Sie das generierte Walkthrough-Artefakt ansehen. Dort wird häufig die erfolgreiche Testausgabe zusammen mit den Abfrageergebnissen angezeigt.

Übersicht über die proaktive Aggregation und erfolgreiche Tests

Der KI-Agent hat den Fehler umgangen. Sehen Sie sich den generierten SQL-Code in fct_order_analysis.sql an, um zu sehen, wie die Aggregation strukturiert ist. Fahren Sie dann mit dem nächsten Abschnitt Antwort liefern fort.

Option B: Der Self-Healing-Agent (Debugging und Diagnose)

Wenn das Modell zuerst einen naiven direkten Left Join schreibt, wird die SQL-Abfrage selbst erfolgreich ausgeführt, aber die automatisierte dbt test-Suite erkennt die Änderung der Granularität.

  1. Fehlgeschlagenen Test beobachten: Der fehlgeschlagene Test wird in den Ausführungsfortschrittsprotokollen im Chatbereich gemeldet:
    Completed with 1 error
    
    Failure in test unique_fct_order_analysis_order_id
    Got 287 results, configured to fail if != 0
    
    Beim Eindeutigkeitstest für order_id wurden doppelte Einträge gefunden, da Kunden mit mehreren Haustieren die Bestellungen auf mehrere Bestellungen aufgeteilt haben.
  2. KI-Agenten diagnostizieren und selbst korrigieren lassen: Da der Test fehlgeschlagen ist, bitten Sie den KI-Agenten, ihn zu debuggen. Geben Sie im Chatbereich Folgendes ein:
    The uniqueness test failed. Can you figure out why and fix it?
    
  3. Diagnose ansehen: Der Agent fragt die Daten ab, erkennt die 1:n-Beziehung in pet_profiles, erklärt, dass durch das direkte Verknüpfen die Granularität von eine Zeile pro Bestellung in eine Zeile pro Bestellung pro Haustier geändert wird, und schreibt das Modell neu, um die Haustierprofile vorab zu aggregieren:
    -- Pre-aggregating pets per customer to resolve fan-out
    LEFT JOIN (
      SELECT
        customer_id,
        COUNT(*) AS num_pets,
        STRING_AGG(DISTINCT pet_type, ', ') AS pet_types,
        STRING_AGG(DISTINCT dietary_needs, ', ') AS dietary_needs
      FROM pet_profiles
      GROUP BY customer_id
    ) pet_agg ON c.customer_id = pet_agg.customer_id
    
  4. Fehlerbehebung überprüfen: Der Agent führt dbt build noch einmal aus. Dieses Mal werden alle Modelle materialisiert und alle Tests bestehen.

Zusammenfassung des Abschnitts:Unabhängig davon, ob Ihr Agent den Fehler proaktiv vermieden oder sich nach einem fehlgeschlagenen Test selbst behoben hat, hat er die Cloud SQL-Grenze überschritten, Kunden- und Haustierprofildaten integriert und in der Fakttabelle eine Zeile pro Bestellung beibehalten. Die Pipeline ist fertig und wurde getestet.

10. Antwort bereitstellen

Es ist Donnerstag. Sie haben die Woche mit einem besorgten CFO und verstreuten Daten in drei Cloud-Diensten begonnen. Sie haben jetzt die Ursache und eine Produktionspipeline. Zeit, die Antwort zu liefern, zusammen mit einer zukunftsorientierten Empfehlung, die durch eine quantitative Prognose gestützt wird.

Kurze Zusammenfassung schreiben

  1. Geben Sie im Chatbereich Folgendes ein:
    Write an executive summary covering:
    - Main findings and the quantitative margin impact
    - Project AOV for the subsequent quarter if the B2B program continues at its current trajectory
    - A data-driven recommendation
    
  2. Sehen Sie dem Agent bei der Arbeit zu.
  3. Sehen Sie sich die Zusammenfassung des KI-Agenten an. Eine typische und gut strukturierte Antwort sollte Folgendes enthalten:
    • Wichtigste Erkenntnis: Der durchschnittliche Bestellwert im Januar ist ausschließlich aufgrund des neuen B2B-Großhandelskanals gesunken. Online und Offline bleiben stabil bei rund 110 US-Dollar.
    • Hauptursache: Durch die Aktion „B2B Wholesale Push“ (25% Rabatt auf Großbestellungen) wurden 100 neue Konten gewonnen, was zu etwa 25.000 Bestellungen führte.
    • Auswirkungen auf die Marge: Durch Großhandelsbestellungen sank der durchschnittliche Gewinn pro Einheit um etwa 65% (von etwa 7,50 $ auf etwa 2,60 $).
    • Umsatz: Der Gesamtumsatz bleibt unverändert, da das hohe B2B-Volumen die niedrigeren Preise ausgleicht.

Durchschnittlichen Bestellwert mit AI.FORECAST vorhersagen

  1. Der Agent sollte auch eine zukunftsorientierte Prognose erstellen. Suchen Sie nach einem MCP-Tool-Aufruf, bei dem der Agent eine AI.FORECAST-Abfrage für BigQuery ausführt. Dazu wird das integrierte TimesFM-Foundation Model verwendet, um den durchschnittlichen Bestellwert basierend auf bisherigen Trends für die nächsten 90 Tage zu prognostizieren. Mit der Abfrage soll der durchschnittliche Bestellwert für die nächsten 90 Tage in zwei Szenarien prognostiziert werden: Fortsetzung der Kampagne (strukturell niedriger durchschnittlicher Bestellwert) und Beendigung der Kampagne (Erholung auf etwa 110 $).
  1. Sehen Sie sich die strategischen Empfehlungen des KI-Agenten an. Die Empfehlungen sollten Folgendes abdecken:
    • Rabatte neu strukturieren: Implementieren Sie Mindestmargen oder begrenzen Sie Mengenrabatte, um die Margen auf Einheitenebene zu schützen.
    • Strengere Mindestbestellmengen durchsetzen: So verhindern Sie, dass Einzelhandelskunden Großhandelspreise missbrauchen.
    • Separate Berichte: Verfolgen Sie die Einzelhandels- und B2B-Bereiche unabhängig voneinander, um die Einzelhandelsleistung nicht zu verschleiern.

Die ganze Geschichte

Was am Montag mit einer Übung aufgrund eines Rückgangs des durchschnittlichen Bestellwerts um 7% begann, hat für den CFO eine klare Lösung:

  • Einzelhandel: Die wichtigsten Einzelhandelskanäle sind weiterhin gesund und stabil.
  • Großhandelszufluss: Der Rückgang des durchschnittlichen Bestellwerts ist ausschließlich auf den neuen B2B-Großhandelskanal und die BIGORDER25-Kampagne zurückzuführen.
  • Auswirkung auf die Marge: Der Mengenrabatt von 25% hat die Margen pro Einheit stark geschmälert und die Rentabilität trotz eines gleichbleibenden Umsatzes gefährdet.
  • Strategische Prognose: Eine AI.FORECAST-Prognose zeigt, dass durch die Umstrukturierung der Großhandelsebenen der durchschnittliche Umsatz pro Bestellung wiederhergestellt wird.

Sie geben eine datengestützte Empfehlung ab, um Mindestmargen für den Großhandel und separate Berichte für den Einzelhandel/B2B-Bereich einzuführen.

Zusammenfassung des Abschnitts:Sie haben den Agent gebeten, eine Zusammenfassung für Führungskräfte mit einer Margenanalyse zu erstellen, eine AI.FORECAST-Prognose zu generieren und eine datengestützte Empfehlung zu geben. Die Prüfung ist abgeschlossen.

11. Bereinigen

Wenn Sie vermeiden möchten, dass Ihrem Google Cloud-Konto laufend Gebühren berechnet werden, löschen Sie die in diesem Codelab erstellten Ressourcen, indem Sie das Teardown-Script ausführen.

  1. Kehren Sie zu Google Cloud Shell zurück (wo Sie das Setupscript ausgeführt haben) und führen Sie das Teardown-Script aus:
cd ~/devrel-demos/codelabs/agentic-data-labs/scripts
chmod +x teardown.sh
./teardown.sh
  1. Im Skript werden alle Ressourcen angezeigt, die gelöscht werden sollen. Sie werden aufgefordert, die Aktion zu bestätigen, bevor sie ausgeführt wird:
    • Cloud SQL-Instanz (cymbal-pets-ops): Alle Tabellen
    • BigQuery-Datasets (cymbal_pets, dbt_marts): Alle Tabellen und Modelle
    • Cloud Storage-Bucket (gs://YOUR_PROJECT_ID-cymbal-pets-raw)
    • BigQuery-Verbindung (cymbal-pets-cloudsql)
  2. Geben Sie zur Bestätigung y ein. Das Zerlegen dauert etwa 2 bis 3 Minuten.
[INFO]  Deleting BigQuery dataset cymbal_pets...
[ OK ]  BigQuery dataset cymbal_pets deleted.
[INFO]  Deleting BigQuery dataset dbt_marts...
[ OK ]  BigQuery dataset dbt_marts deleted.
[INFO]  Deleting GCS bucket gs://YOUR_PROJECT_ID-cymbal-pets-raw...
[ OK ]  GCS bucket deleted.
[INFO]  Deleting BigQuery connection cymbal-pets-cloudsql...
[ OK ]  BQ connection deleted.
[INFO]  Deleting Cloud SQL instance cymbal-pets-ops...
[ OK ]  Cloud SQL instance deleted.

12. Glückwunsch!

Sie haben The Cymbal Pets Investigation erfolgreich abgeschlossen. Sie haben aus einer vagen Frage des CFO eine vollständig operationalisierte, auf Prognosen basierende Empfehlung gemacht, indem Sie einen KI-Agenten verwendet haben, der für alle Ihre Google Cloud-Daten funktioniert.

Ihre Erfolge

  1. 🔍 Dienstübergreifend untersucht: Assets in BigQuery, Cloud SQL und Cloud Storage wurden mithilfe des Data Agent Kit-Knowledge Catalog ermittelt und in der Vorschau angezeigt.
  2. 🕵️‍♂️ Mit KI untersucht: Es wurden mehrere Dienste in einem einzigen Chatfenster mit MCP-Tools abgefragt, um die Anomalie beim durchschnittlichen Bestellwert auf eine B2B-Werbekampagne zurückzuführen.
  3. 🔧 Produktionspipeline erstellt: Ein vollständiges dbt-Projekt wurde erstellt, um Bestell- und Kundendaten zu bereinigen, zusammenzuführen und zu testen.
  4. 🐛 Fan-out-Fehler behoben: Der Agent hat automatisch ein Granularitätsproblem diagnostiziert und das dbt-SQL-Modell umgestaltet, um Kundenprofile für Haustiere vorab zu aggregieren.
  5. 📈 Prognostiziert und empfohlen: Das integrierte AI.FORECAST von BigQuery wurde verwendet, um AOV-Trends zu modellieren und dem CFO eine datengestützte Empfehlung zu geben.

Wichtige Konzepte

Konzept

Das haben Sie gelernt

MCP-Tools

Sichere, prüfbare Verbindungen, mit denen der KI-Agent in Ihrem Namen Dienste wie BigQuery, Cloud SQL, Spanner und andere Datenbanken abfragen kann. Jeder Aufruf ist im Chatbereich sichtbar.

KI-Agenten-Skills

Vordefinierte Anweisungssätze (z. B. dbt-bigquery oder discovering-gcp-data-assets), die dem Agenten domainspezifische Best Practices vermitteln, ohne dass Sie sie explizit anfordern müssen

Dienstübergreifende Untersuchung

Der Agent fragt mehrere Google Cloud-Dienste in einem einzigen Gespräch ab, ohne dass eine Verbindung eingerichtet oder zwischen Konsolen gewechselt werden muss.

Zielorientierte Prompts

Dem Agenten mitteilen, was Sie möchten („Erstelle ein dbt-Projekt, in dem der durchschnittliche Bestellwert nach Channel berechnet wird“), anstatt wie, und ihm die Wahl des Implementierungsansatzes überlassen

Data Agent Kit

Die Erweiterung, die alles zusammenbindet, von MCP-Tools und Agent-Skills bis hin zur Datenermittlung, und Ihnen Zugriff auf alle Ihre Google Cloud-Daten direkt in Ihrer bevorzugten IDE bietet.

Nächste Schritte