что делает compute () в dask?

Question

Я новичок в dask и не понимаю, что именно делает метод compute () в dask? это метод для печати объекта, где он вызывается? Я прочитал документацию с ее веб-сайта и не уверен, что понимаю термины «конкретные значения» и «ленивый напиток».

Вы можете превратить любую коллекцию напитков в конкретное значение, вызвав .compute() или функцию dask.compute (...). Эта функция будет блокироваться до тех пор, пока вычисление не будет завершено, переходя прямо из коллекции отложенных данных в конкретное значение в локальной памяти.

что я имею в виду, говоря «делает ли это метод для печати объекта, гдепозвонить? в том, что когда я создаю объект dask и вызываю его в консоли spyder, это приводит к dask.array<arange, shape=(11,), dtype=int32, chunksize=(5,)>, а когда я вызываю на нем метод compute (), он печатает объект.

объект x был создан с помощью кода ниже:

x = da.arange(11, chunks=5)

Answer 1

Хорошее и простое введение в эту тему можно найти по адресу https://towardsdatascience.com/why-every-data-scientist-should-use-dask-81b2b850e15b (найти главу Параллельная обработка с Dask ).

Первым шагом является подготовка график вычислений :

computation_graph = sum_list([square(i) for i in items])

Приведенная выше инструкция только создала «рецепт», как выполнять вычисления, но фактические вычисления не были начаты (пока).

Aчуть ниже есть следующая инструкция:

print("Result", computation_graph.compute())

, которая запускает вычисление , и поскольку она находится внутри инструкции print , у нас также есть демонстрация того, каквычисления выполняются.

Таким образом, использование Dask обычно включает в себя 4 шага:

• Получение (чтение) исходных данных.
• Подготовка рецептадолжны быть вычислены.
• Запустить вычисление (и только это выполняет вычислить ).
• "Поглотить" результат вычисления (после его завершения).