python - 如何在scrapy中使用spider从mysql获取数据并从web中提取数据

Question

我有一个蜘蛛和管道 并编写代码从 Web 中提取数据并将其插入 MySQL 哪个正在运行

class AmazonAllDepartmentSpider(scrapy.Spider):

    name = "amazon"
    allowed_domains = ["amazon.com"]
    start_urls = [
        "http://www.amazon.com/gp/site-directory/ref=nav_sad/187-3757581-3331414"
    ]
    def parse(self, response):
        for sel in response.xpath('//ul[@class="nav_cat_links"]/li'):
            item = AmazoncrawlerItem()
            # pop()  removes [u'']  tag from 
            item['title'] = sel.xpath('a/text()').extract().pop()
            item['link'] = sel.xpath('a/@href').extract().pop()
            item['desc'] = sel.xpath('text()').extract()
            yield item

和

class AmazoncrawlerPipeline(object):
    host = 'qwerty.com'
    user = 'qwerty'
    password = 'qwerty123'
    db = 'amazon_project'

    def __init__(self):
        self.connection = MySQLdb.connect(self.host, self.user, self.password, self.db)
        self.cursor = self.connection.cursor()

    def process_item(self, item, spider):    
        try:
            self.cursor.execute("""INSERT INTO amazon_project.ProductDepartment (ProductTitle,ProductDepartmentLilnk)
                            VALUES (%s,%s)""", 
                           (item['title'],'amazon.com' + str(item.get('link'))))


            self.connection.commit()

        except MySQLdb.Error, e:
            print "Error %d: %s" % (e.args[0], e.args[1])
        return item

现在我想获取这些数据(这是 URL 的链接) 并再次调用spider从web中提取数据

请帮我看看该怎么做，谢谢

Answer 1

应该在蜘蛛级别上解决。

要点击链接，您可以在生成项目实例后生成请求:

def parse(self, response):
    for sel in response.xpath('//ul[@class="nav_cat_links"]/li'):
        item = AmazoncrawlerItem()
        item['title'] = sel.xpath('a/text()').extract().pop()
        item['link'] = sel.xpath('a/@href').extract().pop()
        item['desc'] = sel.xpath('text()').extract()
        yield item
        yield Request(item['link'], callback=self.parse_link)

或者，您可以更改策略并切换到 Link Extractors .

---

UPD(在评论中讨论后):

如果数据库中已有链接，则需要启动另一个蜘蛛，从start_requests()中的数据库中读取链接。和yield请求:

from scrapy.http import Request

class AmazonSpider(scrapy.Spider):
    name = "amazon"
    allowed_domains = ["amazon.com"]

    def start_requests(self):
         connection = MySQLdb.connect(<connection params here>)
         cursor = connection.cursor()

         cursor.execute("SELECT ProductDepartmentLilnk FROM amazon_project.ProductDepartment")
         links = cursor.fetchall()

         for link in links:
              yield Request(link, callback=self.parse)

         cursor.close()

     ...