python - 根据 Django 中的项目分组进行分页

Question

对于在 Django/Python 中实现的网站，我们有以下要求:

在 View 页面上，每个网页显示 15 条消息。当来自同一来源的两条或多条消息在 View 中相互跟随时，应将它们分组在一起。

可能不是很清楚，但是用下面的例子可能是:

一个例子是(这次页面上有 5 条消息):

  Message1 Source1
  Message2 Source2
  Message3 Source2
  Message4 Source1
  Message5 Source3
  ...

这应该显示为:

Message1 Source1
Message2 Source2 (click here to 1 more message from Source2)
Message4 Source1
Message5 Source3
Message6 Source2

因此在每个页面上，固定数量的项目显示在页面上，其中一些已经重新分组。

我们想知道如何创建 Django 或 MySQL 查询以最佳且简单的方式查询此数据。请注意，使用了分页并且消息按时间排序。

PS:由于 SQL 的性质，我认为对此没有简单的解决方案，但有时可以轻松解决复杂的问题

Answer 1

我看不出有什么好方法可以直接完成您想要做的事情。如果您愿意接受一点非规范化，我建议您使用预保存信号将消息标记为位于头部。

#In your model
head = models.BooleanField(default=True)

#As a signal plugin:
def check_head(sender, **kwargs):
    message = kwargs['instance']
    if hasattr(message,'no_check_head') and message.no_check_head:
        return
    previous_message = Message.objects.filter(time__lt=message.time).order_by('-time')[0]
    if message.source == previous_message.source:
        message.head = False
    next_message = Message.objects.filter(time__gt=message.time).order_by('time')[0]
    if message.source == next_message.source:
        next_message.head = False
        next_message.no_check_head
        next_message.save()

然后您的查询变得神奇地简单:

messages = Message.objects.filter(head=True).order_by('time')[0:15]

老实说……信号监听器必须比我写的要复杂一点。我的方法中存在许多固有的同步丢失/更新丢失问题，解决方案将根据您的服务器而有所不同(如果它是单处理的，多线程的，那么一个 python Lock 对象应该可以帮助你，但如果它是多进程的，那么你真的需要基于文件或数据库对象实现锁定)。此外，您当然还必须编写相应的删除信号监听器。

显然，此解决方案涉及添加一些数据库命中，但它们是在编辑中而不是在 View 中，这对您来说可能是值得的。否则，或许可以考虑一种更粗略的方法:抓取 30 个故事，在 View 中循环，剔除不显示的故事，如果还剩 15 个，则显示它们，否则重复。绝对是一个可怕的最坏情况，但也许不是可怕的平均情况？

如果您的服务器配置使用单个多线程进程，那么 Lock 或 RLock 应该可以解决问题。这是使用不可重入锁的可能实现:

import thread
lock = thread.allocate_lock()
def check_head(sender, **kwargs):
    # This check must come outside the safe zone
    # Otherwise, your code will screech to a hault
    message = kwargs['instance']
    if hasattr(message,'no_check_head') and message.no_check_head:
        return
    # define safe zone
    lock.acquire()
    # see code above
    ....
    lock.release()

同样，相应的删除信号也很重要。

编辑:许多或大多数服务器配置(例如 Apache)将预 fork ，这意味着有多个进程在进行。在这种情况下，上面的代码将毫无用处。参见 this page有关如何开始与 fork 进程同步的想法。