如何在 Google App Engine 上设计线程式消息传递系统

Question

我正在尝试使用 Django-nonrel 在 Google App Engine 上设计一个类似 gmail 的线程消息传递系统。我已经观看了“在 App Engine 上构建可扩展的复杂应用程序”并阅读了关于 SO 的以下问题。

App Engine Messaging System with Message Status - Design Pattern
database design in google app engine

我喜欢 Kevin 指出的想法 (App Engine Messaging System with Message Status - Design Pattern)，所以我目前的模型是这样的：

class Message(models.Model):
    sender = models.ForeignKey(User)
    content = models.TextField()
    thread_id = models.IntegerField()

class MessageReceivers(models.Model):
    message = models.ForeignKey(Message)
    users = ListField(models.CharField())
    status = models.IntegerField()  # 1 unread, 2 read ....

Django-nonrel 上的 ListField 来自这里：
http://www.allbuttonspressed.com/blog/django/2010/03/Updates-on-djangoappengine

这是我的问题，我不知道如何实现在每个线程中显示消息计数，例如 gmail。让我澄清一下我的观点。
当用户小天狼星向哈利和罗恩发送消息时。模型（为解释而简化）应该是这样的：

Message
id = 1
sender = Sirius
thread_id = 1

MessageReceivers
message = 1
users = [Harry, Ron]

然后，哈利回复了小天狼星，但由于某种原因他没有包括罗恩：

Message
id = 2
sender = Harry
thread_id = 1

MessageReceivers
message = 2
users = [Sirius]

小天狼星也回复了哈利，但他又包括了罗恩：

Message
id = 3
sender = Sirius
thread_id = 1

MessageReceivers
message = 3
users = [Haary, Ron]

当小天狼星和哈利看到他们的收件箱时，会出现一个带有邮件计数的线程 (3)。并且 Ron 看到他的收件箱里有一个带有消息计数的线程 (2)。我应该如何计算这些数字？我应该制作一个新模型来保留它们吗？

提前致谢，
哟

编辑
当 Kevin 向我介绍 Thread 模型时，我意识到我不需要关系索引模型来满足我的要求，所以我当前的模型如下所示。

class Message(models.Model):
    sender = models.ForeignKey(User)
    content = models.TextField()

class Thread(models.Model):
    user = models.ForeignKey(User)
    messages = ListField(models.CharField())    # array of message id
    lastmodified = models.DateTimeField()
    # could have a status field for read or unread, not sure for now

我可能会在这些模型的进一步开发中发现困难，但我会暂时使用它们:)

Answer 1

试试这个：

from collections import defaultdict

messages = MessageReceivers.objects.filter(users='Harry')

message_threads = []
for m in messages:
  message_threads.append(m.message.thread_id)

counted_threads = defaultdict(int)

for curr in message_threads:
    counted_threads[curr] += 1

这将为您提供 thread_id 的字典，以及它们的出现频率。

例如：

message_threads = ['a','b','c','a','a','b','a']

将产生

counted_threads == defaultdict(, {'a': 4, 'c': 1, 'b': 2})

Answer 2

如果您的数字如此之低，我只会在客户端计算它们，而无需在服务器上进行统计。下载哈利的信息并计算它们。对 Sirius 做同样的事情。您每次都必须对它们进行计数（效率较低），但您不必存储或维护计数（效率更高），并且客户端的处理时间比服务器的便宜得多。

这似乎特别正确，因为这个数字只是一种方便。如果您想添加“按回复数量对对话进行排序”之类的功能，则需要将计数存储在服务器上，否则您并不真正关心这个数字。