Live
OpenCode 2.0 Unifies Interfaces with a Shared Background Service for Better Automation and ObservabilityAgentic Data Pipelines: Using the Data Agent Kit to Build End‑to‑End Fraud Detection WorkflowsRunning AI‑Generated Looker Data Apps at Enterprise ScaleRunning llama.cpp Decision Models on SageMaker: Architecture and Ops GuideGPU Sharing on Kubernetes Forces Teams to Build Their Own Metrics, Rightsizing, and GuardrailsDeploying Existing Node.js HTTP Servers with Lambda Web FunctionsImplementing ML-DSA Signing on AWS for a Quantum‑Resistant Software Supply ChainEnforcing ML‑DSA Algorithm Policy with SCPs and IAM on AWSOpenCode 2.0 Unifies Interfaces with a Shared Background Service for Better Automation and ObservabilityAgentic Data Pipelines: Using the Data Agent Kit to Build End‑to‑End Fraud Detection WorkflowsRunning AI‑Generated Looker Data Apps at Enterprise ScaleRunning llama.cpp Decision Models on SageMaker: Architecture and Ops GuideGPU Sharing on Kubernetes Forces Teams to Build Their Own Metrics, Rightsizing, and GuardrailsDeploying Existing Node.js HTTP Servers with Lambda Web FunctionsImplementing ML-DSA Signing on AWS for a Quantum‑Resistant Software Supply ChainEnforcing ML‑DSA Algorithm Policy with SCPs and IAM on AWS
Google Cloud

Agentic Data Pipelines: Using the Data Agent Kit to Build End‑to‑End Fraud Detection Workflows

AI SummaryPowered by AI

The Data Agent Kit introduces IDE‑integrated agent assistance and pre‑packaged skills that let you generate and run data‑ingestion notebooks, query BigQuery, and deploy Airflow pipelines without leaving your editor. This reduces context switching for AI, cloud, and DevOps engineers and reshapes the operational flow for data‑driven fraud detection.

The Data Agent Kit adds a layer of agent‑driven automation directly inside your development environment, allowing you to ask an agent to create a PySpark notebook, load raw logs from Cloud Storage into BigQuery, and schedule the resulting pipeline—all from the same IDE. For engineers who already juggle data preparation, model training, and pipeline orchestration, the kit promises a tighter feedback loop and fewer hand‑offs.

What Changed with the Data Agent Kit

Two concrete capabilities are introduced:

  • Agent help files: Markdown‑based skill files describe best practices for the underlying data stack and are consumed by the agent at runtime.
  • IDE tooling: A VS Code‑compatible extension surfaces Google’s Agentic Data Cloud services—query editors, Airflow deployment helpers, and Spark runtime selectors—without leaving the code window.

These pieces work together so that a natural‑language request to the agent can be turned into executable code that runs on managed services.

Why It Matters to Engineers

AI and data scientists gain a shortcut for repetitive data‑engineering steps, while cloud and platform engineers see a new pattern for exposing service‑level operations to an agent. DevOps and SRE staff can incorporate the generated notebooks into CI/CD pipelines, and security engineers obtain a single point of visibility for data‑access actions performed by the agent.

Architectural and Operational Implications

In the illustrated fraud‑detection scenario, the workflow follows these steps:

  1. Store raw JSON transaction logs in gs://financials-clearing-raw/.
  2. Ask the agent to create a notebook that reads the logs with Spark and writes to a BigQuery table transactions.raw_transactions.
  3. Run the notebook on a pre‑configured Spark Serverless runtime launched from the IDE.
  4. Inspect the resulting BigQuery table using the extension’s table‑browser UI.

The request that triggers step 2 is captured in the source as a structured prompt. A minimal representation can be shown as:

Create a PySpark notebook to ingest JSON transaction logs from gs://financials-clearing-raw/ into the BigQuery table transactions.raw_transactions.

From an architecture perspective, the kit does not replace existing services; it merely adds a thin orchestration layer that translates natural‑language intent into API calls for Spark, BigQuery, and Airflow. Operationally, the generated notebooks run on managed Spark, so the underlying cluster lifecycle is handled by Google Cloud, reducing the need for manual provisioning. However, the agent’s execution still requires appropriate IAM permissions on the storage bucket, BigQuery dataset, and any Airflow resources, so credential scopes must be reviewed.

Because the agent operates inside the developer’s IDE, audit trails are tied to IDE activity rather than separate service logs. Teams should consider integrating IDE audit data with existing security information and event management (SIEM) pipelines if visibility is required.

Related CloudNinjas coverage: Google Cloud.

What This Means For Practitioners

Adopt the Data Agent Kit when you need rapid prototyping of data pipelines that involve Cloud Storage, Spark, and BigQuery, and you already use VS Code‑based environments. Verify that the agent’s skill files reflect your organization’s data‑handling policies, and ensure that the service accounts used by the agent have the least‑privilege permissions needed for each step. Incorporate the generated notebooks into version control and CI pipelines to retain reproducibility. Finally, monitor IDE‑level audit logs alongside Cloud audit logs to maintain a complete picture of who triggered data‑ingestion actions.

Originally published atGoogle Cloud Blog