python - Dask Distributed：如何从集群中删除上传的文件

Question

我想知道是否有一个函数dask.distributed可以删除上传到集群的文件client.upload_file()？

基本上与upload_file()功能相反。此致

Answer 1

截至今天，没有直接执行此操作的功能。但作为一种解决方法，您可以使用client.runwith os.remove：

client.run(lambda dask_worker: os.remove(os.path.join(dask_worker.local_directory, "file.py")))

wherefile.py可以替换为您上传的文件的名称。

请注意，输入参数client.runmust 是dask_worker相关文档：https ://distributed.dask.org/en/latest/api.html#distributed.Client.run