Daskで同じ値を再計算しないでください。

Question

次のコードでは、最初の計算には3 +秒が必要で、2番目の計算ははるかに高速になることが期待されます。クライアントに計算を再実行させないためにdaskを得るにはどうしたらよいですか？ （私は以前に真=純粋について、この質問への答えを探していたし、何も見つかっていない）

from dask import delayed, compute 
from dask.distributed import Client 

@delayed(pure=True) 
def foo(a): 
    time.sleep(3) 
    return 1 

foo_res = foo(1) 

client = Client() 

import time 
t1 = time.time() 
results = compute(foo_res, get=client.get) 
t2 = time.time() 
print("Time : {}".format(t2-t1)) 


t1 = time.time() 
results = compute(foo_res, get=client.get) 
t2 = time.time() 
print("Time : {}".format(t2-t1)) 

出力：

Time : 3.01729154586792 
Time : 3.0170397758483887 

Answer 1

あなたがクライアント上persistメソッドを使用する必要があります

foo_res = client.persist(foo_res) 

これは、foo_resへの参照がyoにある限り、バックグラウンドで計算を開始し、結果をメモリに保持しますウルPythonのセッション

関連ドキュメントのページはこちらです：http://distributed.readthedocs.io/en/latest/manage-computation.html