菜单
Apply production-ready Apollo.io SDK patterns. Use when implementing Apollo integrations, refactoring API usage, or establishing team coding standards. Trigger with phrases like "apollo sdk patterns", "apollo best practices", "apollo code patterns", "idiomatic apollo", "apollo client wrapper".
默认使用会先检查来源的 Prompt；你也可以切换为直接命令，或下载本地副本。
决定是否安装前，请先阅读 SKILL.md，以及 SkillsMP 当前展示的配套文件。
用 Codex 或 Claude 帮你安装 复制这段 Prompt，粘贴到 Codex、Claude 或其他助手里，让它检查 Skill 页面并帮你完成安装。
直接命令不会经过审查 Prompt；运行前请先检查来源。
npx skills add https://github.com/ComeOnOliver/skillshub --skill apollo-sdk-patterns命令会保持在同一行。复制前请横向滚动并检查完整内容。
想先保存到本地？可下载 SkillsMP 当前能够提供的文件。
Review product and feature risk before an AI coding agent starts implementation.
Use Xquik for X data and confirmation-gated X actions: tweet search, user lookup, follower export, media download, monitors, webhooks, MCP, and SDK workflows.
Canton Network open-source ecosystem guide covering DAML SDK, Canton runtime, and Splice applications. Use when working with Canton Network, DAML smart contracts, or building decentralized applications.
基于 SOC 职业分类
正在显示 SKILL.md
| name | apollo-sdk-patterns |
| description | Apply production-ready Apollo.io SDK patterns. Use when implementing Apollo integrations, refactoring API usage, or establishing team coding standards. Trigger with phrases like "apollo sdk patterns", "apollo best practices", "apollo code patterns", "idiomatic apollo", "apollo client wrapper". |
| allowed-tools | Read, Write, Edit |
| version | 1.0.0 |
| license | MIT |
| author | Jeremy Longshore <jeremy@intentsolutions.io> |
| compatible-with | claude-code, codex, openclaw |
| tags | ["saas","apollo","api"] |
Production-ready patterns for Apollo.io API integration. Apollo has no official SDK — these patterns wrap the REST API (https://api.apollo.io/api/v1/) with type safety, retry logic, pagination, and bulk operations. All requests use the x-api-key header.
apollo-install-auth setup// src/apollo/client.ts
import axios, { AxiosInstance } from 'axios';
import { z } from 'zod';
const ConfigSchema = z.object({
apiKey: z.string().min(10, 'API key too short'),
baseURL: z.string().url().default('https://api.apollo.io/api/v1'),
timeout: z.number().default(30_000),
});
let instance: AxiosInstance | null = null;
export function getApolloClient(config?: Partial<z.input<typeof ConfigSchema>>): AxiosInstance {
if (instance) instance;
parsed = .({
: config?. ?? process..,
...config,
});
instance = axios.({
: parsed.,
: parsed.,
: {
: ,
: parsed.,
},
});
instance;
}
() { instance = ; }
// src/apollo/errors.ts
import { AxiosError } from 'axios';
export class ApolloApiError extends Error {
constructor(
message: string,
public statusCode: number,
public endpoint: string,
public retryable: boolean,
public requestId?: string,
) {
super(message);
this.name = 'ApolloApiError';
}
static fromAxios(err: AxiosError): ApolloApiError {
const status = err.response?.status ?? 0;
const body = err.response?.data as any;
return new ApolloApiError(
body?.message ?? err.message,
status,
err.config?.url ?? 'unknown',
[429, 500, 502, 503, 504].includes(status),
err.response?.headers?.['x-request-id'],
);
}
}
export class ApolloRateLimitError extends ApolloApiError {
constructor(
public retryAfterMs: number,
endpoint: string,
) {
super(`Rate limited on ${endpoint}`, 429, endpoint, true);
this.name = 'ApolloRateLimitError';
}
}
// src/apollo/retry.ts
import { ApolloApiError } from './errors';
export async function withRetry<T>(
fn: () => Promise<T>,
opts: { maxRetries?: number; baseMs?: number; maxMs?: number } = {},
): Promise<T> {
const { maxRetries = 3, baseMs = 1000, maxMs = 30_000 } = opts;
for (let attempt = 0; attempt <= maxRetries; attempt++) {
try {
return await fn();
} catch (err) {
const isRetryable = err instanceof ApolloApiError && err.retryable;
if (!isRetryable || attempt === maxRetries) throw err;
const jitter = Math.random() * 500;
const delay = Math.min(baseMs * 2 ** attempt + jitter, maxMs);
await new Promise((r) => setTimeout(r, delay));
}
}
throw new Error('Unreachable');
}
Apollo endpoints return pagination.total_entries and accept page/per_page. The People Search API limits to 500 pages (50,000 records).
// src/apollo/paginator.ts
import { getApolloClient } from './client';
import { withRetry } from './retry';
export async function* paginate<T>(
endpoint: string,
body: Record<string, unknown>,
itemKey: string = 'people',
perPage: number = 100,
maxPages: number = 500,
): AsyncGenerator<T[], void, undefined> {
const client = getApolloClient();
let page = 1;
let totalPages = Infinity;
while (page <= Math.min(totalPages, maxPages)) {
const { data } = await withRetry(() =>
client.post(endpoint, { ...body, page, per_page: perPage }),
);
const items: T[] = data[itemKey] ?? [];
totalPages = data.pagination?.total_pages ?? 1;
if (items.length === 0) break;
yield items;
page++;
}
}
// Usage:
// for await (const batch of paginate('/mixed_people/api_search', {
// q_organization_domains_list: ['stripe.com'],
// })) {
// await processBatch(batch);
// }
Apollo's Bulk People Enrichment endpoint handles up to 10 records per call.
// src/apollo/bulk-enrich.ts
import { getApolloClient } from './client';
import { withRetry } from './retry';
interface EnrichmentDetail {
email?: string;
linkedin_url?: string;
first_name?: string;
last_name?: string;
organization_domain?: string;
}
export async function bulkEnrichPeople(
details: EnrichmentDetail[],
opts: { revealPersonalEmails?: boolean; revealPhoneNumber?: boolean } = {},
): Promise<any[]> {
const client = getApolloClient();
const results: any[] = [];
// Apollo bulk endpoint accepts max 10 at a time
for (let i = 0; i < details.length; i += 10) {
const batch = details.slice(i, i + 10);
const { data } = await withRetry(() =>
client.post('/people/bulk_match', {
details: batch,
reveal_personal_emails: opts.revealPersonalEmails ?? false,
reveal_phone_number: opts.revealPhoneNumber ?? false,
}),
);
results.push(...(data.matches ?? []));
// Brief pause between batches to respect rate limits
if (i + 10 < details.length) {
await new Promise((r) => setTimeout(r, 500));
}
}
return results;
}
src/apollo/client.ts — Zod-validated singleton with x-api-key headersrc/apollo/errors.ts — ApolloApiError + ApolloRateLimitError with retryable flagsrc/apollo/retry.ts — Exponential backoff with jittersrc/apollo/paginator.ts — Async generator for paginated endpoints (500-page limit)src/apollo/bulk-enrich.ts — Batch enrichment via /people/bulk_match (10 per call)| Pattern | When to Use |
|---|---|
| Singleton client | Always — one client instance per process |
| Retry | 429 rate limits, 5xx server errors |
| Pagination | Search results > 100 records |
| Bulk enrichment | Multiple contacts need email/phone data |
| Custom errors | Typed catch blocks distinguishing auth vs rate limit vs server |
import { paginate } from './apollo/paginator';
import { bulkEnrichPeople } from './apollo/bulk-enrich';
async function enrichLeadsAtCompany(domain: string) {
const allPeople: any[] = [];
for await (const batch of paginate('/mixed_people/api_search', {
q_organization_domains_list: [domain],
person_seniorities: ['vp', 'director', 'c_suite'],
})) {
allPeople.push(...batch);
}
console.log(`Found ${allPeople.length} decision-makers at ${domain}`);
// Bulk enrich only those without email
const toEnrich = allPeople
.filter((p) => !p.email && p.linkedin_url)
.map((p) => ({ linkedin_url: p.linkedin_url }));
const enriched = await bulkEnrichPeople(toEnrich);
console.log(`Enriched ${enriched.length} contacts`);
}
Proceed to apollo-core-workflow-a for lead search implementation.