从任务中获取 Dask 工作人员的 ID

MRo*_*lin 6 dask dask-distributed

dask 工作人员是否可以从任务中以编程方式访问工作人员 ID 或某些唯一标识符?

MRo*_*lin 8

是的,您可以使用该get_worker函数访问您当前所在的工作人员,然后获取该id属性。

from dask.distributed import get_worker
get_worker().id
Run Code Online (Sandbox Code Playgroud)