从 dbpool.runQuery 获取延迟，而不是使用 Twisted 和 Oracle 获取数据

Question

我正在尝试使用 Twisted 和 runQuery 从 Oracle 获取一些数据，并不断获取 Deferred 而不是实际数据。 如何解决？ 一些代码（我排除了一些不必要的部分，但思路应该很清楚）：

from twisted.enterprise import adbapi
from twisted.internet import defer
import service_config

ORACLE_DSN = service_config.oracle_dsn
ORACLE_USER = service_config.oracle_user
ORACLE_PASSWORD = service_config.oracle_password
dbpool = adbapi.ConnectionPool('cx_Oracle',
    user=ORACLE_USER,
    password=ORACLE_PASSWORD,
    dsn=ORACLE_DSN, port='49161')

@defer.inlineCallbacks
def ask_db():
    data = yield dbpool.runQuery("SELECT * FROM customer")

a = ask_db()
print(a)

我让反应堆在其他模块中运行，如果这很重要的话。 提前谢谢你。

更新： 在@notorious.no 的帮助下，得到了工作代码，返回数据而不是 Python 3.5 的延迟：

@defer.inlineCallbacks
def ask_db(request):
    data = yield dbpool.runQuery(request)

    return defer.returnValue(data) 

Answer 1

你得到一个 Deferred 是因为你调用了一个总是返回 Deferred 的 inlineCallback。您还误解了 yield 的作用。它实际上并没有从inlinceCallback 返回值，它只是等待结果。使用 defer.returnValue() 返回一个值（如果您使用的是 Python 3.4+，则可以使用简单的 return）。你的代码应该是这样的：

from __future__ import print_function
#...

@defer.inlineCallbacks
def ask_db():
    data = yield dbpool.runQuery("SELECT * FROM customer")
    defer.returnValue(data)    # actually return a value

a = ask_db()    # this returns a Deferred so add callbacks!
a.addCallback(print)    # add a useful callback to processes query list
reactor.run()

你之前和这个答案的区别在于添加了一个回调，所以当runQuery()返回一个值时，回调被执行并且ask_db()实际上返回一个你关心的值。

参考文献

• Database Usage with Klein/Twisted