2

我正在尝试为学校项目创建一个raspberry-pi cluster使用dispy。

只是为了尝试一下，我只使用一个 RPi 作为 anode和我的 pc 作为master请求作业。

在设备及其ip（S）下方：

master (pc)  -->  192.168.1.106
node (rpi)   -->  192.168.1.105

节点配置：

我dispynode在我的节点中执行：

sudo dispynode.py -i 192.168.1.105

在哪里：

  • sudo确保不会有关于许可的问题
  • -i 192.168.1.105告诉节点为通信设置了哪个地址（文档）

控制台输出：

2015...12:21 - dispynode - dispynode version 4.5
2015...12:21 - dispynode - serving 1 cpus at 192.168.1.105:51348

我说：“看起来不错！”

主配置：

我写了一个小脚python本来测试集群：

import dispy

cluster = dispy.JobCluster(
    "/bin/ls",
    nodes=["192.168.1.105"],
    ip_addr="192.168.1.106"
)

cluster.stats()

在哪里：

  • cluster将是JobCluster具有以下规格的新产品
  • "/bin/ls"是可执行文件的路径，节点的作业
  • nodes包含将接收作业的节点的地址（在这种情况下只有一个，我的 rpi）
  • ip_addr是主站用于通信的地址
  • cluster.stats()打印有关创建的集群的统计信息

我希望只有一个节点已连接，但是当我运行此脚本时，我得到了以下统计信息：

2015...12:22 - dispy - Storing fault recovery information in "_dispy_2015..."

Node |  CPUs |    Jobs |    Sec/Job | Node Time Sec
-----------------------------------------------------------------------------

Total job time: 0.000 sec

如您所见，没有连接到主节点的 rpi 节点...

创建的也是fault recovery file空的。

如何将节点连接到主节点？

我以错误的方式dispynode或主脚本使用？

注意和有用：

  • Obiuvsly 我已经安装dispy在这两种设备中。
  • 我可以使用 from master 到达节点，ping反之亦然。
  • ufw被禁用。
  • 文档在这里。
4

1 回答 1

0

您是否尝试提交工作？Dispy 可能仅在有实际工作时才启动连接。

于 2016-06-30T21:39:05.853 回答