在django中对计数器进行原子增量操作

6 浏览
0 Comments

在django中对计数器进行原子增量操作

我正在尝试在Django中原子地增加一个简单的计数器。我的代码如下所示：

from models import Counter
from django.db import transaction
@transaction.commit_on_success
def increment_counter(name):
    counter = Counter.objects.get_or_create(name = name)[0]
    counter.count += 1
    counter.save()

如果我理解Django正确的话，这应该在一个事务中包装该函数，并使增量操作变为原子操作。但是它并不起作用，计数器更新存在竞态条件。如何使这段代码线程安全？

0

3 答案

0 Comments

在Django 1.4版本中，引入了SELECT ... FOR UPDATE子句，利用数据库锁来确保没有数据会被错误地并发访问。这是我最终选择的解决方案，同时还将该块代码包装在transaction.commit_on_success中。

确切地说，真正的问题是不同客户端对相同数据的竞争。内部锁可以确保每个客户端在其事务中获得自己的序列号。

因此，解决这个问题的方法是使用SELECT ... FOR UPDATE子句来引入数据库锁，并将相关的代码块包装在transaction.commit_on_success中，以确保每个客户端在其事务中获得独立的序列号。

0
0 Comments

在Django中实现原子递增计数器的问题是出于以下原因：

1. 避免竞态条件：在多线程或多进程环境下，如果多个实例同时递增计数器，并且在查询当前值之前获取到相同的值，可能导致计数器的结果不符合预期。

解决方法如下：

1. 使用F表达式：通过在查询中使用F表达式可以实现原子递增。可以在update()方法中使用F表达式或者在对象实例上使用F表达式进行递增。

- 在update()方法中使用F表达式：

from django.db.models import F
Counter.objects.get_or_create(name=name)
Counter.objects.filter(name=name).update(count=F("count") + 1)

- 在对象实例上使用F表达式：

from django.db.models import F
counter, _ = Counter.objects.get_or_create(name=name)
counter.count = F("count") + 1
counter.save(update_fields=["count"])

需要注意在使用对象实例上的F表达式时，要指定update_fields参数，以避免对模型的其他字段造成竞态条件。

2. 在官方文档中添加有关使用F表达式避免竞态条件的说明。

关于使用F表达式避免竞态条件的说明已经添加到了官方文档中。

这是一个正确的解决方案。参考Django文档中关于F()的说明：使用F()的另一个好处是，通过数据库而不是Python更新字段的值可以避免竞态条件。

get_or_create()方法返回一个元组，所以应该使用"counter, created = ..."来接收返回值。

在执行更新操作之前，可以先计算新的计数值，例如"new_count = counter.count + 1"，然后再进行更新。

在更新字段后，模型将保存一个django.db.models.expressions.CombinedExpression的实例，而不是实际的结果。如果需要立即访问结果，可以使用"counter.refresh_from_db()"方法。

需要注意的是，有时候这种方法会失败，导致计数值比预期的要小。不同的数据库后端对此是否支持可能有所不同，具体而言，sqlite3是否支持需要进一步确认。

我正在寻找一种方式来递增字段的值，但是在页面上点击递增按钮时，不需要刷新页面即可获取新的值。

0
0 Comments

在Django中，原子递增计数器的问题出现的原因是多个线程同时访问该计数器时可能会导致不一致的结果。解决这个问题的方法是使用数据库的原子操作来确保只有一个线程可以读取和更新计数器的值。

如果不需要在设置计数器时知道计数器的值，可以使用以下代码来实现原子递增计数器：

counter, _ = Counter.objects.get_or_create(name=name)
counter.count = F('count') + 1
counter.save()

这告诉数据库将1添加到计数器的值上，而不会阻塞其他操作。缺点是你无法知道刚刚设置的计数器的值。如果两个线程同时访问这个函数，它们会看到相同的值，并且都会告诉数据库添加1。数据库最终会添加2，但你无法知道哪个线程先执行。

如果你确实关心当前的计数器值，可以使用Emil Stenstrom提到的select_for_update选项。代码如下：

from models import Counter
from django.db import transaction
@transaction.atomic
def increment_counter(name):
    counter = (Counter.objects
               .select_for_update()
               .get_or_create(name=name)[0])
    counter.count += 1
    counter.save()

这个代码会读取当前的计数器值并在事务结束之前锁定匹配的行。现在只有一个工作线程可以读取计数器。详细信息请参考文档。

这个回答给出了最好的解释。直到读到这个回答，我才确信count = F('count') + 1是可以工作的。

0