将多个Scrapy数据插入mysql

import pymysql

class MySQLPipeline(object):
    def __init__(self):
        self.conn = pymysql.connect(host='localhost', user='username', password='password', db='database_name')
        self.cursor = self.conn.cursor()

    def process_item(self, item, spider):
        # 将item中的数据插入到数据库中
        sql = "INSERT INTO table_name (column1, column2, ...) VALUES (%s, %s, ...)"
        values = (item['field1'], item['field2'], ...)
        self.cursor.execute(sql, values)
        self.conn.commit()
        return item

    def close_spider(self, spider):
        self.cursor.close()
        self.conn.close()

ITEM_PIPELINES = {
    'myproject.pipelines.MySQLPipeline': 300,
}