python - 调用 dask.distributed.Executor 和 dask.distributed.Client 有什么区别

Question

我对 dask 文档中的并发 future 要点有疑问:https://gist.github.com/mrocklin/ef9ccd29a6ec5f4de84d6192be95042a

当我们实例化一个执行器时，是否意味着它也实例化了一个调度器？执行者的代表说

<Client: scheduler='tcp://127.0.0.1:60329' processes=4 cores=4>

那么调用Client()和Executor()有什么区别呢？如果不相同，文档似乎非常相似。在并发 future 示例中，一些人首先实例化一个客户端，然后使用客户端的 IP 地址实例化一个执行器。

Answer 1

它们完全一样。 Executor 是 Client 的旧称。

最初 Dask 使用术语 Executor 来匹配 concurrent.futures应用程序接口(interface)。然而，这个术语让 Spark 用户感到困惑，因为 Executor 被用于他们的 worker 等价物。我们在 2016 年将术语 Executor 更改为 Client，最终将弃用该术语。