Интерфейс IPython для распределенных работников Dask через ssh приводит к «Отказ в соединении» - PullRequest
0 голосов
/ 19 октября 2018

Сегодня я подумал, что попытаюсь лучше узнать своих работников, создав ядро ​​ipython.Это казалось достаточно простым, используя удобный

client.start_ipython_workers()

. Мне удалось получить информацию о соединении, а затем я написал сценарий для вывода его в JSON.Затем я настроил переадресацию некоторых портов для подключения к рабочему, однако рабочий клиент, похоже, не принимает подключения.

подключение канала 2: открытие не удалось: подключение не удалось: подключение отклонено

Возможно, у меня все еще есть некоторые проблемы с настройкой ssh, однако я успешно подключился к ядру ноутбука Jupyter через аналогичный канал.Есть ли какая-то причина, по которой работник блокирует соединения?

winfo = client.start_ipython_workers()
for worker in winfo.keys():
    winfo[worker]['key']=winfo[worker]['key'].decode('utf8')
with open(os.path.join('/home/centos/kernels/','kernel-'+winfo[worker].pop('ip')+'.json'), 'w+') as f:
    winfo[worker]['ip']='127.0.0.1'
    json.dump(winfo[worker], f,indent=2)
#!/bin/bash

for port in $(cat $2 | grep '_port' | grep -o '[0-9]\+'); do
echo "establishing tunnel to "$port
ssh $1 -f -N -L $port:127.0.0.1:$port
done
...