直接上例子

# -*- coding: utf-8 -*-

#!/usr/bin/python3

# Define your item pipelines here

#

# Don't forget to add your pipeline to the ITEM_PIPELINES setting

# See: http://doc.scrapy.org/en/latest/topics/item-pipeline.html

import pymysql

from spiderman.env import *

class SpidermanPipeline(object):

def __init__(self):

self.conn = pymysql.connect(

host=dbhost,

user=dbuser,

password=dbpass,

db=dbname,

charset='utf8mb4',

cursorclass=pymysql.cursors.DictCursor)

self.cursor = self.conn.cursor()

self.table = table_pool

self.filters = [

'测试',

'demo',

'pre-a',

'概念',

'天使',

'未',

'种子',

'不明确',

'上线',

'正在运营',

]

def process_item(self, item, spider):

qsql = "select count(*) from "+self.table+" where item_id='"+item['item_id'] + "' and item_from='" + item['item_from'] +"'"

self.cursor.execute(qsql) # 返回受影响的行数

count = self.cursor.fetchone()['count(*)']

if count > 0:

print('***********数据重复！***************')

return None

else:

sql = "INSERT INTO "+self.table+" (`item_id`, \

`item_name`, `item_logo`, `item_brief`, `item_area`, \

`item_from`, `item_CEO`,`item_round`,`item_phone`,\

`item_email`,`item_weixin`,`item_weibo`,`item_website`,`item_from_website`,\

`item_address`) \

VALUES ('%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s', '%s') " % \

(item['item_id'],

item['item_name'],

item['item_logo'],

item['item_brief'],

item['item_area'],

item['item_from'],

item['item_CEO'],

item['item_round'],

item['item_phone'],

item['item_email'],

item['item_weixin'],

item['item_weibo'],

item['item_website'],

item['item_from_website'],

item['item_address'])

for index,value in enumerate(self.filters):

if value in item['item_round'].lower() and item['item_website']:

self.cursor.execute(sql)

self.conn.commit()

print(sql)

break

else:

continue

return item

def close_spider(self,spider):

self.conn.close()

其中env.py文件为常量

# -*- coding: utf-8 -*-

#!/usr/bin/python3

dbuser = 'root'

dbpass = '123456'

dbname = 'testdb'

dbhost = '127.0.0.1'

dbport = '3306'

table_pool='test'