feapder 批量入库代码示例

真的好方便 高效率
比一条一条入库效率提高了500倍

import pandas as pd
from utils.md5 import md5Encryption
from feapder.db.mysqldb import MysqlDB
import json
from datetime import datetime

df = pd.read_csv("XXX.csv")
db = MysqlDB(ip="XXXXX", port=XXX, db="XXXX", user_name="XXXX", user_pass="XXXXXX")
a = md5Encryption()

dtime = datetime.now()
print(dtime)
items = []
for i in range(len(df)):
    dict = {}
    dict['name'] = df.iloc[i][0]
    dict['type_id'] = 11
    dict['author'] = df.iloc[i][2]
    dict['content'] = df.iloc[i][3]
    dict['add_time'] = dtime.strftime("%Y-%m-%d %H:%M:%S.%f")
    dict['md5_id'] = a.computeMd5(df.iloc[i])
    items.append(dict)
db.add_batch_smart('poetry_poetry', items)
print("已完成",datetime.now())