当我尝试使用以下命令导入scheduler时，我正在尝试使用scheduler、worker和client设置分布式计算： ImportError Traceback (most recent call last)----> 1
浏览 46提问于2020-03-02得票数 1
我正在尝试导入集合包，但一直收到这个错误: ImportError:无法导入名称‘dask.distributed _ to _dsk’。感谢您的帮助。
浏览 0提问于2018-03-30得票数 1
下面是我的示例代码：from time import time
print("Setup some
浏览 4提问于2017-02-21得票数 1
我启动了几个EC2实例，并在conda中安装了dask，在各自的实例中启动了调度程序和worker，调度程序能够接收来自工作人员的连接。但是，在启动客户端并收集结果(例如x.result())之后，会抛出错误
调度器-终端
>>> from dask</em
浏览 0提问于2018-07-16得票数 2
回答已采纳
由于特定于我的构建系统的原因，我目前无法运行dask-调度程序CLI -我必须从代码启动调度程序(示例在dask.distributed文档中提供)。是否也有一种方法来启动和自定义(即选择端口)用于调度程序的Web？
浏览 4提问于2017-07-17得票数 1
回答已采纳
2回答
使用，我创建了一个Dask集群。dask01-worker-ccc-cccc 1/1 Running 0 3d19hfrom dask import distributed
cluster = None # TODO: configure KubeCluster somehow https://kubernetes.<e
浏览 17提问于2020-03-14得票数 1
测试代码：import dask.array as dafrom itertools importda.from_array(arr, chunks=chunks) print(result.compute())
如果是这样的话，那么设置调度程序的上下文可以帮助吗如何为dask数组上的函数设置上下文？我想使用默认
浏览 4提问于2017-12-23得票数 0
回答已采纳
我正在考虑不同的方法来自动启动和控制dask分布式调度程序和Ubuntu16.04上的工作人员。
目前，我认为最相关的选项是使用systemd守护进程。这需要创建和安装。重新加载配置的命令也是有用的，但是，我不确定如何使Python重新导入模块，以及它是否比重新启动进程更简单。看起来目前不可能通过运行dask-scheduler或dask-worker命令来停止调度程序/工作人员，不是吗？我没有找到任何相关的命令行开关。另一
浏览 1提问于2016-09-08得票数 2
回答已采纳
当我使用启动调度程序时，dask调度程序没有提到启动仪表板。正如我所预期的那样，我无法按我所期望的地址到达它。
分布式
浏览 1提问于2019-01-06得票数 0
1回答
我已经在集群上安装并运行了dask，但我似乎无法访问诊断网页。登陆页可见，见下文：但所有的链接只是挂起，从来没有加载页面。调度程序很好地启动了这个输出：distributed.scheduler- INFO - -----------------------------------------------
<em
浏览 2提问于2017-04-18得票数 5
我正在尝试使用dask.distributed Python API来启动一个调度程序。中提供的示例按预期工作，但它没有提供有关如何提供启动Bokeh web界面所需的选项的见解。在检查了dask.distributed源代码之后，我知道我需要使用Scheduler(services={})提供Bokeh选项。不幸的是，我尝试为services={}找到正确的字典格式失败了。下面是dask调度器函数的代码。import dask.<e
浏览 40提问于2019-05-23得票数 0
回答已采纳
1回答
问题Situationdask-scheduler --port 8786Waiting to conn
浏览 0提问于2017-06-20得票数 0
回答已采纳
在OSX10.12.6上运行DASK0.16.0时，我无法将本地dask-worker连接到本地dask-scheduler。我只想跟随官方的。复制步骤：
步骤2:运行dask-worker 10.160.39.103:8786这个问题似乎与dask调度程序有关，而与工作人员无关，因为我甚至无法通过其他方法(例如nc -zv 10.160.39.103
浏览 8提问于2018-01-02得票数 3
回答已采纳
1回答
如何取消和重新提交停滞的任务？
、、、、
我在运行脚本的同一个节点上运行Dask调度程序(不同于.228节点和数据存储节点)。, get_pty=True) distributed.worker - INFO
浏览 4提问于2019-11-13得票数 3
回答已采纳
2回答
从客户端获取调度程序地址
、、、、
我正在使用dask部署在我的HPC上。我想获得调度器地址，以便与另一个库一起使用。对于LocalCluster (或任何其他显式集群定义)来说，这很简单，例如：client = Client(cluster)
但是dask-mpi是在没有集群对象的情况下初始化的：
from
浏览 6提问于2022-04-05得票数 1
回答已采纳
它使用远程调度器(dask.config.set({"kubernetes.scheduler-service-type": "LoadBalancer"}))，工作非常完美。这与传递containers: args: [dask-scheduler]有关import daskfrom d
浏览 5提问于2020-07-20得票数 0
回答已采纳
2回答
Modin与dask冲突
、、、
= 'file.csv'
df = pd.read_csv(PATH)
mdf = md.read_csv(PATH) UserWarning:尚未初始化的Dask\asyncio\tasks.py:683> exception=ImportError(“无法从部分初始化的模块'multiprocessing.popen_spawn_win32‘导入名称'Popen_Popen”中，ImportError</e
浏览 7提问于2021-05-16得票数 0
dask中有没有办法在老工人死后添加新工人时重新提交工作(来自以前死的工人)？有没有可能使用调度程序插件distributed.diagnostics.plugin.SchedulerPlugin来实现这一点
浏览 12提问于2021-03-10得票数 1
我试图使用Dask在一个数据中心中的4个服务器(称为B、C、D和E)上从机器(称为A)分发工作。A应该设置SSHCluster，将调度器分配给B，然后在B、C、D和E上生成工作人员。这对于调度程序来说很容易，但我不能让它为工人工作。
浏览 5提问于2020-06-17得票数 2
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
