Python gearman 基本示例错误

标签 python gearman python-gearman

我正在尝试使用 Python gearman 模块进行字符串反转的基本示例 我的本地主机已使用端口 4730 上的 IIS 设置 但是我收到错误

raise UnknownCommandError(missing_callback_msg)
UnknownCommandError: Could not handle command: 'GEARMAN_COMMAND_TEXT_COMMAND' - {'raw_text': 'HTTP/1.1 400 Bad Request\r'}

Client.py

    import gearman
    #  setup client, connect to Gearman HQ
    gm_client = gearman.GearmanClient(['localhost:4730'])
    print 'Sending job...'
    request = gm_client.submit_job('reverse', 'Hello World!')
    print "Result: " + request.result

Worker.py

    import gearman
    gm_worker = gearman.GearmanWorker(['localhost:4730'])
    #  define method to handled 'reverse' work
    def task_listener_reverse(gearman_worker, gearman_job):
            print 'reporting status'
            return reversed(gearman_job.data)
    gm_worker.set_client_id('your_worker_client_id_name')
    gm_worker.register_task('reverse', task_listener_reverse)
    gm_worker.work()

关于为什么会发生这种情况以及如何解决该问题的任何建议

最佳答案

当前版本的 gearman 有不同的导入结构。您需要说 from gearman.worker import GearmanWorkerfrom gearman.client import GearmanClient

此外,返回值应为 return ''.join([i for i in returned(gearman_job.data[::1])]) 以获得反转的字符串。

关于Python gearman 基本示例错误,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31226942/

相关文章:

php - Gearman:从后台 worker 向客户端发送数据

ruby-on-rails - Gearman 架构查询

python - 如何通过他们的唯一 ID 获取 Gearman Jobs 的状态?

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

python - Pandas :对于一列中的每个项目,计算另一个给定列中不同项目的数量

mysql - 如何用gearman配置mysql?

python - TensorFlow 'global_step' 变量未针对指数衰减进行更新

python - 如何将 python 字符串(包括 '\b' )转换为原始字符串?

python - 如何在 hexbin 图上绘制等高线?