MySQL+Flask，在本地实现一个API接口。

import pymysql

db = pymysql.connect(host='127.0.0.1', user='root', password='20191126', port=3306)
cursor = db.cursor()
cursor.execute("CREATE DATABASE history DEFAULT CHARACTER SET utf8mb4")
db.close()

import pymysql

db = pymysql.connect(host='127.0.0.1', user='root', password='20191126', port=3306, db='history')
cursor = db.cursor()
sql = 'CREATE TABLE IF NOT EXISTS messages (date VARCHAR(255) NOT NULL, id INT NOT NULL, title VARCHAR(255) NOT NULL, year VARCHAR(255) NOT NULL, year_num INT NOT NULL, PRIMARY KEY (id))'
cursor.execute(sql)
db.close()

import requests
import operator
import pymysql
import json
import time

headers = {
    'User-Agent': 'Mozilla/5.0 (Macintosh; Intel Mac OS X 10_13_6) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/77.0.3865.90 Safari/537.36'
}

db = pymysql.connect(host='127.0.0.1', user='root', password='20191126', port=3306,  db='history', charset='utf8mb4')
cursor = db.cursor()


def to_mysql(data):
    """
    写入数据库
    """
    table = 'messages'
    keys = ', '.join(data.keys())
    values = ', '.join(['%s'] * len(data))
    sql = 'INSERT INTO {table}({keys}) VALUES ({values}) ON DUPLICATE KEY UPDATE'.format(table=table, keys=keys, values=values)
    update = ','.join([" {key} = %s".format(key=key) for key in data])
    sql += update
    try:
        if cursor.execute(sql, tuple(data.values())*2):
            print('Successful')
    except:
        print('Failed')
        db.rollback()
    db.commit()


# 每月 
for i in range(1, 13):
    time.sleep(10)
    # 每日
    for j in range(1, 31):
        url = 'http://www.jiahengfei.cn:33550/port/history?dispose=easy&key=jiahengfei&month=' + str(i) + '&day=' + str(j)
        response = requests.get(url=url, headers=headers)
        result = json.loads(response.text)
        list1 = []
        for k in result['data']:
            if len(k['title']) < 100:
                if int(k['year']) > 0:
                    item = {}
                    item['date'] = str(i) + '/' + str(j)
                    item['id'] = k['id']
                    item['title'] = k['title']
                    item['year'] = k['year'] + '年' + str(i) + '月' + str(i) + '号'
                    item['year_num'] = int(k['year'])
                    # print(item)
            list1.append(item)
        # 按照年份排序
        sorted_x = sorted(list1, key=operator.itemgetter('year_num'))
        for x in sorted_x:
            # print(x)
            to_mysql(x)

import json
import pymysql
from flask import Flask, request
from pymysql.cursors import DictCursor

app = Flask(__name__)


# 只接受get方法访问
@app.route("/port/history/", methods=["GET"])
def check():
    # 默认返回内容
    return_dict = {'code': 1, 'result': False, 'msg': '请求成功'}
    # 判断入参是否为空
    if request.args is None:
        return_dict['return_code'] = '504'
        return_dict['return_info'] = '请求参数为空'
        return json.dumps(return_dict, ensure_ascii=False)
    # 获取传入的参数
    get_data = request.args.to_dict()
    month = get_data.get('month')
    day = get_data.get('day')
    date = str(month) + '/' + str(day)
    # 对参数进行操作
    return_dict['result'] = sql_result(date)
    return json.dumps(return_dict, ensure_ascii=False)


# 功能函数
def sql_result(date):
    conn = pymysql.connect(host='127.0.0.1', database='history', user='root', password='20191126')
    cursor = conn.cursor(DictCursor)
    cursor.execute("SELECT * FROM messages WHERE date= '%s'" % str(date))
    result = cursor.fetchall()
    conn.close()
    return result


if __name__ == "__main__":
    app.run(host='127.0.0.1', port=5000)