MAPREDUCE服务 MRS-Python样例代码:样例代码

时间：2024-06-19 14:14:17

样例代码

from kazoo.client import KazooClient
zk = KazooClient(hosts='ZookeeperHost')
zk.start()
result=zk.get("/thriftserver/active_thriftserver")
result=result[0].decode('utf-8')
JD BCS erverHost=result[0].split(":")[0]
JDB CS erverPort=result[0].split(":")[1]
from pyhive import hive
conn = hive.Connection(host=JDBCServerHost, port=JDBCServerPort,database='default')
cursor=conn.cursor()
cursor.execute("select * from test")
for result in cursor.fetchall():
    print result

其中，ZookeeperHost使用4获取到的zookeeper IP和PORT替换。

上一篇：MAPREDUCE服务 MRS-Python样例代码:环境准备

下一篇：MAPREDUCE服务 MRS-Python样例代码:环境准备