	In Browser
	StumbleUpon
	del.icio.us
	Google
	Google Buzz
	reddit
	LinkedIn

	Facebook
	Twitter
	Linkedin
	E-Mail

Generative AI > Google Gemini API > Abandoned Cart Recovery Agent

Abandoned Cart Recovery Agent

Author: Venkata Sudhakar

ShopMax India loses significant revenue each week to abandoned carts. A customer adds a Samsung TV or Apple iPad to their cart, gets distracted, and never completes the purchase. An automated recovery agent that detects these drop-offs within hours and sends a personalised, time-sensitive message can recover 15-25% of that lost revenue without any manual effort.

This tutorial builds an Abandoned Cart Recovery Agent using ADK and Gemini. The agent scans carts abandoned for more than 2 hours, scores each by recovery priority using cart value and customer tier, and generates a personalised outreach message with a targeted incentive.

The below example shows the recovery workflow for ShopMax India abandoned carts.

from google.adk.agents import LlmAgent
from google.adk.tools import FunctionTool
from google.adk.runners import Runner
from google.adk.sessions import InMemorySessionService
import datetime

# --- Simulated abandoned cart data ---
ABANDONED_CARTS = [
    {
        "cart_id": "CART-001",
        "customer_id": "CUST-101",
        "customer_name": "Vikram Nair",
        "city": "Hyderabad",
        "customer_tier": "Gold",
        "items": [{"sku": "SKU-1001", "name": "Samsung 55-inch 4K TV", "price": 62000}],
        "cart_value": 62000,
        "abandoned_hours_ago": 3,
        "previous_purchases": 8,
    },
    {
        "cart_id": "CART-002",
        "customer_id": "CUST-102",
        "customer_name": "Sneha Pillai",
        "city": "Pune",
        "customer_tier": "Silver",
        "items": [
            {"sku": "SKU-1002", "name": "Sony WH-1000XM5 Headphones", "price": 29000},
            {"sku": "SKU-1004", "name": "Bose SoundLink Speaker", "price": 15500},
        ],
        "cart_value": 44500,
        "abandoned_hours_ago": 5,
        "previous_purchases": 2,
    },
    {
        "cart_id": "CART-003",
        "customer_id": "CUST-103",
        "customer_name": "Arjun Menon",
        "city": "Chennai",
        "customer_tier": "Bronze",
        "items": [{"sku": "SKU-1004", "name": "Bose SoundLink Speaker", "price": 15500}],
        "cart_value": 15500,
        "abandoned_hours_ago": 8,
        "previous_purchases": 1,
    },
]

# --- Tool: get abandoned carts ---
def get_abandoned_carts(min_value: int = 0) -> dict:
    """Fetch all carts abandoned for more than 2 hours.
    Args:
        min_value: Minimum cart value in Rs (default 0 = all carts)
    Returns:
        List of abandoned carts with customer details
    """
    carts = [c for c in ABANDONED_CARTS if c["cart_value"] >= min_value]
    return {"total_carts": len(carts), "total_value": sum(c["cart_value"] for c in carts), "carts": carts}

# --- Tool: score recovery priority and generate incentive ---
def score_cart_recovery(cart_id: str) -> dict:
    """Score a cart for recovery priority and suggest incentive.
    Args:
        cart_id: Cart identifier
    Returns:
        Priority score, incentive offer, and recommended channel
    """
    cart = next((c for c in ABANDONED_CARTS if c["cart_id"] == cart_id), None)
    if not cart:
        return {"error": f"Cart not found: {cart_id}"}
    score = 0
    # Cart value scoring
    if cart["cart_value"] >= 50000:
        score += 40
    elif cart["cart_value"] >= 20000:
        score += 25
    else:
        score += 10
    # Customer tier scoring
    tier_scores = {"Gold": 30, "Silver": 20, "Bronze": 10}
    score += tier_scores.get(cart["customer_tier"], 10)
    # Recency scoring (sooner = better recovery chance)
    if cart["abandoned_hours_ago"] <= 3:
        score += 30
    elif cart["abandoned_hours_ago"] <= 6:
        score += 20
    else:
        score += 10
    # Incentive based on tier and value
    if cart["customer_tier"] == "Gold" or cart["cart_value"] >= 50000:
        incentive = "5% off + free delivery"
    elif cart["cart_value"] >= 20000:
        incentive = "3% off coupon SAVE3"
    else:
        incentive = "free delivery on this order"
    return {
        "cart_id": cart_id,
        "customer_name": cart["customer_name"],
        "cart_value": cart["cart_value"],
        "priority_score": score,
        "priority": "HIGH" if score >= 70 else ("MEDIUM" if score >= 50 else "LOW"),
        "incentive": incentive,
        "items": cart["items"],
    }

