scrapyとmysqlの接続設定
3569 ワード
pipelinesでmysqlデータベースへの接続を設定する
import MySQLdb
class Zwlpipelines(object):
def __init__(self):
self.conn = MySQLdb.connect(
host = '127.0.0.1',post = 3306,
user = 'root' , password = '123456',
charset = 'utf8', db='day4'
)
def process_item(self,item,spider):
self.save(item)
return item
def save(self,item):
sql = 'insert into device_table(name,time,value)VALUES (%s,%s,%s)'
self.conn.cursor().execute(sql,[item['variatename'],item['device_time'],item['device_value']])
self.conn.commit()