MCPcopy Index your code
hub / github.com/bda-research/node-crawler

github.com/bda-research/node-crawler @v2.1.1

repository ↗ · DeepWiki ↗ · release v2.1.1 ↗ · + Follow
78 symbols 168 edges 32 files 11 documented · 14% updated 17d agov2.1.1 · 2026-06-16★ 6,79729 open issues
README

Node.js


npm package

CircleCI NPM download Package Quality

Crawler v2 : Advanced and Typescript version of node-crawler

Features:

  • Server-side DOM & automatic jQuery insertion with Cheerio (default),
  • Configurable pool size and retries,
  • Control rate limit,
  • Priority queue of requests,
  • let crawler deal for you with charset detection and conversion,

If you have prior experience with Crawler v1, for fast migration, please proceed to the section Differences and Breaking Changes.

Use with AI agents

This package ships an agent skill that teaches AI agents (e.g. OpenClaw, Hermes, Claude Code, Codex etc) how to crawl with crawler — queue vs. direct requests, rate limiting, proxy rotation, Cheerio parsing, and common pitfalls.

Recommended — install from ClawHub: clawhub.ai/mike442144/node-crawler

openclaw skills install node-crawler

Fallback — download the skill bundle from the latest release and unzip it into your agent's skills directory:

curl -L -o node-crawler-skill.zip https://github.com/bda-research/node-crawler/releases/latest/download/node-crawler-skill.zip
unzip node-crawler-skill.zip -d .openclaw/skills/

Let your agent install it — paste this prompt:

Install the node-crawler skill so you can use it for large-scale web crawling: download https://github.com/bda-research/node-crawler/releases/latest/download/node-crawler-skill.zip, unzip it, and place the node-crawler/ folder in your skills directory (e.g. .openclaw/skills/, .claude/skills/, or wherever your runtime loads skills from).

The agent loads it automatically when a task involves large-scale scraping or crawling.

Quick start

Install

Requires Node.js 22 or above.

$ npm install crawler

Warning: Given the dependencies involved (Especially migrating from request to got) , Crawler v2 has been designed as a native ESM and no longer offers a CommonJS export. We would also like to recommend that you convert to ESM. Note that making this transition is generally not too difficult.If you have a large codebase built with Crawler v1, you can upgrade to v2.0.3-beta (using npm install crawler@beta), which supports both ESM and CommonJS builds.Please note that code previously using the "body" parameter to send form data in POST requests will need to be updated to use "form" even in the beta version.

Usage

Execute asynchronously via custom options

import Crawler from "crawler";

const c = new Crawler({
    maxConnections: 10,
    // This will be called for each crawled page
    callback: (error, res, done) => {
        if (error) {
            console.log(error);
        } else {
            const $ = res.$;
            // $ is Cheerio by default
            //a lean implementation of core jQuery designed specifically for the server
            console.log($("title").text());
        }
        done();
    },
});

// Add just one URL to queue, with default callback
c.add("http://www.amazon.com");

// Add a list of URLs
c.add(["http://www.google.com/", "http://www.yahoo.com"]);

// Add URLs with custom callbacks & parameters
c.add([
    {
        url: "http://parishackers.org/",
        jQuery: false,

        // The global callback won't be called
        callback: (error, res, done) => {
            if (error) {
                console.log(error);
            } else {
                console.log("Grabbed", res.body.length, "bytes");
            }
            done();
        },
    },
]);

// Add some HTML code directly without grabbing (mostly for tests)
c.add([
    {
        html: "<title>This is a test</title>",
    },
]);

please refer to options for detail.

Slow down

Use rateLimit to slow down when you are visiting web sites.

import Crawler from "crawler";

const c = new Crawler({
    rateLimit: 1000, // `maxConnections` will be forced to 1
    callback: (err, res, done) => {
        console.log(res.$("title").text());
        done();
    },
});

c.add(tasks); //between two tasks, minimum time gap is 1000 (ms)

Custom parameters

Sometimes you have to access variables from previous request/response session, what should you do is passing parameters in options.userParams :

c.add({
    url: "http://www.google.com",
    userParams: {
        parameter1: "value1",
        parameter2: "value2",
        parameter3: "value3",
    },
});

then access them in callback via res.options

console.log(res.options.userParams);

Raw body

If you are downloading files like image, pdf, word etc, you have to save the raw response body which means Crawler shouldn't convert it to string. To make it happen, you need to set encoding to null

import Crawler from "crawler";
import fs from "fs";

const c = new Crawler({
    encoding: null,
    jQuery: false, // set false to suppress warning message.
    callback: (err, res, done) => {
        if (err) {
            console.error(err.stack);
        } else {
            fs.createWriteStream(res.options.userParams.filename).write(res.body);
        }
        done();
    },
});

c.add({
    url: "https://raw.githubusercontent.com/bda-research/node-crawler/master/crawler_primary.png",
    userParams: {
        filename: "crawler.png",
    },
});

preRequest

If you want to do something either synchronously or asynchronously before each request, you can try the code below. Note that direct requests won't trigger preRequest.

import Crawler from "crawler";

const c = new Crawler({
    preRequest: (options, done) => {
        // 'options' here is not the 'options' you pass to 'c.queue', instead, it's the options that is going to be passed to 'request' module
        console.log(options);
        // when done is called, the request will start
        done();
    },
    callback: (err, res, done) => {
        if (err) {
            console.log(err);
        } else {
            console.log(res.statusCode);
        }
    },
});

c.add({
    url: "http://www.google.com",
    // this will override the 'preRequest' defined in crawler
    preRequest: (options, done) => {
        setTimeout(() => {
            console.log(options);
            done();
        }, 1000);
    },
});

Direct request

Support both Promise and callback

import Crawler from "crawler";

const crawler = new Crawler();

