第10章 ScrapyとRaspberry Pi
はじめに
ここでは、Raspberry Piのセットアップ、Scrapyのインストール、MariDBのインストール、IPアドレスの固定、SSHとVNCでの接続、VS CODEのインストールの作業をはじめに行います。そして、実際に、Scrapyで作ったクローラーをRaspberry Piで定期的に実行する方法をまとめておきます。
Raspberry Pi、Python3、Scrapyのバージョンは下記の通りです。
pi@raspberrypi:~ $ cat /etc/issue
Raspbian GNU/Linux 10
pi@raspberrypi:~ $ python3 -V
Python 3.7.3
pi@raspberrypi:~ $ scrapy -V
Scrapy 1.5.1 - no active projectお金さえあれば、AWSの製品とか、GCP製品で環境構築して常時稼働させて、クローラーを実行すればいいんだろうけど、そんなお金ないので、家に転がっていたRaspberry Piを使います。
Raspberry Piのセットアップ
ここで書く必要も無いかもしれませんが、まとめておきます。まずは購入したRaspberry Piにフォーマット済みのSDカードとRaspberry Pi Imagerを使って、Raspbianをインストールしていきます。RaspbianはLinuxのディストリビューションであるDebianをベースにしているOSなので、似たような操作感で操作ができます。
SDカードをRaspberry Piに差し込み、電源を起動すると、Raspberry Piが起動します。設定ウィザードが表示されるので、順に従って設定します。
Set Countryでは、「日本」を設定しておきます。
Change Passwordでは、パスワードは初期設定のままだと「pi / raspberry」になっているので、よしなに修正します。
Set Up Screenが表示されるので、スクリーンの端に黒い線が表示されているのであればチェックボックスにチェックをいれます。
Select WiFi NetWorkでは、WiFiのネットワークを設定します。
Update Softwareでは、アップデートしておきます。
再起動します。
再起動後、「Raspberry Piマーク > 設定 > Raspberry Piの設定」と進み、
「インターフェース」のSSH、VNCを有効にします。これでSSHとVNCでアクセスができます。
ここからはScrapyとMySQLをインストールしていきます。Raspberry PiにはPython3がすでにインストールされているので、Scrapyをインストールします。あわせてPyMySQLをインストールしておきます。
pi@raspberrypi:~ $ sudo apt-get update
pi@raspberrypi:~ $ sudo apt-get upgrade
pi@raspberrypi:~ $ sudo apt-get install python-scrapy
~~~~~~
略
~~~~~~
pi@raspberrypi:~ $ pip3 install PyMySQL
Looking in indexes: https://pypi.org/simple, https://www.piwheels.org/simple
Collecting PyMySQL
Using cached https://files.pythonhosted.org/packages/ed/39/15045ae46f2a123019aa968dfcba0396c161c20f855f11dea6796bcaae95/PyMySQL-0.9.3-py2.py3-none-any.whl
Installing collected packages: PyMySQL
Successfully installed PyMySQL-0.9.3次はMySQLです。正確にはMariaDBですが、MariaDBはMySQLから派生したもので、非常に互換性も高く、細かい部分を除けばMySQLと同じような操作感で使用できます。
$ sudo apt-get install mariadb-server
$ sudo mysql_secure_installation
~~~~~
設定内容は省略
~~~~~とりあえずテスト用のDBtest_dbとテスト用のユーザーuser01を作成します。
$ sudo mysql -u root -p
password : ******
MariaDB [(none)]> CREATE DATABASE test_db;
MariaDB [(none)]> CREATE USER 'user01'@'localhost' IDENTIFIED BY 'user01';
MariaDB [(none)]> GRANT ALL PRIVILEGES ON test_db.* TO 'user01'@'localhost';
MariaDB [(none)]> FLUSH PRIVILEGES;
MariaDB [(none)]> show databases;
+--------------------+
| Database |
+--------------------+
| information_schema |
| mysql |
| performance_schema |
| test_db |
+--------------------+
4 rows in set (0.001 sec)
MariaDB [(none)]> USE mysql;
MariaDB [mysql]> SELECT USER, HOST FROM mysql.user;
+--------+-----------+
| USER | HOST |
+--------+-----------+
| root | localhost |
| user01 | localhost |
+--------+-----------+
2 rows in set (0.001 sec)cronの設定を行います。下記コンフィグファイルを開き、cronがコメントアウトされているので、#を削除してcronを使えるようにします。
pi@raspberrypi:~ $ sudo apt-get install vim
pi@raspberrypi:~ $ sudo vim /etc/rsyslog.conf
###############
#### RULES ####
###############
#
# First some standard log files. Log by facility.
#
auth,authpriv.* /var/log/auth.log
*.*;auth,authpriv.none -/var/log/syslog
cron.* /var/log/cron.log
daemon.* -/var/log/daemon.log
kern.* -/var/log/kern.log
lpr.* -/var/log/lpr.log
mail.* -/var/log/mail.log
user.* -/var/log/user.logテキストエディタとしてVS CODEを入れておきます。
pi@raspberrypi:~ $ sudo -s
root@raspberrypi:/home/pi# . <( wget -O - https://code.headmelted.com/installers/apt.sh )
root@raspberrypi:~# su pi下記のコマンドでVS CODEを起動できます。
pi@raspberrypi:~ $ code-oss
試しにデスクトップにhello.pyを作成して実行してみます。
pi@raspberrypi:~ $ python3 ~/Desktop/hello.py
Hello Python From VS CODE最後にSSHでログインできるか確認しておきます。まずは、下記のip addrコマンドでipアドレスを調べ、ipアドレスが定期的に変動しないようにを固定します。
pi@raspberrypi:~ $ ip addr | grep 192
inet ***.***.*.**/24 brd ***.***.*.** scope global dynamic noprefixroute wlan0ip_addressの部分は固定した番号に変更してください。
pi@raspberrypi:~ sudo vim /etc/dhcpcd.conf
# 下記を末尾に追加します。
interface wlan0
static ip_address=192.168.*.**/24
static routers=192.168.1.1
static domain_name_servers=192.168.1.1再起動して、ipアドレスを確認します。固定した番号が表示されるはずです。
pi@raspberrypi:~ $ ip addr | grep 192
inet ***.***.*.**/** brd ***.***.*.*** scope global noprefixroute wlan0この作業のあとにブラウザからインターネットにアクセスできないようになっている場合は下記のコマンドで修正します。
$ sudo dhclient wlan0SSHでターミナルからログインします。
$ ssh pi@***.***.*.**
pi@***.***.*.**'s password:
Linux raspberrypi 4.19.118-v7l+ #1311 SMP Mon Apr 27 14:26:42 BST 2020 armv7l
The programs included with the Debian GNU/Linux system are free software;
the exact distribution terms for each program are described in the
individual files in /usr/share/doc/*/copyright.
Debian GNU/Linux comes with ABSOLUTELY NO WARRANTY, to the extent
permitted by applicable law.
Last login: Mon Jun 8 16:55:34 2020 from ***.***.*.**
pi@raspberrypi:~ $ cat /etc/issue
Raspbian GNU/Linux 10問題なくSSHでもアクセスできるようになっています。もう1つ試しておきます。それはscpコマンドです。このコマンドはローカルのデータをSSH経由でサーバーに転送するコマンドです。Raspberry Pi側でScrapyのクローラーを作っても良いのですが、少し重たいので、手元のPCで作ったものをディレクトリごと、Raspberry Piに転送してクローラーを起動させることにします。もちろん、Git経由でも他の方法でも、転送できれば何でも良いです。
-rのオプションをつけるとディレクトリをコピーすることができます。ここでは、crawl.pyを格納しているscrapy_scpというディレクトリを丸ごと Raspberry Piのデスクトップに転送します。
➜ scp -r ~/Desktop/scrapy_scp pi@***.***.*.**:~/Desktop/
pi@***.***.*.**'s password:
crawl.py 100% 0 0.0KB/s 00:00 Raspberry Pi側で確認しておきます。デスクトップにscrapy_scpというディレクトリが作られ、crawl.pyも保存されています。
pi@raspberrypi:~ $ tree ~/Desktop/scrapy_scp/
/home/pi/Desktop/scrapy_scp/
└── crawl.py反対にRaspberry Piのデータをもらう場合は下記のように書きます。ここでは、Raspberry PiのDesktopにあるexcute.logというデータをローカルのデスクトップに転送する例です。
$ scp pi@***.***.*.**:~/Desktop/execute.log ~/Desktop/これ以降は環境にあわせて、Raspberry Piを設定してください。GUIからCUIに変更するには、「Raspberry Piマーク > 設定 > Raspberry Piの設定」と進み、「システム」からブートをCLIにしてから再起動します。
再起動後はCLIになります。戻すためには下記の通り設定します。
$ sudo raspi-config
3 Boot Options
→ B1 Desktop / CLI
→→ B4 Desktop Autologin Desktop GUI, automatically logged in as 'pi' user
5 Interfacing Options
→ P3 VNC ⇒ Enable
7 Advanced Options
→ A5 Resolution
→→ モニタの解像度の設定データベースへのテストインサート
データベースにテストでインサートできるかを確認しておく。まずはデータベースにログインし、下記の通り、テスト用のテーブルを先程作成したtest_dbの中に作成します。
pi@raspberrypi:~ $ mysql -u user01 -p
Enter password: ****
MariaDB [(none)]> use test_db;
Database changed
MariaDB [test_db]> CREATE TABLE test (
-> id int(11) NOT NULL AUTO_INCREMENT,
-> name varchar(50) NOT NULL,
-> value double NOT NULL,
-> text text NOT NULL,
-> PRIMARY KEY (id)
-> ) ENGINE = INNODB DEFAULT CHARSET = UTF8
-> ;
Query OK, 0 rows affected (0.038 sec)
MariaDB [test_db]> show tables;
+-------------------+
| Tables_in_test_db |
+-------------------+
| test |
+-------------------+
1 row in set (0.001 sec)下記のテストインサート用のコードtest_insert.pyを利用します。pymysqlでMariaDBは操作できるので、これまでの内容と合わせるために、pymysqlを利用します。
import datetime
import pymysql
connection = pymysql.connect(user="user01",
password="user01 passwaord",
host="localhost",
database="test_db",
charset="utf8")
def main():
datum = data_generator()
start_time = datetime.datetime.now()
insert_data(datum)
end_time = datetime.datetime.now()
diff_time = end_time - start_time
print("Elapsed Time:" + str(diff_time))
def data_generator():
values = []
for i in range(10):
name = "name_{}".format(i)
value = i
text = "text_{}".format(i)
values.append([name, value, text])
return values
def insert_data(values):
insert_sql = "INSERT INTO `test` (`name`, `value`, `text`) VALUES (%s, %s, %s)"
cursor = connection.cursor()
for value in values:
cursor.execute(insert_sql, value)
connection.commit()
connection.close()
if __name__ == "__main__":
main()とりあえずデスクトップに保存し、インサートを実行します。問題なくtestテーブルにインサートが行われています。
pi@raspberrypi:~ $ python3 ~/Desktop/test_insert.py
Elapsed Time:0:00:00.009876
MariaDB [test_db]> select * from test;
+----+--------+-------+--------+
| id | name | value | text |
+----+--------+-------+--------+
| 1 | name_0 | 0 | text_0 |
| 2 | name_1 | 1 | text_1 |
| 3 | name_2 | 2 | text_2 |
| 4 | name_3 | 3 | text_3 |
| 5 | name_4 | 4 | text_4 |
| 6 | name_5 | 5 | text_5 |
| 7 | name_6 | 6 | text_6 |
| 8 | name_7 | 7 | text_7 |
| 9 | name_8 | 8 | text_8 |
| 10 | name_9 | 9 | text_9 |
+----+--------+-------+--------+
10 rows in set (0.001 sec)cronのテスト
次はcronが実際に動かうかどうか、動作テストをしていきます。下記のようなバッシュスクリプトを作成します。これはRaspberry Piの温度を表示してくれるものです。
#!/bin/bash
date=(`date +"%m/%d"`)
time=(`date +"%H:%M"`)
temp=(`vcgencmd measure_temp`)
str=$date" "$time" "$temp
echo $str次はcronの設定です。ここではデスクトップにファイルを保存して、1分毎にログを出力するようにします。
pi@raspberrypi:~ $ crontab -l
*/1 * * * * bash ~/Desktop/heat.sh >> ~/Desktop/execute.log 2>&1数分ほど放置しておいたあとでログファイルを見てみると、cronは問題なく動いていることがわかります。
pi@raspberrypi:~ $ cat ~/Desktop/execute.log
06/09 11:44 temp=45.0'C
06/09 11:45 temp=44.0'C
06/09 11:46 temp=45.0'C
06/09 11:47 temp=45.0'C
06/09 11:48 temp=44.0'C
06/09 11:49 temp=45.0'C
06/09 11:50 temp=45.0'C
06/09 11:51 temp=44.0'C
06/09 11:52 temp=44.0'C
06/09 11:53 temp=43.0'C
06/09 11:54 temp=42.0'C
06/09 11:55 temp=41.0'C
06/09 11:56 temp=40.0'CこれでRaspberry PiでScrapyを定期的に実行し、データベースに保存する準備が整いました。
Scrapyを実行する
今回は、ヤフーニュースの記事を取得するクローラーを作成していきます。イメージは下記のような感じで、ヤフーニュースのトップの「主要タブ」のニュースのリンクからスタートして、ピックアップページでは「続きを読む」から中に入り、アーティクルのページにあるニュース本文を取得します。これを「主要タブ」のニュース数分繰り返します。
ここではローカルで作業したものをRaspberry Piに転送することにします。いつものようにプロジェクトを作成するところからはじめます。
$ scrapy startproject ynews_spider
$ cd ynews_spider
$ scrapy genspider yahoo_news_spider news.yahoo.co.jp
Created spider 'yahoo_news_spider' using template 'basic' in module:items.pyでは、記事のタイトル、本文、ニュースのID、報道局の名前を保存するためのフィールドを定義します。
# -*- coding: utf-8 -*-
import scrapy
class Headline(scrapy.Item):
title = scrapy.Field()
body = scrapy.Field()
news_id = scrapy.Field()
news_agency = scrapy.Field()yahoo_news_spider.pyでは、トップページ、ピックアップページ、アーティクルページの情報を抽出できるようにコードを書いておきます。動画のニュースの場合は、HTMLの構造が変わるので、スクレイピングできないコードですが、ここでは不要なのでこのままにします。
# -*- coding: utf-8 -*-
from scrapy import Spider
from scrapy.http import Request
from ynews_spider.items import Headline
class YahooNewsSpiderSpider(Spider):
name = 'yahoo_news_spider'
allowed_domains = ['news.yahoo.co.jp',
'headlines.yahoo.co.jp']
start_urls = ['https://news.yahoo.co.jp/']
def parse(self, response):
urls = response.xpath('.//*[@class="topicsListItem "]/a/@href').getall()
for url in urls:
absolute_url = response.urljoin(url)
yield Request(absolute_url,
callback=self.parse_summary)
def parse_summary(self, response):
detail_url = response.xpath('.//*[@class="pickupMain_detailLink"]/a/@href').get()
news_id = response.url.split('pickup/')[1]
news_agency = response.xpath('.//*[@class="pickupMain_media"]/text()').get()
yield Request(detail_url,
callback=self.parse_news,
meta={"news_id": news_id,
"news_agency": news_agency}
)
def parse_news(self, response):
item = Headline()
item["news_id"] = response.meta["news_id"]
item["news_agency"] = response.meta["news_agency"]
item["title"] = response.xpath('.//*[@class="sc-cmTdod hpDMzp"]/text()').get()
tmp = response.xpath('.//*[@class="sc-dVhcbM hFPXIO yjDirectSLinkTarget"]/text()').getall()
item["body"] = ' '.join(tmp)
yield itempipelines.pyは、データベースへのコネクションや同じニュースをインサートしないように、ニュースIDを使って重複しているかを判定しています。新規の記事であれば、データベースにインサートしていきます。データベースへのコネクションはconfigparserライブラリを使って、ファイルの中から取得する方法のほうがセキュリティ的によろしいかと思います。
# -*- coding: utf-8 -*-
import pymysql
class MySQLPipeline:
def open_spider(self, spider):
self.connection = pymysql.connect(
host="localhost",
user="*******", # change here
passwd="*******", # change here
database="news",
charset="utf8mb4"
)
self.cursor = self.connection.cursor()
def process_item(self, item, spider):
# duplication check
check_news_id = item["news_id"]
print(check_news_id)
find_qry = "SELECT `news_id` FROM `ynews` WHERE `news_id` = %s"
is_done = self.cursor.execute(find_qry, check_news_id)
# if already news exists in database, return 1
if is_done == 0:
insert_qry = "INSERT INTO `ynews` (`title`, `body`, `news_id`, `news_agency`) VALUES (%s, %s, %s, %s)"
self.cursor.execute(insert_qry, (item["title"], item["body"], item["news_id"], item["news_agency"]))
self.connection.commit()
else:
pass
return item
def close_spider(self, spider):
self.connection.close()settings.pyでは、データベースへのパイプラインを機能させる設定とFEED_EXPORT_ENCODINGの設定を行います。FEED_EXPORT_ENCODINGを設定しておかないと日本語の文字が文字化けします。
# Configure item pipelines
# See https://docs.scrapy.org/en/latest/topics/item-pipeline.html
ITEM_PIPELINES = {
'ynews_spider.pipelines.MySQLPipeline': 800,
}
【最終行まで略】
FEED_EXPORT_ENCODING = 'utf-8'クローラーが完成したので、scpコマンドでクローラーのスクリプトを転送します。
$ scp -r ~/Documents/scrapy/ynews_spider pi@***.***.*.**:~/Desktop/
scrapy.cfg 100% 267 91.6KB/s 00:00
yahoo_news_spider.py 100% 1504 348.5KB/s 00:00
__init__.py 100% 161 44.5KB/s 00:00
__init__.cpython-38.pyc 100% 164 49.3KB/s 00:00
yahoo_news_spider.cpython-38.pyc 100% 1749 407.0KB/s 00:00
__init__.py 100% 0 0.0KB/s 00:00
__init__.cpython-38.pyc 100% 156 45.0KB/s 00:00
settings.cpython-38.pyc 100% 481 161.5KB/s 00:00
items.cpython-38.pyc 100% 421 99.8KB/s 00:00
pipelines.cpython-38.pyc 100% 1293 290.7KB/s 00:00
middlewares.py 100% 3607 732.5KB/s 00:00
settings.py 100% 3162 561.6KB/s 00:00
items.py 100% 314 2.0KB/s 00:00
pipelines.py 100% 1119 302.5KB/s 00:00
profiles_settings.xml 100% 174 53.2KB/s 00:00
Project_Default.xml 100% 432 119.7KB/s 00:00
vcs.xml 100% 183 49.3KB/s 00:00
.gitignore 100% 47 14.3KB/s 00:00
workspace.xml 100% 3044 590.9KB/s 00:00
modules.xml 100% 276 35.8KB/s 00:00
misc.xml 100% 185 72.7KB/s 00:00
ynews_spider.iml 100% 402 114.8KB/s 00:00 Raspberry Piではデータを受け取るDBnewsにynewsテーブルを作成しておきます。
MariaDB [None]> CREATE DATABASE news;
MariaDB [None]> USE news;
MariaDB [news]>
CREATE TABLE ynews(news_id INT NOT NULL AUTO_INCREMENT,
title TEXT,
body TEXT,
news_agency VARCHAR(50),
created TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
PRIMARY KEY(news_id));cronjobを設定します。まずはテストのため、1時間ごとにクロールするように設定します。cronの設定は、crontab guruで調べるのが簡単かもしれません。
pi@raspberrypi:~ $ crontab -e
0 */ * * * cd ~/Desktop/ynews_spider && /usr/bin/scrapy crawl yahoo_news_spider >> ~/Desktop/ynews_spider/exec-error.log 2>&1
# 確認
pi@raspberrypi:~ $ crontab -l
0 */ * * * cd ~/Desktop/ynews_spider && /usr/bin/scrapy crawl yahoo_news_spider >> ~/Desktop/ynews_spider/exec-error.log 2>&1時間になるとクローラーが実行されます。ターミナルに出力すると見づらいので、MySQL WorkBenchからクエリを発行した画面で確認しておきます。NULLは動画のニュースの場合です。ここでは不要なので、このままにしておきます。
ログも出力されています。
pi@raspberrypi:~ $ cd ~/Desktop/ynews_spider/
pi@raspberrypi:~/Desktop/ynews_spider $ ls
exec-error.log scrapy.cfg ynews_spider意図したように機能しているので、cronの設定を1時間ごとから6時間ごとに変更しておきます。
pi@raspberrypi:~ $ crontab -e
0 */6 * * * cd ~/Desktop/ynews_spider && /usr/bin/scrapy crawl yahoo_news_spider >> ~/Desktop/ynews_spider/exec-error.log 2>&1おまけ
再起動するとネットワークが繋がらなくなります。SSHやVNCではアクセスできるのにネットにはつながらないという状態です。この場合、もちろんScrapyもHTTPリクエストを送ることができません。下記のコマンドを実行することで解消されます。
// 無線の場合
pi@raspberrypi:~ $ sudo dhclient wlan0
// 有線の場合
pi@raspberrypi:~ $ sudo dhclient eth0最終更新
役に立ちましたか？