flask+sqlite3+echarts3+ajax 異步更新數據

時間 2019-11-21

標籤 flask+sqlite3+echarts3+ajax flask sqlite echarts ajax 異步更新數據欄目 Python 简体版

原文原文鏈接

1、先準備數據

# create_db.py
# 只運行一次！！！

import sqlite3

# 鏈接
conn = sqlite3.connect('mydb.db')
c = conn.cursor()

# 建立表
c.execute('''DROP TABLE IF EXISTS weather''')
c.execute('''CREATE TABLE weather (month text, evaporation text, precipitation text)''')

# 數據
# 格式：月份,蒸發量,降水量
purchases = [('1月', 2, 2.6),
             ('2月', 4.9, 5.9),
             ('3月', 7, 9),
             ('4月', 23.2, 26.4),
             ('5月', 25.6, 28.7),
             ('6月', 76.7, 70.7),
             ('7月', 135.6, 175.6),
             ('8月', 162.2, 182.2),
             ('9月', 32.6, 48.7),
             ('10月', 20, 18.8),
             ('11月', 6.4, 6),
             ('12月', 3.3, 2.3)
            ]

# 插入數據
c.executemany('INSERT INTO weather VALUES (?,?,?)', purchases)

# 提交！！！
conn.commit()

# 查詢方式一
for row in c.execute('SELECT * FROM weather'):
    print(row)
    
    
# 查詢方式二
c.execute('SELECT * FROM weather')
print(c.fetchall())


# 查詢方式二_2
res = c.execute('SELECT * FROM weather')
print(res.fetchall())


# 關閉
conn.close()

2、定義路由

第一次性加載六條數據
之後，每隔1秒更新一條數據html

由以下函數實現：java

@app.route("/weather", methods=["GET","POST"])
def weather():
    if request.method == "GET":
        res = query_db("SELECT * FROM weather WHERE id <= 6") #不妨設定：第一次只返回6個數據
    elif request.method == "POST":
        res = query_db("SELECT * FROM weather WHERE id = (?)", args=(int(request.form['id'])+1,)) #之後每次返回1個數據
        #res = query_db("SELECT * FROM weather WHERE id = 13") # 一個不存在的記錄
    
    return jsonify(month = [x[1] for x in res],
                   evaporation = [x[2] for x in res], 
                   precipitation = [x[3] for x in res]) # 返回json格式

此函數用於處理ajax，返回json格式。形如：python

{
    month: ['1月','2月',...],
    evaporation: [3.1, 4, 4.6, ...],
    precipitation: [...]
}

完整app.py文件：jquery

import sqlite3
from flask import Flask, request, render_template, jsonify

app = Flask(__name__)


def get_db():
    db = sqlite3.connect('mydb.db')
    db.row_factory = sqlite3.Row
    return db


def query_db(query, args=(), one=False):
    db = get_db()
    cur = db.execute(query, args)
    db.commit()
    rv = cur.fetchall()
    db.close()
    return (rv[0] if rv else None) if one else rv


@app.route("/", methods=["GET"])
def index():
    return render_template("index.html")


@app.route("/weather", methods=["GET","POST"])
def weather():
    if request.method == "GET":
        res = query_db("SELECT * FROM weather WHERE id <= 6") #不妨設定：第一次只返回6個數據
    elif request.method == "POST":
        res = query_db("SELECT * FROM weather WHERE id = (?)", args=(int(request.form['id'])+1,)) #之後每次返回1個數據
        #res = query_db("SELECT * FROM weather WHERE id = 13") # 一個不存在的記錄
    
    return jsonify(month = [x[1] for x in res],
                   evaporation = [x[2] for x in res], 
                   precipitation = [x[3] for x in res]) # 返回json格式


if __name__ == "__main__":
    app.run(debug=True)

3、使用echarts

官網對eccharts 3數據動態更新的描述：ajax

···
數據的動態更新sql

ECharts 由數據驅動，數據的改變驅動圖表展示的改變，所以動態數據的實現也變得異常簡單。json

全部數據的更新都經過 setOption實現，你只須要定時獲取數據，setOption 填入數據，而不用考慮數據到底產生了那些變化，ECharts 會找到兩組數據之間的差別而後經過合適的動畫去表現數據的變化。flask

> ECharts 3 中移除了 ECharts 2 中的 addData 方法。若是隻須要加入單個數據，能夠先 data.push(value) 後 setOption

···數組

index.html文件以下：

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="utf-8">
    <title>ECharts3 Ajax</title>
    <script src="{{ url_for('static', filename='jquery-3.1.1.js') }}"></script>
    <script src="{{ url_for('static', filename='echarts.js') }}"></script>
</head>

<body>
    <!--爲ECharts準備一個具有大小（寬高）的Dom-->
    <div id="main" style="height:500px;border:1px solid #ccc;padding:10px;"></div>
    
    <script type="text/javascript">
    //--- 折柱 ---
    var myChart = echarts.init(document.getElementById('main'));
    
    myChart.setOption({
        title: {
            text: '異步數據更新示例'
        },
        tooltip: {},
        legend: {
            data:['蒸發量','降水量']
        },
        xAxis: {
            data: []
        },
        yAxis: {},
        series: [{
            name: '蒸發量',
            type: 'bar',
            data: []
        },{
            name: '降水量',
            type: 'line',
            data: []
        }]
    });
    
    
    // 四個全局變量：月份、蒸發量、降水量、  哨兵（用於POST）
    var month = [],
        evaporation = [],
        precipitation = [],
        
        lastID = 0; // 哨兵，記錄上次數據表中的最後id +1（下次查詢只要>=lastID）

    
    //準備好統一的 callback 函數
    var update_mychart = function (data) { //data是json格式的response對象
        
        myChart.hideLoading(); // 隱藏加載動畫
        
        dataLength = data.month.length //取回的數據長度
        lastID += dataLength //哨兵，相應增長。
        
        // 切片是能統一的關鍵！！
        month = month.slice(dataLength).concat(data.month) // 數組，先切片、再拼接
        evaporation = evaporation.slice(dataLength).concat(data.evaporation.map(parseFloat)) //注意map方法
        precipitation = precipitation.slice(dataLength).concat(data.precipitation.map(parseFloat))
        
        // 填入數據
        myChart.setOption({
            xAxis: {
                data: month
            },
            series: [{
                name: '蒸發量', // 根據名字對應到相應的系列
                data: evaporation
            },{
                name: '降水量',
                data: precipitation
            }]
        });
        
        if (dataLength == 0){clearInterval(timeTicket);} //若是取回的數據長度爲0,中止ajax
    }
    
    myChart.showLoading(); // 首次顯示加載動畫
    
    
    // 異步加載數據 （首次，get，顯示6個數據）
    $.get('/weather').done(update_mychart);
    
    
    // 異步更新數據 （之後，定時post，取回1個數據）
    var timeTicket = setInterval(function () {
        $.post('/weather',{id: lastID}).done(update_mychart);
    }, 5000);
    
    </script>
</body>
</html>

效果圖：