Firebase Firestore 事务和线程 - python

Question

我有一个 python 脚本，它基于此处给出的示例： https://firebase.google.com/docs/firestore/manage-data/transactions

即：

transaction = db.transaction()
city_ref = db.collection(u'cities').document(u'SF')

@firestore.transactional
def update_in_transaction(transaction, city_ref):
    snapshot = city_ref.get(transaction=transaction)
    transaction.update(city_ref, {
        u'population': snapshot.get(u'population') + 1
    })

update_in_transaction(transaction, city_ref)

我找不到任何关于事务装饰器详细功能的好的文档（除了标记应该在事务中执行的内容），但似乎每当我尝试从新线程进行调用时，它都会卡住我还没有想出一个解释：

   //Works fine if called like this
   update_in_transaction(transaction, city_ref)

   //Does NOT work if called like this:
   threading.Thread(target=self.__my_method_to_start_the_transaction)

这是有问题的，因为它阻塞了我的 UI 线程并且我无法呈现任何加载指示器等。有什么建议吗？我错过了什么吗？

非常感谢！

Answer 1

我创建了一个小代码来检查来自here 的示例数据会发生什么。

from google.cloud import firestore
import threading

db = firestore.Client()
transaction = db.transaction()

city_ref = db.collection(u'cities').document(u'LA')

@firestore.transactional
def update_in_transaction(transaction, city_ref):
    snapshot = city_ref.get(transaction=transaction)
    transaction.update(city_ref, {
        u'population': snapshot.get(u'population') + 1
    })


x = threading.Thread(target=update_in_transaction, args=(transaction, city_ref))
x.start()

它按预期工作。在您的代码中，我认为您的工作流程更复杂，并且可能会遗漏一些东西。无论如何，如果您想了解有关装饰器的更多详细信息，这里是装饰器 transactional 的代码，它同时调用方法 _Transactional。