Resumen
Este flujo de trabajo describes un n8n pipeline ese enriquece CRM leads diario con fresh search datos de Scavio. El Programar Activar fires diario, lee leads de Airtable o un base de datos, consultas Scavio Google for cada lead's company o producto, y escribe enriquecimiento datos back. All search nodes usar el same Scavio HTTP Solicitud configuracion for easy maintenance.
Desencadenador
n8n Programar Activar (diario at 9 AM UTC)
Programación
Ejecuta diario at 9:00 AM UTC (n8n Programar Activar)
Pasos del flujo de trabajo
Programar activar fires
n8n Programar Activar inicia el flujo de trabajo diario at 9 AM UTC.
Leer leads de Airtable
Airtable node lee leads ese necesita enriquecimiento (estado = pending).
Search via Scavio
HTTP Solicitud node calls Scavio Google for cada lead's company nombre.
Analizar enriquecimiento datos
Code node extrae relevante datos de Scavio respuesta: fragmentos, AI Overview, enlaces.
Actualizar Airtable
Escribir enriquecimiento datos back to Airtable y establecer estado = enriquecido.
Implementacion en Python
import requests
import json
API_KEY = "your_scavio_api_key"
def enrich_leads(leads: list[dict]) -> list[dict]:
"""Simulates the n8n pipeline in Python.
n8n equivalent: Schedule -> Airtable Read -> HTTP Request (Scavio) -> Code -> Airtable Update
"""
enriched = []
for lead in leads:
res = requests.post(
"https://api.scavio.dev/api/v1/search",
headers={"x-api-key": API_KEY},
json={"platform": "google", "query": lead["company"], "ai_overview": True},
timeout=15,
)
if not res.ok:
continue
data = res.json()
ai_text = data.get("ai_overview", {}).get("text", "")
snippets = [r.get("snippet", "") for r in data.get("organic", [])[:3]]
lead["enrichment"] = {
"ai_overview": ai_text[:300],
"top_snippets": snippets,
"enriched_at": "2026-05-21",
}
enriched.append(lead)
print(f"Enriched {len(enriched)}/{len(leads)} leads")
return enriched
leads = [
{"id": 1, "company": "Acme Corp"},
{"id": 2, "company": "Widget Inc"},
]
enrich_leads(leads)Implementacion en JavaScript
const API_KEY = "your_scavio_api_key";
async function enrichLeads(leads) {
for (const lead of leads) {
const res = await fetch("https://api.scavio.dev/api/v1/search", {
method: "POST",
headers: { "x-api-key": API_KEY, "content-type": "application/json" },
body: JSON.stringify({ platform: "google", query: lead.company, ai_overview: true }),
});
if (!res.ok) continue;
const data = await res.json();
lead.enrichment = {
aiOverview: (data.ai_overview?.text ?? "").slice(0, 300),
snippets: (data.organic ?? []).slice(0, 3).map((r) => r.snippet ?? ""),
};
}
console.log(`Enriched ${leads.length} leads`);
return leads;
}
await enrichLeads([{ company: "Acme Corp" }]);Plataformas utilizadas
Búsqueda web con grafo de conocimiento, PAA y resúmenes de IA