如何使用 PHP Stargate 客户端将数据插入 Hbase 表答案

【问题标题】：How to insert data into Hbase tables using PHP Stargate client如何使用 PHP Stargate 客户端将数据插入 Hbase 表
【发布时间】：2011-01-09 07:00:37
【问题描述】：

我正在安装 HBase 集群，并尝试通过 Stargate REST 接口访问数据。大多数只读功能（即列出表格、获取版本、元数据等）都运行良好。但是，我无法将数据实际插入到我创建的任何表中。这是我到目前为止所得到的......

创建了一个有两列的虚拟表，如下：

$table_schema = <<<SCHEMA
    <TableSchema name="mytable" IS_META="false" IS_ROOT="false">
        <ColumnSchema name="info" BLOCKSIZE="65536" BLOOMFILTER="false" BLOCKCACHE="false" COMPRESSION="NONE" LENGTH="2147483647" VERSIONS="1" TTL="-1" IN_MEMORY="false" />
        <ColumnSchema name="url" BLOCKSIZE="65536" BLOOMFILTER="false" BLOCKCACHE="false" COMPRESSION="NONE" LENGTH="2147483647" VERSIONS="1" TTL="-1" IN_MEMORY= "false"/>
    </TableSchema>
SCHEMA;

require_once "HTTP/Request.php";
$request = new HTTP_Request("http://localhost:8080");
$request->setMethod(HTTP_REQUEST_METHOD_PUT);
$request->addHeader("Accept", "text/xml");
$request->addHeader("Accept", "text/xml");
$request->setBody($table_schema);
$request->sendRequest();

表创建工作正常。接下来，我想在我的新表中插入一些数据。这是我尝试这样做的方法：

$row_key = base64_encode("higgilty");
$column_name = base64_encode("info");
$value = base64_encode("Here is a test value");

$data = <<<DATA
     <?xml version="1.0" encoding="UTF-8" standalone="yes"?>
     <CellSet>
         <Row key="$row_key">
             <Cell column="$column_name">
                 $value
             </Cell>
         </Row>
     </CellSet>
DATA;

require_once "HTTP/Request.php";
$request = new HTTP_Request("http://localhost:8080/mytable/higgilty");
$request->setMethod(HTTP_REQUEST_METHOD_PUT);
$request->addHeader("Accept", "text/xml");
$request->addHeader("Accept", "text/xml");
$request->setBody($data);
$request->sendRequest();

此请求的结果返回 503 错误，有以下异常：

[...] org.apache.hadoop.hbase.regionserver.NoSuchColumnFamilyException: Column family  does not exist in region [...]

错误很明显，但我不确定上面发布的架构有什么问题。

我还想知道我是否最好使用 Thrift 包并生成必要的 PHP 客户端文件而不是使用 Starbase？如果有人对此有任何经验，我很乐意听取您的意见。

非常感谢任何帮助。

【问题讨论】：

标签： php rest hbase thrift stargate

【解决方案1】：

您需要将列名指定为family:qualifier 对。您指定的“ColumnSchema”仅给出家族名称，因此您可以说，例如，$column_name = base64_encode("info:column1");

【讨论】：

我已经有一段时间没有发布这个了，但是感谢您抽出宝贵的时间来回答！