记一次ssh.exec_command(cmd)执行后读取结果为空

# 连接跳板机，执行插标签
def con_tmp_machine(mobile_phoneno, myguid):
    keyfile = os.path.expanduser('/Users/kusy/.ssh/id_rsa')
    password = keyring.get_password('SSH', keyfile)
    key = paramiko.RSAKey.from_private_key_file(keyfile, '')

    ssh = paramiko.SSHClient()
    ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
    ssh.connect(hostname='88.88.888.88', port=10022, username='kusy', password="kusy@cys", pkey=key)
    mobile_phoneno = mobile_phoneno
    mobile_phone_tail = mobile_phoneno[-1]
    user_guid = myguid
    sex = "0" if int(mobile_phone_tail) % 2 == 0 else "1"
    add_tag_raw = r'''
        curl -XPOST -H 'Content-Type:application/json' 'xxx.cn:9200/xx_label/job' -d '{
      "user_guid": "$user_guid",
      "mobile_phone_tail": "$mobile_phone_tail",
      "mobile_phone": "$mobile_phoneno",
      "sex":"$sex"
    }'
        '''
    add_tag = add_tag_raw.replace('$mobile_phoneno', mobile_phoneno)\
        .replace('$mobile_phone_tail', mobile_phone_tail)\
        .replace('$user_guid', user_guid)\
        .replace('$sex', sex)

    search_tag_raw = '''curl -XPOST -H "Content-Type:application/json" "xxx.cn:9200/xx_label/job/_search" -d '{"query":{"query_string":{"query":"$mobile_phoneno"}}}'
    '''
    search_tag = search_tag_raw.replace('$mobile_phoneno', mobile_phoneno)

    # 查询标签、加标签流程控制
    result = ''
    err_flag = False
    if user_guid == '':
        cmd = ssh.exec_command(search_tag)
    else:
        cmd = ssh.exec_command(add_tag)
        # Alias [xx_label] has more than one indices
        stdin, stdout, stderr = cmd
        result = stdout.read().decode()
        # print('result', result)
        if result.__contains__('Alias [xx_label] has more than one indices'):
            xx_label = re.compile('(xx-\d{8})').findall(result)
            new_xx_label = sorted(xx_label)[-1]
            print('**new_xx_label**', new_xx_label)
            cmd = ssh.exec_command(add_tag.replace('xx_label', new_xx_label))
        else:
            err_flag = True
            print('add normaly..')
            pass
    if result != '' and err_flag:
        return result
    else:
        stdin, stdout, stderr = cmd
        return stdout.read().decode()

    print("\nssh execute over")

    # 关闭连接
    ssh.close()