The crawling process downloads HTML and saves them into per-domain snapshots. The crawler seeks out HTML documents, and ignores other types of documents, such as PDFs. Crawling is done on a domain-by-domain basis, and the crawler does not follow links to other domains within a single job.
The crawler stores data from crawls in-progress in a WARC file. Once the crawl is complete, the WARC file is converted to a parquet file, which is then used by the converting process. The intermediate WARC file is not used by any other process, but kept to be able to recover the state of a crawl in case of a crash or other failure.
If configured so, these crawls may be retained. This is not the default behavior, as the WARC format is not very dense, and the parquet files are much more efficient. However, the WARC files are useful for debugging and integration with other tools.
A significant part of the crawler is dealing with robots.txt and similar, rate limiting headers; especially when these
are not served in a standard way (which is very common). RFC9390 as well as Google's Robots.txt Specifications are good references.
The crawler can use old crawl data to avoid re-downloading documents that have not changed. This is done by
comparing the old and new documents using the HTTP If-Modified-Since and If-None-Match headers. If a large
proportion of the documents have not changed, the crawler falls into a mode where it only randomly samples a few
documents from each domain, to avoid wasting time and resources on domains that have not changed.
On top of organic links, the crawler can use sitemaps and rss-feeds to discover new documents.
The crawler supports various configuration options via system properties that can be set in system.properties:
crawler.crawlSetGrowthFactor(default: 1.25) - Growth factor for crawl depthcrawler.minUrlsPerDomain(default: 100) - Minimum URLs to crawl per domaincrawler.maxUrlsPerDomain(default: 10000) - Maximum URLs to crawl per domaincrawler.poolSize(default: 256) - Thread pool size for concurrent crawlingcrawler.useVirtualThreads(default: false) - Use virtual threads instead of platform threadscrawler.maxConcurrentRequests(default: 512) - Maximum concurrent HTTP requestscrawler.maxFetchSize(default: 33554432) - Maximum fetch size in bytes
crawler.socketTimeout(default: 10) - Socket timeout in secondscrawler.connectTimeout(default: 30) - Connection timeout in secondscrawler.responseTimeout(default: 10) - Response timeout in secondscrawler.connectionRequestTimeout(default: 5) - Connection request timeout in minutescrawler.jvmConnectTimeout(default: 30000) - JVM-level connect timeout in millisecondscrawler.jvmReadTimeout(default: 30000) - JVM-level read timeout in millisecondscrawler.httpClientIdleTimeout(default: 15) - HTTP client idle timeout in secondscrawler.httpClientConnectionPoolSize(default: 256) - HTTP client connection pool size
crawler.userAgentString- Custom user agent stringcrawler.userAgentIdentifier- User agent identifier
links.block_mailing_lists(default: false) - Block mailing list linksip-blocklist.disabled(default: false) - Disable IP blocklist
- CrawlerMain orchestrates the crawling.
- CrawlerRetreiver visits known addresses from a domain and downloads each document.
- HttpFetcher fetches URLs.