streaming.py 文件源码

def run(self, args, opts):
        if len(args) != 1:
            raise UsageError()
        command = args[0]

        arguments = _parse_arguments(opts.args)
        spider = ExternalSpider('StreamingSpider', command, arguments)
        loader = ExternalSpiderLoader.from_settings(self.settings, load_spiders=False)

        loader.crawl(spider)