自定义pipeline拦截item
from scrapy.pipelines.images import ImagesPipeline
class SelfDefinedImagePipeline(ImagesPipeline):
def item_completed(self, results, item, info):
if "img_saved_path" in item:
for ok, value in results:
item["img_saved_path"] = value["path"]
return item
pass