// When using directly "send", the preRequest won't be called and the "Event:request" won't be triggered
const response = await crawler.send("https://github.com/");
console.log(response.options);
// console.log(response.body);

crawler.send({
    url: "https://github.com/",
    // When calling `send`, `callback` must be defined explicitly, with two arguments `error` and `response`
    callback: (error, response) => {
        if (error) {
            console.error(error);
        } else {
            console.log("Hello World!");
        }
    },
});

Table

Content

Work with Http2

Now we offer hassle-free support for using HTTP/2: just set http2 to true, and Crawler will operate as smoothly as with HTTP (including proxies).

Note: As most developers using this library with proxies also work with Charles, it is expected to set rejectAuthority to false in order to prevent the so-called 'self-signed certificate' errors."

crawler.send({
    url: "https://nghttp2.org/httpbin/status/200",
    method: "GET",
    http2: true,
    callback: (error, response) => {
        if (error) {
            console.error(error);
        }
        console.log(`inside callback`);
        console.log(response.body);
    },
});

Work with rateLimiters

Control the rate limit. All tasks submit to a rateLimiter will abide the rateLimit and maxConnections restrictions of the limiter. rateLimit is the minimum time gap between two tasks. maxConnections is the maximum number of tasks that can be running at the same time. rateLimiters are independent of each other. One common use case is setting different rateLimiters for different proxies. One thing is worth noticing, when rateLimit is set to a non-zero value, maxConnections will be forced to 1.

import Crawler from "crawler";

const c = new Crawler({
    rateLimit: 2000,
    maxConnections: 1,
    callback: (error, res, done) => {
        if (error) {
            console.log(error);
        } else {
            const $ = res.$;
            console.log($("title").text());
        }
        done();
    },
});

// if you want to crawl some website with 2000ms gap between requests
c.add("http://www.somewebsite.com/page/1");
c.add("http://www.somewebsite.com/page/2");
c.add("http://www.somewebsite.com/page/3");

// if you want to crawl some website using proxy with 2000ms gap between requests for each proxy
c.add({
    url: "http://www.somewebsite.com/page/1",
    rateLimiterId: 1,
    proxy: "proxy_1",
});
c.add({
    url: "http://www.somewebsite.com/page/2",
    rateLimiterId: 2,
    proxy: "proxy_2",
});
c.add({
    url: "http://www.somewebsite.com/page/3",
    rateLimiterId: 3,
    proxy: "proxy_3",
});
c.add({
    url: "http://www.somewebsite.com/page/4",
    rateLimiterId: 4,
    proxy: "proxy_1",
});

Normally, all ratelimiters instances in the limiter cluster of crawler are instantiated with options specified in crawler constructor. You can change property of any rateLimiter by calling the code below. Currently, we only support changing property 'rateLimit' of it. Note that the default rateLimiter can be accessed by crawler.setLimiter(0, "rateLimit", 1000);. We strongly recommend that you leave limiters unchanged after their instantiation unless you know clearly what you are doing.

const crawler = new Crawler();
crawler.setLimiter(0, "rateLimit", 1000);

Class: Crawler

Event: 'schedule'

  • options

Emitted when a task is being added to scheduler.

crawler.on("schedule", options => {
    options.proxy = "http://proxy:port";
});

Event: 'limiterChange'

  • options
  • rateLimiterId : number

Emitted when limiter has been changed.

Event: 'request'

  • options

Emitted when crawler is ready to send a request.

If you are going to modify options at last stage before requesting, just listen on it.

crawler.on("request", options => {
    options.searchParams.timestamp = new Date().getTime();
});

Event: 'drain'

Emitted when queue is empty.

crawler.on("drain", () => {
    // For example, release a connection to database.
    db.end(); // close connection to MySQL
});

crawler.add(url|options)

  • url | options

Add a task to queue and wait for it to be executed.

crawler.queueSize

  • Number

Size of queue, read-only

Options

You can pass these options to the Crawler() constructor if you want them to be global or as it

Extension points exported contracts — how you extend this code

AbstractNode (Interface)
(no doc) [3 implementers]
src/lib/queue.ts

Core symbols most depended-on inside this repo

getType
called by 5
src/lib/utils.ts
_schedule
called by 4
src/rateLimiter/rateLimiter.ts
isEmpty
called by 3
src/lib/queue.ts
getValidOptions
called by 2
src/options.ts
setDefaults
called by 2
src/lib/utils.ts
getRateLimiter
called by 2
src/rateLimiter/cluster.ts
dequeue
called by 2
src/rateLimiter/rateLimiter.ts
loadGot
called by 1
src/crawler.ts

Shape

Method 41
Function 20
Class 16
Interface 1

Languages

TypeScript100%

Modules by API surface

src/lib/queue.ts20 symbols
src/rateLimiter/cluster.ts14 symbols
src/rateLimiter/rateLimiter.ts12 symbols
src/lib/utils.ts10 symbols
src/crawler.ts7 symbols
src/lib/multiPriorityQueue.ts6 symbols
src/options.ts4 symbols
test/lib/avaTestCb.js2 symbols
test/urlOptions.js1 symbols
test/requests.js1 symbols
src/logger.ts1 symbols

Dependencies from manifests, versioned

@eslint/js10.0.1 · 1×
@types/node24.0.0 · 1×
ava8.0.1 · 1×
c811.0.0 · 1×
cheerio1.2.0 · 1×
eslint10.4.1 · 1×
globals17.6.0 · 1×
got15.0.5 · 1×
hpagent1.2.0 · 1×
http2-wrapper2.2.1 · 1×
iconv-lite0.7.2 · 1×
nock14.0.15 · 1×

For agents

$ claude mcp add node-crawler \
  -- python -m otcore.mcp_server <graph>

⬇ download graph artifact