python - 从本地 gearman 客户端调用远程 gearman 工作人员？

Question

是否可以从本地系统调用远程 gearman 工作人员？我尝试使用我的远程 Azure 服务器 IP 进行调用:

本地系统上的客户端:

gm_client = gearman.GearmanClient(['204.43.9.41:4730'])
sent = sys.argv[1]
completed_job_request = gm_client.submit_job("load_db", sent)

远程 worker :

def __init__(self):
    self.gm_worker = gearman.GearmanWorker(['204.43.9.41:4730'])
    self.context = self.init_context()
    res = self.gm_worker.register_task('load_db', self.run_query)

当我让工作程序在远程服务器上运行并从本地客户端调用时，它给出了以下错误:

gearman.errors.ServerUnavailable: Found no valid connections: GearmanConnection 204.43.9.41:4730 connected=False

Answer 1

有一个非常简单的方法可以做到这一点:

1. 将本地 gearman 端口与远程 gearman 端口绑定(bind):

   sudo ssh -L 4730:localhost:4730 <a href="https://stackoverflow.com/cdn-cgi/l/email-protection" class="__cf_email__" data-cfemail="bedfc4cbccdbcbcddbccfecddbccc8dbccd0dfd3db90dfc4cbccdbddd2d1cbdadfcece90d0dbca" rel="noreferrer noopener nofollow">[email protected]</a>

2. 现在让工作线程在远程服务器上运行

3. 从本地系统进行简单调用

   python worker.py 'input parameter'