是否可以运行另一个蜘蛛从Scrapy蜘蛛

Question

现在我有2个蜘蛛，我想做的是

1. 蜘蛛1去url1，如果url2出现，用url2召唤蜘蛛2。还可以通过管道保存url1的内容。
2. 蜘蛛2去url2做一些事情。

由于这两种蜘蛛的复杂性，我想把它们分开。

我尝试使用scrapy crawl:

def parse(self, response):
    p = multiprocessing.Process(
        target=self.testfunc())
    p.join()
    p.start()
def testfunc(self):
    settings = get_project_settings()
    crawler = CrawlerRunner(settings)
    crawler.crawl(<spidername>, <arguments>)

加载设置但不爬行:

2015-08-24 14:13:32 [scrapy] INFO: Enabled extensions: CloseSpider, LogStats, CoreStats, SpiderState
2015-08-24 14:13:32 [scrapy] INFO: Enabled downloader middlewares: DownloadTimeoutMiddleware, UserAgentMiddleware, RetryMiddleware, HttpAuthMiddleware, DefaultHeadersMiddleware, MetaRefreshMiddleware, HttpCompressionMiddleware, RedirectMiddleware, CookiesMiddleware, ChunkedTransferMiddleware, DownloaderStats
2015-08-24 14:13:32 [scrapy] INFO: Enabled spider middlewares: HttpErrorMiddleware, OffsiteMiddleware, RefererMiddleware, UrlLengthMiddleware, DepthMiddleware
2015-08-24 14:13:32 [scrapy] INFO: Spider opened
2015-08-24 14:13:32 [scrapy] INFO: Crawled 0 pages (at 0 pages/min), scraped 0 items (at 0 items/min)

文档有一个关于从脚本启动的例子，但我想做的是在使用scrapy crawl命令时启动另一个蜘蛛。

编辑:完整代码

from scrapy.crawler import CrawlerRunner
from scrapy.utils.project import get_project_settings
from twisted.internet import reactor
from multiprocessing import Process
import scrapy
import os

def info(title):
    print(title)
    print('module name:', __name__)
    if hasattr(os, 'getppid'):  # only available on Unix
        print('parent process:', os.getppid())
    print('process id:', os.getpid())

class TestSpider1(scrapy.Spider):
    name = "test1"
    start_urls = ['http://www.google.com']
    def parse(self, response):
        info('parse')
        a = MyClass()
        a.start_work()

class MyClass(object):
    def start_work(self):
        info('start_work')
        p = Process(target=self.do_work)
        p.start()
        p.join()
    def do_work(self):
        info('do_work')
        settings = get_project_settings()
        runner = CrawlerRunner(settings)
        runner.crawl(TestSpider2)
        d = runner.join()
        d.addBoth(lambda _: reactor.stop())
        reactor.run()
        return
class TestSpider2(scrapy.Spider):
    name = "test2"
    start_urls = ['http://www.google.com']
    def parse(self, response):
        info('testspider2')
        return

我希望是这样的:

1. 挠性爬行test1(例如，当响应。status_code is 200:)
在test1中调用scrapy crawl test2

Answer 1

我不会深入讨论，因为这个问题真的很老，但我将继续从官方Scrappy文档....中删除这个片段你很接近了!lol

import scrapy
from scrapy.crawler import CrawlerProcess
class MySpider1(scrapy.Spider):
    # Your first spider definition
    ...
class MySpider2(scrapy.Spider):
    # Your second spider definition
    ...
process = CrawlerProcess()
process.crawl(MySpider1)
process.crawl(MySpider2)
process.start() # the script will block here until all crawling jobs are finished

https://doc.scrapy.org/en/latest/topics/practices.html

然后使用回调你可以在你的蜘蛛之间传递项目做我们的逻辑函数你说的是

Answer 2

我们不应该从一个蜘蛛运行一个蜘蛛。在我的理解中，您希望在其他蜘蛛结束时运行一个蜘蛛，对吗?如果是这样，让我们使用下面的源代码:

from twisted.internet import reactor, defer
from scrapy.crawler import CrawlerRunner
from scrapy.utils.log import configure_logging
from datascraper.spiders.file1_spd import Spider1ClassName
from datascraper.spiders.file2_spd import Spider2ClassName
from scrapy.utils.project import get_project_settings

@defer.inlineCallbacks
def crawl():
    yield runner.crawl(Spider1ClassName)
    yield runner.crawl(Spider2ClassName)
    reactor.stop()

configure_logging()
config = get_project_settings()
runner = CrawlerRunner(settings=config)
crawl()
reactor.run() # the script will block here until the last crawl call is finished

你可以参考这里:https://doc.scrapy.org/en/latest/topics/practices.html#running-multiple-spiders-in-the-same-process