[大数据]scrapy Pipline保存到数据库

import json
import pymssql
class TqybPipeline:
    # #保存到当前路径
    # def open_spider(self,spider):
    #      self.fp=open("天气.txt",'w',encoding='utf-8')
    # def process_item(self, item, spider):
    #     self.fp.write(json.dumps(dict(item),ensure_ascii=False)+"\n")
    #     return item
    # def close_spider(self,spider):
    #      self.fp.close()
    def __init__(self):
        self.conn = pymssql.connect(server='192.168.1.104',port=1433,user='sa',password='******',database='stuDB',charset='UTF-8')
        self.cursor = self.conn.cursor()
    def process_item(self,item,spider):
        sql = 'insert into tianqi(rq,tq,tem,dw,city) values(%s,%s,%s,%s,%s)'
        self.cursor.execute(sql,(item['day'],item['tq'],item['gw'],item['dw'],item['city']))
        # sql ='select * from tianqi'
        # self.cursor.execute(sql)
        self.conn.commit()
        return item
    def spider_close(self,spider):
        self.cursor.close()
        self.conn.close()
在setting中添加
ITEM_PIPELINES = {
    'tqyb.pipelines.TqybPipeline': 300,

}