pyspider引入mysql

# 示例代码：配置数据库连接参数
from pyspider.libs.base_handler import BaseHandler
import pymysql

class Handler(BaseHandler):
    crawl_config = {
        'headers': {'User-Agent': 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/58.0.3029.110 Safari/537.3'}
    }

    @classmethod
    def from_crawler(cls, crawler):
        return cls()

    def on_start(self):
        self.conn = pymysql.connect(host='localhost', port=3306, user='root', password='password', db='test')
        self.cursor = self.conn.cursor()

    def on_message(self, task):
        # 处理爬取的数据并存储到 MySQL 数据库中
        pass

# 示例代码：插入数据到 MySQL 数据库中
def insert_data(self, data):
    sql = "INSERT INTO table_name (column1, column2, column3) VALUES (%s, %s, %s)"
    self.cursor.execute(sql, (data['value1'], data['value2'], data['value3']))
    self.conn.commit()