dask - 分析工作人员和客户端之间的 Dask 分布式通信

Question

我想问一下是否有办法及时衡量工人和客户之间的沟通。目前，我正在使用调度程序插件来获取任务状态并从那里获取执行的详细信息。当结果返回给客户端时，我看不到任何传输任务。假设它等于最后完成的任务和计算返回之间的时间是否公平？

我们如何才能找到从每个任务转移到客户端的数据量？

一个一般的例子是

{task: id, "Bytes Returned": 128, "Time":50ms}

谢谢！

Answer 1

目前没有衡量与客户端之间的通信的机制。