通过添加搜索丰富步骤来修复 n8n 中薄弱的外展个性化问题，该步骤会在电子邮件生成之前拉取最近的潜在客户活动。像使用名字和公司名称这样的通用个性化设置会被忽略。有效的个性化涉及特定的内容：最近的博客文章、融资公告、产品发布或会议演讲。通过在起草电子邮件之前查询每个潜在客户的搜索 API，您的 n8n 工作流程可以生成引用真实的近期事件的真正个性化的开场白。
前置条件
- 正在运行的 n8n 实例（自托管或 n8n 云）
- 来自 scavio.dev 的 Scavio API 密钥
- 包含姓名和公司的潜在客户名单
- n8n中配置的电子邮件发送节点
操作指南
步骤 1: 搜索潜在客户活动
查询潜在客户的姓名和公司以查找最近的公开活动。
Python
import os, requests
API_KEY = os.environ['SCAVIO_API_KEY']
def find_prospect_activity(name: str, company: str) -> list:
resp = requests.post('https://api.scavio.dev/api/v1/search',
headers={'x-api-key': API_KEY},
json={'platform': 'google', 'query': f'{name} {company} 2026'}, timeout=15)
results = resp.json().get('organic_results', [])
activities = []
for r in results[:5]:
activities.append({
'title': r.get('title', ''),
'snippet': r.get('snippet', ''),
'url': r.get('link', ''),
'type': classify_activity(r),
})
return activities
def classify_activity(result: dict) -> str:
title = (result.get('title', '') + result.get('snippet', '')).lower()
if any(w in title for w in ['blog', 'article', 'wrote', 'published']):
return 'content'
if any(w in title for w in ['spoke', 'conference', 'keynote', 'panel']):
return 'speaking'
if any(w in title for w in ['raised', 'funding', 'series', 'launch']):
return 'news'
return 'mention'
activities = find_prospect_activity('Jane Smith', 'Acme Corp')
for a in activities:
print(f"[{a['type']}] {a['title'][:60]}")步骤 2: 搜索公司新闻
提取最近的公司新闻以查找相关事件以进行个性化设置。
Python
def get_company_news(company: str) -> list:
resp = requests.post('https://api.scavio.dev/api/v1/search',
headers={'x-api-key': API_KEY},
json={'platform': 'google', 'query': f'{company} news announcement 2026'}, timeout=15)
results = resp.json().get('organic_results', [])
return [{
'headline': r.get('title', ''),
'snippet': r.get('snippet', '')[:150],
'url': r.get('link', ''),
} for r in results[:3]]
news = get_company_news('Acme Corp')
for n in news:
print(f" {n['headline'][:60]}")步骤 3: 选择最佳的个性化挂钩
对发现的活动和新闻项目进行排名，以选择最强的个性化角度。
Python
def select_hook(activities: list, news: list) -> dict:
# Prioritize: content > speaking > news > mention
priority = {'content': 1, 'speaking': 2, 'news': 3, 'mention': 4}
sorted_activities = sorted(activities, key=lambda a: priority.get(a['type'], 5))
if sorted_activities:
best = sorted_activities[0]
return {
'type': best['type'],
'reference': best['title'],
'url': best['url'],
'snippet': best['snippet'][:100],
}
if news:
return {
'type': 'company_news',
'reference': news[0]['headline'],
'url': news[0]['url'],
'snippet': news[0]['snippet'][:100],
}
return {'type': 'none', 'reference': '', 'url': '', 'snippet': ''}
hook = select_hook(activities, news)
print(f"Best hook: [{hook['type']}] {hook['reference'][:60]}")步骤 4: 生成个性化开场白
创建一个电子邮件开场白，引用找到的特定活动或新闻项目。
Python
def personalized_opener(name: str, company: str, hook: dict) -> str:
first_name = name.split()[0] if name else 'there'
if hook['type'] == 'content':
return f"Hi {first_name}, I came across your piece \"{hook['reference'][:50]}\" and it resonated with something we have been working on."
if hook['type'] == 'speaking':
return f"Hi {first_name}, I noticed your talk at {hook['reference'][:40]} and wanted to connect."
if hook['type'] in ('news', 'company_news'):
return f"Hi {first_name}, saw the news about {company} - {hook['reference'][:40]}. Congrats on the milestone."
return f"Hi {first_name}, I have been following {company}'s work and wanted to reach out."
opener = personalized_opener('Jane Smith', 'Acme Corp', hook)
print(opener)步骤 5: 批量丰富线索名单
处理整个潜在客户列表并为每个列表输出个性化的开场白。
Python
import time
def enrich_leads(leads: list) -> list:
enriched = []
for lead in leads:
activities = find_prospect_activity(lead['name'], lead['company'])
news = get_company_news(lead['company'])
hook = select_hook(activities, news)
opener = personalized_opener(lead['name'], lead['company'], hook)
enriched.append({
**lead,
'hook_type': hook['type'],
'hook_reference': hook['reference'][:80],
'personalized_opener': opener,
})
print(f"{lead['name']}: [{hook['type']}] {hook['reference'][:40]}")
time.sleep(0.5)
return enriched
test_leads = [
{'name': 'Jane Smith', 'company': 'Acme Corp', 'email': '[email protected]'},
{'name': 'John Doe', 'company': 'Beta Inc', 'email': '[email protected]'},
]
results = enrich_leads(test_leads)Python 示例
Python
import requests, os
H = {'x-api-key': os.environ['SCAVIO_API_KEY']}
def personalize(name, company):
data = requests.post('https://api.scavio.dev/api/v1/search', headers=H,
json={'platform': 'google', 'query': f'{name} {company} 2026'}).json()
top = data.get('organic_results', [{}])[0]
return f"Re: {top.get('title', 'your recent work')[:50]}"
print(personalize('Jane Smith', 'Acme Corp'))JavaScript 示例
JavaScript
const H = {'x-api-key': process.env.SCAVIO_API_KEY, 'Content-Type': 'application/json'};
async function personalize(name, company) {
const r = await fetch('https://api.scavio.dev/api/v1/search', {
method: 'POST', headers: H,
body: JSON.stringify({platform: 'google', query: `${name} ${company} 2026`})
});
const top = ((await r.json()).organic_results || [{}])[0];
return `Re: ${(top.title || 'your recent work').slice(0, 50)}`;
}
personalize('Jane Smith', 'Acme Corp').then(console.log);预期输出
JSON
An n8n-compatible outreach personalization pipeline that enriches each lead with real prospect activity and company news, generating specific personalized email openers.