本期爬虫系列主要讲解爬虫采集完成数据之后,我们应该怎么存储,以及用什么样的方式存储数据。
虽然在命令行里显示结果很有意思,但是随着数据不断增多,并且需要对数据分析时,将数据打印到命令行就不是办法了。为了可以远程使用大部分网络爬虫,你还需要把采集到的数据存储起来。
本篇文章介绍的数据存储方式,绝大多数应用程序都适用。如果你准备创建一个网站的后端服务或者创建自己的 API,那么可能需要把数据写入数据库。如果你需要一个快速简单的方法收集网上的文档,然后保存到你的硬盘里,那么可能需要创建一个文件流(file stream)来实现。
存储媒体文件主要有两种方式:只获取文件 URL 链接,或者直接把源文件下载下来。你可以通过媒体文件所在的 URL 链接直接引用它。这样做的优点如下:
保存媒体文件存在的缺点:
如果你还在犹豫究竟是存储文件,还只是存储文件的 URL 链接,可以想想这些文件是要多次使用还是放进数据库之后就只等着“落灰”,再也不会被打开。如果答案是后者,那么最好还是只存储这些文件的 URL 吧。如果答案是前者,那就继续往下看。
import requests
from utils import connection_util
class SaveData(object):
def __init__(self):
self._target_url = 'https://www.pdflibr.com'
self._init_connection = connection_util.ProcessConnection()
def save_image(self):
# 连接目标网站,获取内容
get_content = self._init_connection.init_connection(self._target_url)
if get_content:
imageLocation = get_content.find("img", {"alt": "IP to Location"})["data-src"]
real_path = self._target_url + imageLocation
r = requests.get(real_path)
with open("ip_location.png", 'wb') as f:
f.write(r.content)
if __name__ == "__main__":
SaveData().save_image()
这段程序从IP 查询 - 爬虫识别下载一张图片,然后保存在运行程序的文件夹里。
如果你只需要下载一个文件,而且知道如何获取它,以及它的文件类型,这么做就可以了。但是大多数爬虫一天只下载一个文件。下面的程序会把IP 查询 - 爬虫识别上所有 src 属性的文件都下载下来:
import os.path
from urllib.request import urlretrieve
from utils import connection_util
class GetAllSrc(object):
def __init__(self):
self._init_download_dir = 'downloaded'
self._baseUrl = 'https://www.pdflibr.com/ip'
self._init_connection = connection_util.ProcessConnection()
def get_absolute_url(self, baseUrl, source):
if source.startswith("https://image."):
url = "https://" + source[14:]
elif source.startswith("https://"):
url = source
elif source.startswith("www."):
url = "https://" + source[4:]
else:
url = source
if baseUrl not in url:
return None
return url
def get_download_path(self, baseUrl, absoluteUrl, download_dir):
path = absoluteUrl.replace("www.", "")
path = path.replace(baseUrl, "")
path = download_dir + path
directory = os.path.dirname(path)
if not os.path.exists(directory):
os.makedirs(directory)
return path
def download_main(self):
get_content = self._init_connection.init_connection(self._baseUrl)
if get_content:
download_list = get_content.findAll(src=True)
for download in download_list:
file_url = self.get_absolute_url(self._baseUrl, download["src"])
if file_url is not None:
print(file_url)
urlretrieve(file_url, self.get_download_path(self._baseUrl, file_url, self._init_download_dir))
if __name__ == '__main__':
GetAllSrc().download_main()
运行以上代码需要注意:
这个程序会把页面上所有的文件都下载到你硬盘里,可能会包含一些 bash 脚本,.exe 文件,设置可能是恶意软件(malmare)。
这个程序首先选择页面上所有带 src 属性的标签,然后对 URL 链接进行清理和标准化,获得了文件的绝对路径(而且去掉了外链),最后每个文件都会下载到程序所在的 downloaded 文件里。
这里使用 Python 的 os 模块用来获取每个下载文件的目标文件夹,建立完整的路径。os 模块是 Python 与操作系统交互的接口,它可以操作文件路径,创建目录,获取运行进程和环境变量的信息,以及其他系统相关操作。
文章源代码托管于 Github:爬虫系列:存储媒体文件
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。