from dask import delayed
def my_square_function(x):
return x**2
# Create delayed version of above function
delayed_square_function = delayed(my_square_function)
Dask delayed（延迟）
from dask import delayed
def my_square_function(x):
return x**2
# Create delayed version of above function
delayed_square_function = delayed(my_square_function)
# Use the delayed function with input 4
delayed_result = delayed_square_function(4)
# Print the delayed answer
print(delayed_result)
from dask import delayed
def my_square_function(x):
return x**2
# Delay and use function
delayed_result = delayed(my_square_function)(4)
print(delayed_result)
from dask import delayed
def my_square_function(x):
return x**2
delayed_result = delayed(my_square_function)(4)
real_result = delayed_result.compute() # <- This line is where the calculation happens
# Print the answer
print(real_result)
x_list = [30, 85, 14, 12, 27, 62, 89, 15, 78, 0]
sum_of_squares = 0
for x in x_list:
# Square and add numbers
sum_of_squares += delayed(my_square_function)(x)
惰性求值
x_list = [30, 85, 14, 12, 27, 62, 89, 15, 78, 0]
sum_of_squares = 0
for x in x_list:
# Square and add numbers
sum_of_squares += delayed(my_square_function)(x)
result = sum_of_squares.compute()
# Print the answer
print(result)
27268
共享计算
delayed_intermediate = delayed(my_square_function)(3)
# These two results both use delayed_intermediate
delayed_result1 = delayed_intermediate - 5
delayed_result2 = delayed_intermediate + 4
# delayed_3_squared will be computed twice
print('delayed_result1:', delayed_result1.compute())
print('delayed_result2:', delayed_result2.compute())
delayed_result1: 4
delayed_result2: 13
共享计算
import dask
# delayed_intermediate will be computed once
comp_result1, comp_result2 = dask.compute(delayed_result1, delayed_result2)
print('comp_result1:', comp_result1)
print('comp_result2:', comp_result2)
Preparing Video For Download...
