import pymongo
from pymongo import MongoClient
client = pymongo.MongoClient(host='127.0.0.1', port=27017)
collection = client.newtext
print('============',collection )
class FirstPipeline(object):
def process_item(self, item, spider):
for i in range(0,len(item["content"])):
arrtext = {'title':item['title'][i],'price':item["price"][i],'content':item["content"][i]}
collection.insert_many(arrtext)
return item
这是 scapy 框架,在 pipelines.py 页面里面写的,上面是这个页面所有的代码
打印出来的值是这样的
Database(MongoClient(host=['127.0.0.1:27017'], document_class=dict, tz_aware=False, connect=True), 'newtext')
菜鸟一枚
from pymongo import MongoClient
client = pymongo.MongoClient(host='127.0.0.1', port=27017)
collection = client.newtext
print('============',collection )
class FirstPipeline(object):
def process_item(self, item, spider):
for i in range(0,len(item["content"])):
arrtext = {'title':item['title'][i],'price':item["price"][i],'content':item["content"][i]}
collection.insert_many(arrtext)
return item
这是 scapy 框架,在 pipelines.py 页面里面写的,上面是这个页面所有的代码
打印出来的值是这样的
Database(MongoClient(host=['127.0.0.1:27017'], document_class=dict, tz_aware=False, connect=True), 'newtext')
菜鸟一枚