美文网首页爬虫专题
深圳链家在售二手房数据抓取

深圳链家在售二手房数据抓取

作者: 雷小厮 | 来源:发表于2017-05-31 23:47 被阅读0次

    本来今天还想说试试昨天刚弄的代理池,去爬下链家上面的房源信息,结果今天突然发现,链家的反爬虫没有啦~~

    哎呀,露点了

    赶紧上scrapy,把上面的在售房源信息撸下来。

    其实很简单的爬虫,用框架有点大材小用了,不过真的比普通多进程快好多呀,作为一个老男人,快既是追求,也是必然!

    至于scrapy的设置,就settings里打开了default request headers和item-pipeline,关闭了robots协议,pipelines里面复制了别人的代码,还是用mongodb存数据。

    distinfo.csv 和log.txt 用来存些需要用的信息,好像可以设置middlewares,可是呢,我不会。。。

    import pymongo
    
    class SzlianjiaPipeline(object):
        collection_name = 'sz_onsale'
    
        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_DATABASE')
            )
    
        def open_spider(self, spider):
            self.client = pymongo.MongoClient(self.mongo_uri)
            self.db = self.client[self.mongo_db]
    
        def close_spider(self, spider):
            self.client.close()
    
        def process_item(self, item, spider):
            self.db[self.collection_name].update({'房屋链接':item['房屋链接']},dict(item),True)
            return item
    
    【丝路在哪里】

    反正scrapy的爬虫设计就是一层一层往下爬,咱就从首页开始,先获取区域链接,

         def parse_dist(self,response):
            dists = response.xpath('//div[@data-role="ershoufang"]/div/a/@href').extract()
            for dist in dists:
                url = 'https://sz.lianjia.com'+dist
                yield scrapy.Request(url,self.parse_small_dist,dont_filter=True)
    

    再获取小区域链接,

        def parse_small_dist(self,response):
            small_dists = response.xpath('//div[@data-role="ershoufang"]/div[2]/a/@href').extract()
            for small_dist in small_dists:
                url = 'https://sz.lianjia.com' + small_dist
                if url not in self.dists_list:
                    self.dists_list.append(url)
                    yield scrapy.Request(url,selfs.parse_dist_house_page,dont_filter=True)
    

    因为大区中的小区域还有部分重复了,建了个self.dists_list列表用来排重,减少需要爬取的页面。

    获取小区域页码总数,

        def parse_dist_house_page(self,response):
            total_dist_house = int(response.xpath('//h2[@class="total fl"]/span/text()').extract()[0])
            if total_dist_house >0:
                page_info = response.xpath('//div[@class="page-box house-lst-page-box"]/@page-data').extract()[0]
                page_dic = json.loads(page_info)
                page_num = page_dic.get('totalPage')
            else:
                page_num = 0
            url = response.url
            log_info = '区域链接:  '+url+'      区域二手房总数:  '+str(total_dist_house)+'      区域二手房页数:  '+str(page_num)+'\n'
            with open('log.txt','a+') as f:
                f.write(log_info)
            distinfo = url+','+str(total_dist_house)+','+str(page_num)+'\n'
            with open('distinfo.csv','a+') as f:
                f.write(distinfo)
            if page_num > 0:
                for i in range(1, page_num + 1):
                    url = response.url + 'pg' + str(i) + '/'
                    yield scrapy.Request(url, callback=self.parse_dist_page, dont_filter=True)
    

    奇了怪了居然有2个小区域中没有房源,还的带个判断。log.txt用来存些错误信息。distinfo.csv用来存每个小区域的房源数,爬完了再来对下有没有漏。

    获取小区域中每一页中的房源链接,

        def parse_dist_page(self,response):
            urls = response.xpath('//ul[@class="sellListContent"]/li/a/@href').extract()
            for url in urls:
                yield scrapy.Request(url,callback=self.onsale_page,dont_filter=True)
    

    终于爬到最后一层了,获取每个房源的详细信息。

     def onsale_page(self,response):
            item = SzlianjiaItem()
            soup = BeautifulSoup(response.text, 'lxml')
            title = soup.select('div.title h1')[0].text
            price = float(soup.select('span.total')[0].text) if soup.select('span.total') else ''
            unitprice = float(soup.select('span.unitPriceValue')[0].text.rstrip('元/平米')) if soup.select(
                'span.unitPriceValue') else ''
            houseID = soup.select('div.houseRecord span.info')[0].text.rstrip('举报') if soup.select(
                'div.houseRecord span.info') else ''
            xiaoqu = soup.select('div.communityName a')[0].text if soup.select('div.communityName a') else ''
            infos = [i.text for i in soup.select('div.introContent div.content ul li')]
            info = {}
            for i in infos:
                key = i[:4]
                data = i[4:]
                info[key] = data
            info['标题'] = title
            info['总价'] = price
            info['单价'] = unitprice
            info['链家编号'] = houseID
            info['小区'] = xiaoqu
            info['房屋链接'] = response.url
            info['建筑面积'] = float(info['建筑面积'].rstrip('㎡')) if '㎡' in info['建筑面积'] else ''
            info['套内面积'] = float(info['套内面积'].rstrip('㎡')) if '㎡' in info['套内面积'] else ''
            info['挂牌时间'] = datetime.datetime.strptime(info['挂牌时间'],'%Y-%m-%d') if info['挂牌时间'] != '暂无数据' else ''
            for key in info.keys():
                if info[key] != '暂无数据':
                    item[key] = info[key]
                else:
                    item[key] = ''
            yield item
    

    前面几层都是用xpath解析,比较简单,不需要引进额外的包,我对xpath还不是很熟,正好用来练手不过最后一层太多字段了,想偷个懒,就用更熟练的美丽汤来解析,顺便改下某些字段的类型,方面以后处理。

    结果

    最后爬下来,获取了25800个房源信息,可是。。。

    不开心!!!

    完美主义害死人啊!

    先这样了,明天接着改。

    后续计划

    把所有小区信息爬下来。
    把所有已售房屋信息爬下来。
    分析。
    买房!
    ヽ(Д*)/.✨哈哈

    相关文章

      网友评论

        本文标题:深圳链家在售二手房数据抓取

        本文链接:https://www.haomeiwen.com/subject/ixojfxtx.html