Итерация петли с ожиданием или выходом вызывает ошибку

Question

Я прихожу из земли Twisted/Klein. Я пришел с миром и попросил помощь Tornado. Я изучаю Tornado и как его асинхронный подход отличается от Twisted. Витая есть что-то похожее на gen.coroutine, который defer.inlineCallbacks и я могу написать код асинхронной так:

kleinsample.py

@app.route('/endpoint/<int:n>') 
@defer.inlineCallbacks 
def myRoute(request, n): 
    jsonlist = [] 
    for i in range(n): 
     yield jsonlist.append({'id': i}) 
    return json.dumps(jsonlist) 

локон CMD:

curl localhost:9000/json/2000 

Эта конечная точка будет создайте строку JSON с числом элементов n. n может быть маленьким или очень большим. Я могу разбить его в Twisted, чтобы цикл событий не блокировал использование yield. Теперь вот, как я попытался преобразовать это в Торнадо:

tornadosample.py

async def get(self, n): 
    jsonlist = [] 
    for i in range(n): 
     await gen.Task(jsonlist.append, {'id': i}) # exception here 
    self.write(json.dumps(jsonlist)) 

отслеживающий:

TypeError: append() takes no keyword arguments 

Я смущен о том, что я должен сделать, чтобы правильно перебирать каждый элемент в цикле, чтобы цикл события не блокировался. Кто-нибудь знает способ «Торнадо» сделать это?

Answer 1

Вы не можете и не должны ждать append, так как это не сопрограмма и не возвращает Будущее. Если вы хотите иногда уступать, чтобы другие сопрограммы продолжали использовать цикл событий Tornado, ожидайте gen.moment.

from tornado import gen 

async def get(self, n): 
    jsonlist = [] 
    for i in range(n): 
     jsonlist.append({'id': i}) 
     if not i % 1000: # Yield control for a moment every 1k ops 
      await gen.moment 
    return json.dumps(jsonlist) 

Тем не менее, если эта функция не является чрезвычайно ресурсоемкие и требует сотен миллисекунд или больше, чтобы закончить, вы, вероятно, лучше просто делать все свои вычисления сразу вместо того, чтобы несколько поездок по цикл события перед возвратом функции.

Answer 2

Давайте посмотрим на gen.Taskdocs:

Адаптирует обратный вызов на основе асинхронной функции для использования в сопрограммах.

Выполняет функцию (и необязательные дополнительные аргументы) и запускает ее с этими аргументами плюс аргумент ключевого слова обратного вызова. Аргумент, переданный обратному вызову, возвращается в результате выражения yield.

Поскольку append не принимает ключевое слово аргумент, который не знает, что делать с этим callback kwarg и плюет это исключение.

Что вы можете сделать, это обернуть append с вашей собственной функции, которая делает принимать callback kwarg или подход показал в this ответ.

Answer 3

list.append() возвращает None, так что это немного вводит в заблуждение, что ваш образец Klein выглядит так, будто он дает некоторый объект.Это эквивалентно jsonlist.append(...); yield как два отдельных оператора. Эквивалент торнадо должен был бы сделать await gen.moment вместо голых yield.

Также обратите внимание, что обработчики обработали свои ответы, вызвав self.write(), а не возвращая значения, поэтому оператор return должен быть self.write(json.dumps(jsonlist)).