爬取360攝影美圖

爬取360攝影美圖

新建項目

scrapy startproject images360

建立一個Spider

scrapy genspider image image.so.com

構造請求：

爬取50頁，每頁30張，先在settings.py裏定義一個MAX_PAGE，添加定義   MAX_PAGE = 50

定義 start_requests

    def start_requests(self):
        data = {'ch': 'photography', 'listtype': 'new'}
        base_url = 'https://image.so.com/zj?'
        for page in range(1, self.settings.get('MAX_PAGE') + 1):
            data['sn'] = page * 30
            params = urlencode(data)
            url = base_url + params
            yield Request(url, self.parse)

修改settings.py中ROBOTSTXT_OBEY變量，將其設置爲False。

ROBOTSTXT_OBEY = False

提取信息：

from scrapy import Item, Field
class ImageItem(Item):
    collection = 'images'
    
    id = Field()
    url = Field()
    title = Field()
    thumb = Field()

圖片ID，連接，標題，縮略圖

提取有關信息

        def parse(self, response):
        result = json.loads(response.text)
        for image in result.get('list'):
            item = ImageItem()
            item['id'] = image.get('imageid')
            item['url'] = image.get('qhimg_url')
            item['title'] = image.get('group_title')
            item['thumb'] = image.get('qhimg_thumb_url')
            yield item

解析json，遍歷其list，取出圖片信息，對ImageItem賦值，生成Item對象。

存儲信息

import pymongoclass MongoPipeline(object):
    def __init__(self, mongo_uri, mongo_db):
        self.mongo_uri = mongo_uri
        self.mongo_db = mongo_db
    
    @classmethod
    def from_crawler(cls, crawler):
        return cls(
            mongo_uri=crawler.settings.get('MONGO_URI'),
            mongo_db=crawler.settings.get('MONGO_DB')
        )
    
    def open_spider(self, spider):
        self.client = pymongo.MongoClient(self.mongo_uri)
        self.db = self.client[self.mongo_db]
    
    def process_item(self, item, spider):
        name = item.collection
        self.db[name].insert(dict(item))
        return item
    
    def close_spider(self, spider):
        self.client.close()

settings.py裏設置

MONGO_URI = 'localhost'
MONGO_DB = 'images360'

ImagePipeline

from scrapy import Request
from scrapy.exceptions import DropItem
from scrapy.pipelines.images import ImagesPipeline


class ImagePipeline(ImagesPipeline):
    def file_path(self, request, response=None, info=None):
        url = request.url
        file_name = url.split('/')[-1]
        return file_name
    
    def item_completed(self, results, item, info):
        image_paths = [x['path'] for ok, x in results if ok]
        if not image_paths:
            raise DropItem('Image Downloaded Failed')
        return item
    
    def get_media_requests(self, item, info):
        yield Request(item['url'])