gpt4 book ai didi

scrapy自定义pipeline类实现将采集数据保存到mongodb的方法

转载 作者:qq735679552 更新时间:2022-09-29 22:32:09 25 4
gpt4 key购买 nike

CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章scrapy自定义pipeline类实现将采集数据保存到mongodb的方法由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.

本文实例讲述了scrapy自定义pipeline类实现将采集数据保存到mongodb的方法。分享给大家供大家参考。具体如下:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
# Standard Python library imports
# 3rd party modules
import pymongo
from scrapy import log
from scrapy.conf import settings
from scrapy.exceptions import DropItem
class MongoDBPipeline( object ):
   def __init__( self ):
     self .server = settings[ 'MONGODB_SERVER' ]
     self .port = settings[ 'MONGODB_PORT' ]
     self .db = settings[ 'MONGODB_DB' ]
     self .col = settings[ 'MONGODB_COLLECTION' ]
     connection = pymongo.Connection( self .server, self .port)
     db = connection[ self .db]
     self .collection = db[ self .col]
   def process_item( self , item, spider):
     err_msg = ''
     for field, data in item.items():
       if not data:
         err_msg + = 'Missing %s of poem from %s\n' % (field, item[ 'url' ])
     if err_msg:
       raise DropItem(err_msg)
     self .collection.insert( dict (item))
     log.msg( 'Item written to MongoDB database %s/%s' % ( self .db, self .col),
         level = log.DEBUG, spider = spider)
     return item

希望本文所述对大家的python程序设计有所帮助.

最后此篇关于scrapy自定义pipeline类实现将采集数据保存到mongodb的方法的文章就讲到这里了,如果你想了解更多关于scrapy自定义pipeline类实现将采集数据保存到mongodb的方法的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com