# --- Agent setup ---
carts_tool = FunctionTool(func=get_abandoned_carts)
score_tool = FunctionTool(func=score_cart_recovery)

agent = LlmAgent(
    name="cart_recovery_agent",
    model="gemini-2.0-flash",
    instruction="""You are an abandoned cart recovery agent for ShopMax India.
1. Call get_abandoned_carts to fetch all pending carts.
2. For each cart, call score_cart_recovery to get priority and incentive.
3. Process HIGH priority carts first.
4. For each cart, write a short, warm, personalised WhatsApp/email message (2-3 sentences)
   addressing the customer by first name, mentioning the specific product left in their cart,
   and including the incentive offer with a sense of urgency (limited time).
Keep messages friendly, not pushy. Use Rs for currency.""",
    tools=[carts_tool, score_tool],
)

session_service = InMemorySessionService()
runner = Runner(agent=agent, app_name="cart_recovery", session_service=session_service)

import asyncio

async def run_recovery(query: str) -> str:
    session = await session_service.create_session(app_name="cart_recovery", user_id="marketing")
    from google.genai.types import Content, Part
    msg = Content(role="user", parts=[Part(text=query)])
    result = ""
    async for event in runner.run_async(user_id="marketing", session_id=session.id, new_message=msg):
        if event.is_final_response() and event.content:
            result = event.content.parts[0].text
    return result

response = asyncio.run(run_recovery("Review all abandoned carts and generate recovery messages for each, highest priority first."))
print(response)

It gives the following output,

Abandoned Cart Recovery - ShopMax India
3 carts found  |  Total value at risk: Rs 1,22,000

--- CART-001 | HIGH PRIORITY (score: 100) ---
Customer: Vikram Nair, Hyderabad (Gold tier)
Cart: Samsung 55-inch 4K TV - Rs 62,000
Incentive: 5% off + free delivery

Message: Hi Vikram, your Samsung 55-inch 4K TV is still waiting for you!
As a valued Gold member, we are offering you an exclusive 5% discount plus
free delivery - just for today. Complete your order before midnight:
shopmax.in/cart/CART-001

--- CART-002 | MEDIUM PRIORITY (score: 65) ---
Customer: Sneha Pillai, Pune (Silver tier)
Cart: Sony Headphones + Bose Speaker - Rs 44,500
Incentive: 3% off coupon SAVE3

Message: Hi Sneha, great taste - the Sony WH-1000XM5 and Bose SoundLink
are a perfect combo! Use code SAVE3 at checkout to save Rs 1,335.
Offer valid for 24 hours: shopmax.in/cart/CART-002

--- CART-003 | LOW PRIORITY (score: 30) ---
Customer: Arjun Menon, Chennai (Bronze tier)
Cart: Bose SoundLink Speaker - Rs 15,500
Incentive: Free delivery

Message: Hi Arjun, your Bose SoundLink Speaker is still in your cart!
Complete your order today and we will cover the delivery - free.
shopmax.in/cart/CART-003

In production, trigger this agent via a Cloud Scheduler job every 2 hours. Integrate with your WhatsApp Business API or email service to dispatch messages automatically, and log each recovery attempt in Firestore to avoid sending duplicate messages to the same customer.

Send your comments, suggestions or queries regarding this site to [email protected].