强制 Django 提交

Question

设置：

• Python 脚本 A 每 15 分钟将数据插入数据库
• Python 脚本 B 每隔几分钟从数据库查询一些最新条目

两者都使用Django的ORM，运行在同一台机器上并使用本地MySQL数据库。

问题：
B 会获取条目（最新条目除外），即使 A 在分钟之前保存它。

我怀疑A没有关闭事务，因此B看到数据库没有最后一个条目。事实上，在检查 MySQL 日志时，我注意到每个 INSERT 的commit 发生在下一个 INSERT 之前。

尽管它应该是多余的，但我将 @commit_on_success 装饰器添加到包含 save() 的 A 函数中，但它没有帮助。

如何强制 Django（或 MySQL？！）在 save() 之后立即提交？

更新：
我发现提交确实发生了 - 我被误导相信它们没有发生，因为 MySQL的通用查询日志只有1秒分辨率。
鉴于此和其他新信息，我在这里重新提出了问题 。

Answer 1

您可以使用 commit_manually 装饰器并在需要时调用它。

直接来自文档：

from django.db import transaction

@transaction.commit_manually
def viewfunc(request):
    ...
    # You can commit/rollback however and whenever you want
    transaction.commit()
    ...

    # But you've got to remember to do it yourself!
    try:
        ...
    except:
        transaction.rollback()
    else:
        transaction.commit()

这回答了您提出的问题，尽管我想知道是否还有其他原因在起作用。

注意： commit_manually 在 1.6 并在 1.8。

Answer 2

该问题是由于MySQL默认具有REPEATABLE-READ事务隔离级别引起的。这意味着相同的查询预计会返回相同的值。改变不会回来。您可以在此处执行两件事：

1. 在设置中将事务隔离级别设置为 READ-COMMITTED。正如此处所述。
2. 强制提交，从而关闭脚本 B 上的事务，因此当新事务开始时，您将看到该新事务之前的所有更改。 Model.objects.update() 就可以了。