How to send data to scrapy pipeline to mongodb

# In your pipeline class EPGD_pipeline(object): def __init__(self): self.collections = { spider_name: self.setup_db_connection(dj_mongo_database_url.parse(url)) for spider_name, url in settings['MONGODB_PIPELINE_SETTINGS'].iterItems() ) } def process_item(self, item, spider): collection = self.collections[spider.name] ... # In settings.py MONGODB_PIPELINE_SETTINGS = { "GenDis": "mongodb://myhost:29297/test_db/collection", "EPGD": "mongodb://myhost:29297/test_db/collection2", }

BOT_NAME = 'capstone' SPIDER_MODULES = ['capstone.spiders'] NEWSPIDER_MODULE = 'capstone.spiders' ITEM_PIPLINES = {'capstone.pipelines.MongoDBPipeline': 300,} MONGO_URI = 'mongodb://localhost:27017' MONGO_DATABASE = 'congress' ROBOTSTXT_OBEY = True DOWNLOAD_DELAY = 10

from pymongo import MongoClient
    from scrapy.conf import settings
    from scrapy.exceptions import DropItem
    from scrapy import log

    class MongoDBPipeline(object):
        collection_name= 'members'
        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', 'items')
            )
        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].insert(dict(item))
            return item

Posted by: Guest on November-25-2020

Source

Code answers related to "How to send data to scrapy pipeline to mongodb"

Code answers related to "Whatever"

Browse Popular Code Answers by Language

Answers for "How to send data to scrapy pipeline to mongodb"

Code answers related to "How to send data to scrapy pipeline to mongodb"

Code answers related to "Whatever"

Browse Popular Code Answers by Language

Popular Programming Languages

Advertisements

Company

Compilers

Help

Connect with us