こんにちは。フリーランス・コンサルタント＆エンジニアの九保すこひです。

X（Twitter）やってます！
九保すこひ＠フリーランスエンジニア｜累計300万PVのブログ運営中

さてさて、このところLaravelやVue関連の記事ばかり書いていたので、たまには「９回カレーだったら、次はハヤシライス」的な気分になりました。

そして、じゃあ何がいいかなと考えていたところ過去にやってみたある内容が思い浮かびました。

それは・・・・・・

「ヘッドレス Chrome」

です。

📝 参考ページ： JavaScriptでレンダリングしてるページをスクレイピングする方法

「ヘッドレス Chrome」とは、シンプルに言うと「目に見える部分がない＝頭がない＝ヘッドレス」のことで、その分高速に実行することができるため、スクレイピングなどに利用されています。

しかも、ヘッドレスとは言え、ちゃんとしたブラウザなので、なんと…

JavaScriptのレンダリングに対応している！

のがPHPのGuzzleとの大きな違いです。

そこで❗

今回はNode.jsを使って「ヘッドレス Chrome」を操作し、特定のサイトだけに絞ったクローラーをつくってみることにしました。

ぜひ何かの参考になれば嬉しいです。😊✨

「お気に入りのビール醸造所が
お気に入りだった風味のビール
を出してて感動👍」

開発環境： NodeJS v16.15.0

1 やりたいこと
2 ヘッドレス Chrome をインストールする
3 パッケージをインストールする
4 データベースにテーブルを用意する
5 クローラーのコードを書く
6 テストしてみる
7 企業様へのご提案
8 おわりに

やりたいこと

今回は「ヤフーニュース」のサイト内に「政府」という言葉が存在しているかというクローラーをつくっていきます。

※ なお、「政府」というキーワードは比較的多めに入っているようでしたので、決定しました。（ホントは「明石家さんま」が良かったんですけどね😂）

では、実際に作業をしていきましょう❗

ヘッドレス Chrome をインストールする

まずは「ヘッドレス Chrome」がないとはじまりませんので、以下のURLを参考にしてインストールを済ませておいてください。

📝 参考ページ： JavaScriptでレンダリングしてるページをスクレイピングする方法

パッケージをインストールする

今回はNodeJSからMySQLにアクセスしますので、以下のパッケージをインストールしておいてください。

npm install mysql

データベースにテーブルを用意する

では、クローラーがアクセスした時に取得することになるURLを保存するテーブルcrawler_urlsを作成します。（私の環境ではadminerを使っていますが、PhpMyAdminでも同じことができますので同じテーブル構造を作成してください）

なお、以下の部分にはお気をつけください。

has_keyword はデフォルト値に「false」がついている
url には、UNIQUE制限がついている

（こういう作業をやると、Laravelのマイグレーションって便利だと感じますね😂）

クローラーのコードを書く

では、ここからがメインのNode.jsコードになります。
こちらです。
↓　↓　↓

crawler.js

// Constants
const CRAWLER_TOP_URL = 'https://news.yahoo.co.jp/'; // ヤフーニュース
const KEYWORD = '政府'; // 探したいキーワード

// DB
const mysql = require('mysql');
const util = require('util');
const { exit } = require('process');
const connection = mysql.createConnection({
    host: 'localhost',
    user: '（MySQL のユーザー名）',
    password: '（MySQL のパスワード）',
    database: 'crawler'
});
const query = util.promisify(connection.query).bind(connection);
const getCrawlerUrl = async () => {

    const sql = 'SELECT * FROM crawler_urls ORDER BY RAND() LIMIT 1';
    const rows = await query(sql);

    if(rows.length > 0) {

        return rows[0].url;

    }

    return CRAWLER_TOP_URL;

}
const saveCrawlerUrls = async (urls) => {

    for(const url of urls) {

        const sql = 'INSERT INTO crawler_urls (url) VALUES (?) ON DUPLICATE KEY UPDATE url = ?';
        const values = [url, url];
        await query(sql, values);

    }

};
const saveHasKeyword = async (hasKeyword, url) => {

    const sql = 'UPDATE crawler_urls SET has_keyword = ?, crawled_at = ? WHERE url = ?';
    const values = [hasKeyword, new Date(), url];
    await query(sql, values);

};

// Crawler
const puppeteer = require('puppeteer');
const url = require('url');
const getTargetHostNameUrl = targetUrls => { // ドメインが CRAWLER_TOP_URL と同じものだけ抽出

    const baseHostName = url.parse(CRAWLER_TOP_URL).hostname;

    return targetUrls.filter(targetUrl => {

        if(! targetUrl) {

            return false;

        }

        const hostName = url.parse(targetUrl).hostname;
        return hostName === baseHostName;

    });

};

(async() => {

    // これからクロールする URL を DB から取得する
    const crawlerUrl = await getCrawlerUrl();
    console.log('Crawling URL: '+ crawlerUrl);

    // ヘッドレス Chrome でアクセス
    const browser = await puppeteer.launch();
    const page = await browser.newPage();
    await page.goto(crawlerUrl, { waitUntil: 'networkidle0' });

    const [crawlerUrls, content] = await page.evaluate(() => { // ここはブラウザ内の JavaScript

        let urls = [];
        document.querySelectorAll('a').forEach(link => {

            const url = link.getAttribute('href');
            urls.push(url);

        });
        const content = document.body.innerText;

        return [urls, content];

    })
    const filteredCrawlerUrls = getTargetHostNameUrl(crawlerUrls);

    // 取得した URL を DB へ保存する
    await saveCrawlerUrls(filteredCrawlerUrls);

    // キーワードが含まれているかチェック
    const hasKeyword = content.includes(KEYWORD);
    await saveHasKeyword(hasKeyword, crawlerUrl);

    if(hasKeyword === true) {

        console.log('キーワードが含まれています！');

    }

    await browser.close();
    exit();

})();