Удаленный ssh ​​в ткани без использования fabfile - PullRequest
Новая
       4

Удаленный ssh ​​в ткани без использования fabfile

1 голос
/ 19 декабря 2011

Я пишу программу для удаленного выполнения нескольких команд с использованием Fabric и GearMan.

Ниже приведен код клиента для Gearman 

import sys , os , json
from fabric.api import *
import gearman
from gearman import GearmanClient


def check_request_status(job_request):
    if job_request.complete:
        print "Job %s finished!  Result: %s - %s" % (job_request.job.unique, job_request.state, job_request.result)
    elif job_request.timed_out:
        print "Job %s timed out!" % job_request.unique
    elif job_request.state == JOB_UNKNOWN:
        print "Job %s connection failed!" % job_request.unique


#gearman client (test file)
gm_client = gearman.GearmanClient(['localhost:4730'])

# See gearman/job.py to see attributes on the GearmanJobRequest
d = {}
d['host'] = 'xyz.abc.com'
d['cmd'] = 'ls -l'
a = json.dumps(d)

completed_job_request = gm_client.submit_job("exe_job", a)
check_request_status(completed_job_request)

Ниже приведен мой код Worker 

import sys , os , json
from fabric import *
from fabric.api import *
import gearman
from gearman import GearmanWorker




#executing the fab command . All the configurations are  mentioned in fabfile.py
def exe_job(gmWorker , gmJob ):
 #host = 'synergy.corp.yahoo.com'
 #d = json.loads(gmJob)
 #run (str(d[cmd]), str(d[host]))
 d = json.loads(gmJob.data)
 env.hoststring = [ str(d['host']) ]
 run ( str(d['cmd']) )
 return gmJob.data


#woker node id to be specified in here
gm_worker = gearman.GearmanWorker(['localhost:4730'])
#gm_worker.set_client_id('client1')
gm_worker.register_task('exe_job',exe_job)
gm_worker.work()

Проблема в том, что когда я запускаю код работника и клиента, работник все еще спрашивает у меня имя хоста, хотя я указал имя хоста.Есть ли другой способ установить имя хоста в Fabric?Я не собираюсь создавать подпроцесс и запускать cmd.

1 Ответ

0 голосов
/ 19 декабря 2011

Исправлено:

  1. json возвращал данные в формате Unicode, поэтому использовал simplejson.
  2. Его env.host_string была переменной для хранения имени хоста.

:)

...