PROSAGA码农传奇-hbase-Cloudera / CDH v6.1.x + Python HappyBase v1.1.0：TTransportException（type = 4，message ='TSocket read 0 bytes'）

<div class =“post-text”itemprop =“text”>
  <P>
    经过一天的努力，我的问题的答案如下：
  </p>
   <pre>
    <code>
      import happybase

CDH6_HBASE_THRIFT_VER='0.92'

hbase_cnxn = happybase.Connection(
    host='vps00', port=9090,
    table_prefix=None,
    compat=CDH6_HBASE_THRIFT_VER,
    table_prefix_separator=b'_',
    timeout=None,
    autoconnect=True,
    transport='framed',  # Default: 'buffered'  <---- Changed.
    protocol='compact'   # Default: 'binary'    <---- Changed.
)

print('tables:', hbase_cnxn.tables()) # Works. Output: [b'ns1:mytable', ]

</code>
  </pre>
  <P>
    请注意，虽然这个Q＆amp; A是在上下文中构建的
     <code>
      Cloudera
    </code>
    事实证明（正如你将看到的那样）
     <code>
      Thrift
    </code>
     版本和
     <code>
      Thrift
    </code>
     服务器端配置相关，因此适用于
     <code>
      Hortonworks
    </code>
     和
     <code>
      MapR
    </code>
     用户也是。
  </p>
  <P>
    的<strong>
      说明
    </强>
    ：
  </p>
  <P>
    上
     <code>
      Cloudera CDH v6.1.x
    </code>
     （如果你访问的话，也可能是未来的版本）
     <code>
      Hbase Thrift Server Configuration
    </code>
     它的管理部分U.I.，你会发现 - 在许多其他设置 - 这些：
  </p>
  <HR />
  <H2>
    <a href="https://i.stack.imgur.com/dAtmq.png" rel="nofollow noreferrer">
      <img src =“https://i.stack.imgur.com/dAtmq.png”alt =“CDH6.1.x Hbase Thrift Server配置U.I。”/>
    </A>
  </H2>
  <P>
    请注意
     <code>
      compact protocol
    </code>
     和
     <code>
      framed transport
    </code>
     都启用了;所以他们相应地需要改变
     <code>
      happybase
    </code>
     从它的默认值（我在上面显示）。
  </p>
  <P>
    如上所述
    的<strong>
      编辑
    </强>
     跟进我的初步问题，我也调查了一个纯粹的问题
     <code>
      Thrift
    </code>
     （非
     <code>
      happybase
    </code>
    ）解决方案。对于这种情况的Python代码的类似更改，我也可以使用它。这是你应该用于纯粹的代码
     <code>
      Thrift
    </code>
     解决方案（注意阅读下面的注释注释）：
  </p>
   <pre>
    <code>
      from thrift.protocol import TCompactProtocol             # Notice the import: TCompactProtocol [!]
from thrift.transport.TTransport import TFramedTransport # Notice the import: TFramedTransport [!]
from thrift.transport import TSocket
from hbase import Hbase
   # -- This hbase module is compiled using the thrift(1) command (version >= 0.10 [!])
   #    and a Hbase.thrift file (obtained from http://archive.apache.org/dist/hbase/
   # -- Also, your "pip freeze | grep '^thrift='" should show a version of >= 0.10 [!]
   #    if you want Python3 support.

(host,port) = ("vps00","9090")
transport = TFramedTransport(TSocket.TSocket(host, port))
protocol  = TCompactProtocol.TCompactProtocol(transport)
client = Hbase.Client(protocol)

transport.open()

# Do stuff here ...
print(client.getTableNames()) # Works. Output: [b'ns1:mytable', ]

transport.close()

</code>
  </pre>
  <P>
    我希望这能让人们痛苦地度过难关。 = :)
  </p>
  <P>
    的<strong>
      学分
    </强>
    ：
  </p>
  <UL>
    <LI>
      <a href =“https://mapr.com/support/s/article/How-to-modify-hbase-thrift-client-code-if-Hbase-Thrift-Service-enables-framed-transport-and-compact -protocol？language = en_US“rel =”nofollow noreferrer“>
        这里（MapR）
      </A>
       和
    </LI>
    <LI>
      <a href="http://shzhangji.com/blog/2018/04/22/connect-hbase-with-python-and-thrift/" rel="nofollow noreferrer">
        在这里（来自中国的博客）
      </A>
    </LI>
  </UL>
</DIV>