0

我的 python 应用程序使用了 twisted，并在后台使用了 cassandra python 驱动程序。Cassandra python驱动可以cassandra.io.twistedreactor.TwistedConnection作为连接类使用twisted作为查询方式。

TwistedConnection类使用计时器并reactor.callLater检查查询任务是否超时。

问题是当我使用 cassandra ORM ( cassandra.cqlengine.models.Model) 进行查询时。

from cassandra.cqlengine import columns
from cassandra.cqlengine.models import Model


# ORM for user settings
class UserSettings(Model):
    userid = columns.Text(primary_key=True)
    settings = columns.Text()

# Function registered with autobahn/wamp
def worker():
    userid = "96c5d462-cf7c-11e7-b567-b8e8563d0920"

    def _query():
        # This is a blocking call, internally calling twisted reactor
        # to collect the query result
        setting = model.UserSettings.objects(userid=userid).get()
        return json.loads(setting.settings)

    threads.deferToThread(_query)

在twisted.trial单元测试中运行时。使用上述代码的测试总是失败

失败：twisted.trial.util.DirtyReactorAggregateError：反应堆不干净。

DelayedCalls: (set twisted.internet.base.DelayedCall.debug = True to debug)
<DelayedCall 0x10e0a2dd8 [9.98250699043274s] called=0 cancelled=0 TwistedLoop._on_loop_timer()

然而，在使用此代码的高速公路工人中，工作正常。

TwistedConnection 的 cassandra 驱动程序代码继续调用 callLater，我找不到方法来查找这些调用中是否仍有待处理，因为这些调用隐藏在TwistedLoop类中。

问题：

  • 这是处理 cassandra 查询的正确方法吗（这又称为扭曲反应器）
  • 如果是，有没有办法解决DelayedCall由 cassandra 驱动程序超时 ( reactor.callLater) 导致的问题。
4

1 回答 1

0

只是我的理解：

  1. 也许您需要.filter在过滤时调用函数？如文档中所述 setting = model.UserSettings.objects.filter(userid=userid).get()

  2. 也许可以通过更改 Cassandra conf yaml 文件中的响应时间来解决？

于 2018-10-23T09:31:34.957 回答