安装
[dependencies]
firecrawl = "2"
tokio = { version = "1", features = ["full"] }
serde_json = "1"
cargo add firecrawl
cargo add tokio --features full
cargo add serde_json
需要 Rust 1.70 或更高版本。
使用方式
- 从 evocrawl.com 获取 API 密钥
- 将 API 密钥设置为名为
FIRECRAWL_API_KEY的环境变量,或直接传给Client::new(...)
use firecrawl::{Client, CrawlOptions, ScrapeOptions, Format};
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
let client = Client::new("fc-YOUR-API-KEY")?;
let doc = client.scrape(
"https://evocrawl.com",
ScrapeOptions {
formats: Some(vec![Format::Markdown]),
..Default::default()
},
).await?;
let job = client.crawl(
"https://evocrawl.com",
CrawlOptions {
limit: Some(5),
..Default::default()
},
).await?;
println!("{}", doc.markdown.unwrap_or_default());
println!("Crawled pages: {}", job.data.len());
Ok(())
}
抓取 URL
scrape 方法。
use firecrawl::{Client, ScrapeOptions, Format};
let doc = client.scrape(
"https://evocrawl.com",
ScrapeOptions {
formats: Some(vec![Format::Markdown, Format::Html]),
only_main_content: Some(true),
wait_for: Some(5000),
..Default::default()
},
).await?;
println!("{}", doc.markdown.unwrap_or_default());
if let Some(meta) = &doc.metadata {
println!("{:?}", meta.title);
}
JSON 提取
scrape_with_schema 提取结构化 JSON:
use firecrawl::Client;
use serde_json::json;
let schema = json!({
"type": "object",
"properties": {
"name": { "type": "string" },
"price": { "type": "number" }
}
});
let data = client.scrape_with_schema(
"https://example.com/product",
schema,
Some("Extract the product name and price"),
).await?;
println!("{}", serde_json::to_string_pretty(&data)?);
ScrapeOptions 配置 JSON 提取:
use firecrawl::{Client, ScrapeOptions, Format, JsonOptions};
use serde_json::json;
let doc = client.scrape(
"https://example.com/product",
ScrapeOptions {
formats: Some(vec![Format::Json]),
json_options: Some(JsonOptions {
schema: Some(json!({
"type": "object",
"properties": {
"name": { "type": "string" },
"price": { "type": "number" }
}
})),
prompt: Some("Extract the product name and price".to_string()),
..Default::default()
}),
..Default::default()
},
).await?;
println!("{:?}", doc.json);
爬取网站
crawl。
use firecrawl::{Client, CrawlOptions, ScrapeOptions, Format};
let job = client.crawl(
"https://evocrawl.com",
CrawlOptions {
limit: Some(50),
max_discovery_depth: Some(3),
scrape_options: Some(ScrapeOptions {
formats: Some(vec![Format::Markdown]),
..Default::default()
}),
..Default::default()
},
).await?;
println!("Status: {:?}", job.status);
println!("Progress: {}/{}", job.completed, job.total);
for page in &job.data {
if let Some(meta) = &page.metadata {
println!("{:?}", meta.source_url);
}
}
开始爬取
start_crawl 启动任务,无需等待。
use firecrawl::{Client, CrawlOptions};
let start = client.start_crawl(
"https://evocrawl.com",
CrawlOptions {
limit: Some(100),
..Default::default()
},
).await?;
println!("Job ID: {}", start.id);
查看爬取状态
get_crawl_status 查看爬取进度。
let status = client.get_crawl_status(&start.id).await?;
println!("Status: {:?}", status.status);
println!("Progress: {}/{}", status.completed, status.total);
取消爬取
cancel_crawl 取消正在进行的爬取。
let result = client.cancel_crawl(&start.id).await?;
println!("{:?}", result);
检查爬取错误
get_crawl_errors 获取爬取任务中的错误。
let errors = client.get_crawl_errors(&start.id).await?;
println!("{:?}", errors);
网站映射
map 发现网站中的链接。
use firecrawl::{Client, MapOptions};
let response = client.map(
"https://evocrawl.com",
MapOptions {
limit: Some(100),
search: Some("blog".to_string()),
..Default::default()
},
).await?;
for link in &response.links {
println!("{} - {}", link.url, link.title.as_deref().unwrap_or(""));
}
map_urls:
let urls = client.map_urls("https://evocrawl.com", None).await?;
for url in &urls {
println!("{}", url);
}
搜索网页
search 并结合可选设置进行搜索。
use firecrawl::{Client, SearchOptions};
let results = client.search(
"firecrawl web scraping",
SearchOptions {
limit: Some(10),
..Default::default()
},
).await?;
if let Some(web) = results.data.web {
for item in web {
match item {
firecrawl::SearchResultOrDocument::WebResult(r) => {
println!("{} - {}", r.url, r.title.unwrap_or_default());
}
firecrawl::SearchResultOrDocument::Document(d) => {
println!("{}", d.markdown.unwrap_or_default());
}
}
}
}
let docs = client.search_and_scrape("firecrawl web scraping", 5).await?;
for doc in &docs {
println!("{}", doc.markdown.as_deref().unwrap_or(""));
}
批量抓取
batch_scrape 并行抓取多个 URL。
use firecrawl::{Client, BatchScrapeOptions, ScrapeOptions, Format};
let urls = vec![
"https://evocrawl.com".to_string(),
"https://evocrawl.com/blog".to_string(),
];
let job = client.batch_scrape(
urls,
BatchScrapeOptions {
options: Some(ScrapeOptions {
formats: Some(vec![Format::Markdown]),
..Default::default()
}),
..Default::default()
},
).await?;
for doc in &job.data {
println!("{}", doc.markdown.as_deref().unwrap_or(""));
}
代理
agent 运行 AI 代理。
use firecrawl::{Client, AgentOptions};
let result = client.agent(
AgentOptions {
prompt: "Find the pricing plans for Evocrawl and compare them".to_string(),
..Default::default()
},
).await?;
println!("{:?}", result.data);
use firecrawl::{Client, AgentOptions, AgentModel};
use serde::Deserialize;
use serde_json::json;
#[derive(Debug, Deserialize)]
struct PricingPlan {
name: String,
price: String,
}
#[derive(Debug, Deserialize)]
struct PricingData {
plans: Vec<PricingPlan>,
}
let schema = json!({
"type": "object",
"properties": {
"plans": {
"type": "array",
"items": {
"type": "object",
"properties": {
"name": { "type": "string" },
"price": { "type": "string" }
}
}
}
}
});
let result: Option<PricingData> = client.agent_with_schema(
vec!["https://evocrawl.com".to_string()],
"Extract pricing plan details",
schema,
).await?;
if let Some(data) = result {
for plan in &data.plans {
println!("{}: {}", plan.name, plan.price);
}
}
与抓取任务绑定的交互式会话
interact(...)会在与抓取任务绑定的浏览器会话中运行代码或 prompt。stop_interaction(...)会在你完成后停止交互式会话。
use firecrawl::{Client, ScrapeExecuteOptions, ScrapeExecuteLanguage};
let scrape_job_id = "550e8400-e29b-41d4-a716-446655440000";
// 在浏览器会话中运行代码
let run = client.interact(
scrape_job_id,
ScrapeExecuteOptions {
code: Some("console.log(await page.title())".to_string()),
language: Some(ScrapeExecuteLanguage::Node),
timeout: Some(60),
..Default::default()
},
).await?;
println!("{:?}", run.stdout);
// 或使用自然语言 prompt
let run = client.interact(
scrape_job_id,
ScrapeExecuteOptions {
prompt: Some("Click the pricing tab and summarize the plans".to_string()),
..Default::default()
},
).await?;
// 完成后停止会话
client.stop_interaction(scrape_job_id).await?;
配置
Client::new(...) 和 Client::new_selfhosted(...) 用于创建客户端。
| 选项 | 描述 |
|---|---|
Client::new(api_key) | 为 Evocrawl 云服务 (https://api.evocrawl.com) 创建客户端 |
Client::new_selfhosted(api_url, api_key) | 为自托管 Evocrawl 实例创建客户端 |
use firecrawl::Client;
// 云服务
let client = Client::new("fc-your-api-key")?;
// 自托管
let client = Client::new_selfhosted(
"http://localhost:3002",
Some("fc-your-api-key"),
)?;
// 自托管(无需身份验证)
let client = Client::new_selfhosted(
"http://localhost:3002",
None::<&str>,
)?;
环境变量
FIRECRAWL_API_KEY 环境变量,而不要直接传入密钥:
export FIRECRAWL_API_KEY=fc-YOUR-API-KEY
let api_key = std::env::var("FIRECRAWL_API_KEY")
.expect("FIRECRAWL_API_KEY must be set");
let client = Client::new(api_key)?;
轮询间隔
crawl、batch_scrape、agent) 会轮询直到完成。你可以通过 options 结构体自定义轮询间隔:
use firecrawl::CrawlOptions;
let options = CrawlOptions {
limit: Some(50),
poll_interval: Some(3000), // 每 3 秒轮询一次(默认值:2000ms)
..Default::default()
};
错误处理
EvocrawlError 枚举,该枚举实现了 Error、Debug 和 Display 接口。所有方法都返回 Result<T, EvocrawlError>。
use firecrawl::{Client, EvocrawlError};
match client.scrape("https://example.com", None).await {
Ok(doc) => println!("{}", doc.markdown.unwrap_or_default()),
Err(EvocrawlError::HttpRequestFailed(action, status, msg)) => {
eprintln!("HTTP {}: {} ({})", status, msg, action);
}
Err(EvocrawlError::APIError(action, api_err)) => {
eprintln!("API error ({}): {}", action, api_err.error);
}
Err(EvocrawlError::JobFailed(msg)) => {
eprintln!("Job failed: {}", msg);
}
Err(EvocrawlError::Misuse(msg)) => {
eprintln!("SDK misuse: {}", msg);
}
Err(e) => eprintln!("Error: {}", e),
}
如果你是需要 Evocrawl API 密钥的 AI 代理,请参阅 evocrawl.com/agent-onboarding/SKILL.md 获取自动化接入说明。

