Создание Python-программа ждет, пока Twisted deferred вернет значение
У меня есть программа, которая извлекает информацию с других страниц и анализирует их, используя BeautifulSoup и Twisted getPage. Позже в программе я печатаю информацию, которую создает отложенный процесс. В настоящее время моя программа пытается распечатать его до того, как отличное вернет информацию. Как я могу заставить его ждать?
def twisAmaz(contents): #This parses the page (amazon api xml file)
stonesoup = BeautifulStoneSoup(contents)
if stonesoup.find("mediumimage") == None:
imageurl.append("/images/notfound.png")
else:
imageurl.append(stonesoup.find("mediumimage").url.contents[0])
usedPdata = stonesoup.find("lowestusedprice")
newPdata = stonesoup.find("lowestnewprice")
titledata = stonesoup.find("title")
reviewdata = stonesoup.find("editorialreview")
if stonesoup.find("asin") != None:
asin.append(stonesoup.find("asin").contents[0])
else:
asin.append("None")
reactor.stop()
deferred = dict()
for tmpISBN in isbn: #Go through ISBN numbers and get Amazon API information for each
deferred[(tmpISBN)] = getPage(fetchInfo(tmpISBN))
deferred[(tmpISBN)].addCallback(twisAmaz)
reactor.run()
.....print info on each ISBN
2 ответа
Похоже, вы пытаетесь создать / запустить несколько реакторов. Все подключается к тому же реактору. Вот как использовать DeferredList , чтобы дождаться завершения всех ваших обратных вызовов.
Также обратите внимание, что twisAmaz возвращает значение. Это значение передается через обратные вызовы DeferredList и выводится как значение . Поскольку DeferredList сохраняет порядок вещей, которые в него помещены, вы можете связать индекс результатов с индексом ваших ISBN.
from twisted.internet import defer
def twisAmaz(contents):
stonesoup = BeautifulStoneSoup(contents)
ret = {}
if stonesoup.find("mediumimage") is None:
ret['imageurl'] = "/images/notfound.png"
else:
ret['imageurl'] = stonesoup.find("mediumimage").url.contents[0]
ret['usedPdata'] = stonesoup.find("lowestusedprice")
ret['newPdata'] = stonesoup.find("lowestnewprice")
ret['titledata'] = stonesoup.find("title")
ret['reviewdata'] = stonesoup.find("editorialreview")
if stonesoup.find("asin") is not None:
ret['asin'] = stonesoup.find("asin").contents[0]
else:
ret['asin'] = 'None'
return ret
callbacks = []
for tmpISBN in isbn: #Go through ISBN numbers and get Amazon API information for each
callbacks.append(getPage(fetchInfo(tmpISBN)).addCallback(twisAmazon))
def printResult(result):
for e, (success, value) in enumerate(result):
print ('[%r]:' % isbn[e]),
if success:
print 'Success:', value
else:
print 'Failure:', value.getErrorMessage()
callbacks = defer.DeferredList(callbacks)
callbacks.addCallback(printResult)
reactor.run()
Во-первых, вы не должны помещать response.stop () в отложенный метод, так как он убивает все.
Теперь в Twisted "Ожидание" запрещено. Чтобы распечатать результаты вашего обратного вызова, просто добавьте еще один обратный вызов после первого.