Django:在SQLite中更新后刷新网页上的数据

问题描述 投票:0回答:2

我正在准备一个仪表板Web应用程序(在Django 2.1.7中),它应该监视不同进程的状态。

为此,我在models.py中创建了一个类ReportEntry

class ReportEntry(models.Model):
    process = models.CharField(max_length=30)
    received = models.DateTimeField(auto_now_add=True)
    status = models.SmallIntegerField(default=1)

    def refresh(self):
        self.refresh_from_db()
        self.save()

要查看仪表板,我正在使用django-tables2。 view.py脚本包含

from .tables import SimpleTable
from django_tables2 import SingleTableView
from .models import ReportEntry

class TableView(SingleTableView):
    table_class = SimpleTable
    processes = ReportEntry.objects.values('process').distinct()
    queryset = [ReportEntry.objects.filter(**k).latest('received') for k in processes]
    refresh = [a.refresh() for a in ReportEntry.objects.all()]
    template_name = "simple_list.html"

此Web应用程序正常工作。

现在,我想使用下面的Python脚本向SQLite DB插入一个新条目(假设我想更新进程的状态)

from sqlite3 import connect

def create_connection(db_file):
    try:
        conn = connect(db_file)
        return conn
    except Exception as e:
       print(e)
    return None

if __name__ == '__main__':
    from datetime import datetime, timedelta
    database = r'C:\Apps\Python3702\my_venv\web\mysite\db.sqlite3'
    conn = create_connection(database)
    cur = conn.cursor()
    sql = '''INSERT INTO main.monitor_reportentry(process,received,status)
         VALUES(?,?,?)'''
    cur.execute(sql, ['test', datetime.now(), 1])
    conn.commit()
    conn.close()

当我执行脚本并将数据插入SQLite DB时,我尝试使用我的仪表板刷新网页,但内容不会更新。唯一对我有用的是重启服务器,这不是重新加载数据的方法。

是否有一种“简单”的方式以某种方式定期从数据库重新加载数据而不使用redis / celery和类似的应用程序?

python django django-tables2
2个回答
1
投票

问题是您在类级别显式执行查询,此处:

queryset = [ReportEntry.objects.filter(**k).latest('received') for k in processes]

尽管有这个名字,但在这里你没有定义一个查询集 - 它是懒惰的,并根据需要更新 - 但是一个具体的项目列表,每个进程只评估一次。不要这样做。

相反,定义get_queryset()方法:

class TableView(SingleTableView):
    table_class = SimpleTable
    template_name = "simple_list.html"

    def get_queryset(self, *args, **kwargs):
        processes = ReportEntry.objects.values('process').distinct()
        return [ReportEntry.objects.filter(**k).latest('received') for k in processes]

1
投票

由于这两行,数据不令人耳目一新:

    queryset = [ReportEntry.objects.filter(**k).latest('received') for k in processes]
    refresh = [a.refresh() for a in ReportEntry.objects.all()]

当解析视图代码时,每个人都会评估一次。发生这种情况是因为您要将查询集转换为列表。我不知道你的refresh字段是如何工作的,因为你没有提供任何使用它的代码,但是对于queryset,至少有两种可能的解决方案。

第一个解决方案是重写您的查询集,因此它仍然是查询集,而不是列表。 Django知道如何处理视图中的查询集,因此它们表现为“懒惰”(在每个视图上评估而不是一次),但它不能用列表来做。您的新查询集可能如下所示:

    queryset = ReportEntry.objects.filter(**k).order_by('received').distinct('process')

请注意,与字段不同,不适用于每个数据库后端。

第二个解决方案是将您的查询集移动到get_queryset方法:

    def get_queryset(self, *args, **kwargs):
        return [ReportEntry.objects.filter(**k).latest('received') for k in processes]
© www.soinside.com 2019 - 2024. All rights reserved.