首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >如何在dask-distributed中使用`client.start_ipython_workers()`?

如何在dask-distributed中使用`client.start_ipython_workers()`?
EN

Stack Overflow用户
提问于 2021-02-12 15:08:03
回答 1查看 77关注 0票数 0

我正在尝试让工作人员从他们的ipython内核输出一些信息,并在ipython会话中执行各种命令。我尝试了文档中的示例和ipyparallel示例,但没有尝试第二个示例(使用ipython magics)。我无法让工作人员执行任何命令。例如,我被以下问题卡住了:

代码语言:javascript
运行
复制
from dask.distributed import Client

client = Client()

info = client.start_ipython_workers()

list_workers = info.keys()

%remote info[list_workers[0]]

最后一行返回一个错误:

代码语言:javascript
运行
复制
---------------------------------------------------------------------------
NameError                                 Traceback (most recent call last)
<ipython-input-19-9118451af441> in <module>
----> 1 get_ipython().run_line_magic('remote', "info['tcp://127.0.0.1:50497'] worker.active")

~/miniconda/envs/dask/lib/python3.7/site-packages/IPython/core/interactiveshell.py in run_line_magic(self, magic_name, line, _stack_depth)
   2334                 kwargs['local_ns'] = self.get_local_scope(stack_depth)
   2335             with self.builtin_trap:
-> 2336                 result = fn(*args, **kwargs)
   2337             return result
   2338 

~/miniconda/envs/dask/lib/python3.7/site-packages/distributed/_ipython_utils.py in remote_magic(line, cell)
    115     info_name = split_line[0]
    116     if info_name not in ip.user_ns:
--> 117         raise NameError(info_name)
    118     connection_info = dict(ip.user_ns[info_name])
    119 

NameError: info['tcp://127.0.0.1:50497']

对于如何从运行在workers上的ipython内核获取任何信息,我将不胜感激。

EN

回答 1

Stack Overflow用户

发布于 2021-02-20 01:52:38

在这里发帖只是为了跟踪,我在GitHub上提出了一个问题:https://github.com/dask/distributed/issues/4522

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/66167619

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档