Pythonジェネレータとreduce

Question

@gen.coroutineデコレータを使用して、GETリクエスト用の非同期コルーチンを使用しているPython3 tornado Webサーバで作業しています。

@gen.coroutine 
def foo(x): 
    yield do_something(x) 

十分に単純である：私は図書館から本機能を使用したい

@gen.coroutine 
def get(self): 
    x = self.some_parameter 
    yield response(foo(x)) 

は今など、複数の機能foo1、foo2は、同じタイプであると仮定します。私はgetの方法でちょうどresponse(foo(x))の代わりに...foo3(foo2(foo1(x).result()).result())...とyieldのようなものをしたいと思います。

reduceとresultの方法ではこれが簡単だと思いました。しかし、tornadoの仕組みのために、fooはresultメソッドで何かを返すよう強制することはできません。つまり、yield reduce(...)は「DummyFutureは結果のブロックをサポートしていません」というエラーを表示します。 SOおよび他の場所で他の回答からは、私は私は私は本当に理解していないIOLoopか何かを、使用する必要があります知っている、と...

...私の質問は、どのように私はすべてのを評価避けるすることができますfooとyieldは、getメソッドの評価されていないチャンクですか？ 1.巣機能の多くと2がないがすぐに評価しよう：

編集：私はしたいので、これはthis questionの複製ではありません。

Answer 1

竜巻では、yield未来にコルーチンを入れて結果を得る必要があります。 Tornado's coroutine guideを確認してください。

コルーチンであるレデューサーを書くことができます。それは、未来を得るために、それぞれのコルーチンを実行し、結果を得るために、将来にyieldを呼び出し、その結果を次のコルーチンを実行します：

from tornado.ioloop import IOLoop 
from tornado import gen 


@gen.coroutine 
def f(x): 
    # Just to prove we're really a coroutine. 
    yield gen.sleep(1) 
    return x * 2 


@gen.coroutine 
def g(x): 
    return x + 1 


@gen.coroutine 
def h(): 
    return 10 


@gen.coroutine 
def coreduce(*funcs): 
    # Start by calling last function in list. 
    result = yield funcs[-1]() 

    # Call remaining functions. 
    for func in reversed(funcs[:-1]): 
     result = yield func(result) 

    return result 


# Wrap in lambda to satisfy your requirement, to 
# NOT evaluate immediately. 
latent_result = lambda: coreduce(f, g, h) 
final_result = IOLoop.current().run_sync(latent_result) 
print(final_result)