Phoenix 连接 HBase 建表并插入 MySQL 数据

建立 Phoenix 连接：

首先，需要在 HBase 中启用 Phoenix 功能。在 HBase 的 conf 目录下，找到 hbase-site.xml 文件，在其中添加以下配置：

<property>
  <name>hbase.regionserver.wal.codec</name>
  <value>org.apache.hadoop.hbase.regionserver.wal.IndexedWALEditCodec</value>
</property>

然后，在 HBase 的 lib 目录下，添加 Phoenix 的 jar 包：

phoenix-core-<version>.jar

接着，在 HBase 的 bin 目录下，执行以下命令启动 Phoenix 服务：

./start-hbase.sh
./sqlline.py localhost:2181:/hbase-unsecure

在 sqlline.py 命令行界面中，输入以下命令建立 Phoenix 连接：

!connect jdbc:phoenix:localhost:2181:/hbase-unsecure

在 HBase 中建表：

在 Phoenix 中，可以使用 SQL 语句来操作 HBase 表。下面是一个简单的例子，展示如何在 HBase 中建立一张表：

CREATE TABLE mytable (
     mykey VARCHAR PRIMARY KEY,
     mycolumn1 VARCHAR,
     mycolumn2 VARCHAR
);

将 MySQL 中查出的数据插入到 HBase 表中：

在 Python 中，可以使用 happybase 库来操作 HBase 表。下面是一个简单的例子，展示如何将 MySQL 中查出的数据插入到 HBase 表中：

import happybase
import mysql.connector

# 连接 MySQL 数据库
cnx = mysql.connector.connect(user='user', password='password', host='localhost', database='database')
cursor = cnx.cursor()

# 查询数据
query = ("SELECT mykey, mycolumn1, mycolumn2 FROM mytable")
cursor.execute(query)

# 连接 HBase 表
connection = happybase.Connection(host='localhost', port=9090)
connection.open()
table = connection.table('mytable')

# 插入数据
for (mykey, mycolumn1, mycolumn2) in cursor:
    data = {'mycolumn1': mycolumn1, 'mycolumn2': mycolumn2}
    table.put(mykey, data)

# 关闭连接
cursor.close()
cnx.close()
connection.close()