@base.post_async('/cmd/exec')
def node_exec_command(request):
    t = Talker(request.form['host'], int(request.form['port']))
    try:
        r = t.talk(*json.loads(request.form['cmd']))
    except __HOLE__ as e:
        r = None if e.message == 'No reply' else ('-ERROR: ' + e.message)
    except ReplyError as e:
        r = '-' + e.message
    finally:
        t.close()
    return base.json_result(r)
dataset/ETHPy150Open HunanTV/redis-ctl/handlers/commands.py/node_exec_command