Twisted 및 Oracle이있는 데이터 대신 dbpool.runQuery에서 연기받습니다.

Question

Twisted 및 runQuery를 사용하여 Oracle에서 일부 데이터를 가져 오려고 시도하고 실제 데이터 대신 지연된 데이터를 계속 가져 오려고합니다. 어떻게 해결할 수 있습니까? 일부 코드 (I는 불필요한 부분을 제외하지만, 아이디어가 명확해야한다) : 그 중요한 경우

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) 

나는, 다른 모듈 원자로 운전을 얻었다. 미리 감사드립니다.

UPDATE : @의 도움으로 데이터를 반환 코드를 작업 대신 파이썬 3.5 이연있어 notorious.no :

당신은 항상 이연 반환하는 inlineCallback를 호출하고 있기 때문에 당신이 이연받을

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

    return defer.returnValue(data) 

Answer 1

. yield의 의미를 잘못 해석하고있는 것입니다. 실제로는 결과를 기다리는 inlinceCallback에서 값을 반환하지 않습니다. 값을 반환하려면 defer.returnValue()을 사용하십시오 (파이썬 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() 실제로을 반환 할 때 콜백이 그렇게 추가됩니다 무엇의 차이 가치있는 것. 당신이 ask_db 내부 인쇄 (데이터)에 인쇄 (A)를 변경하는 경우

참조

• Database Usage with Klein/Twisted