zookeeper,通过python连接找出其对应的hive
2024-10-19 18:29:45
#通过zookpeer找到对应的hive
from kazoo.client import KazooClient zkClient = KazooClient(hosts="ip1:2181,ip2:2181")
zkClient.start()
result = zkClient.get_children('/mynode') # znodename对应的值
zkClient.stop()
print(result) #
['serverUri=IP1:10000;version=1.1.0-cdh5.7.0;sequence=0000001093', 'serverUri=ip2:10000;version=1.1.0-cdh5.7.0;sequence=0000001094', 'serverUri=IP3:10000;version=1.1.0-cdh5.7.0;sequence=0000001090', 'serverUri=IP4:10000;version=1.1.0-cdh5.7.0;sequence=0000001095']
for i in result:
a=i.split(';')[0].split('=')[1]
print(a) #得出 IP:port
最新文章
- H5项目常见问题汇总及解决方案
- Redis作为多个Windows服务运行配置方法
- java 笔记(4) —— java I/O 流、字节流、字符流
- netbeans环境的建立
- erlang observer工具
- 修改eclipse中web项目的server部署路径
- 394. Coins in a Line
- C# mvc 验证码2
- 搜索提示時jquery的focusout和click事件沖突問題完美解决
- javascript区分电脑与手机登陆
- Tornado web 框架
- [ext4]空间管理 - 分配机制
- 初步了解asp.net运行机制
- HDOJ2002-计算球体面积
- MyCP课下作业
- Android - 简单listview
- git批量修改已经提交的commit的姓名和邮箱
- Kylin知识点介绍
- chrome谷歌浏览器常用快捷键搜集整理
- Grunt-Kmc基于KISSY项目打包
热门文章
- asp.net开发微信公众平台----目录汇总-持续更新
- 牛客多校第五场G
- IDEA创建springboot异常(Failed to load class ";org.slf4j.impl.StaticLoggerBinder";)
- centos7升级kernel之后,vmware无法打开
- 小程序的开发框架MINA及小程序的启动机制
- git 时 出现 Permission denied (publickey).
- vlan vtp配置
- jmeter动态修改线程组参数
- 【ABAP系列】SAP ABAP基础-abap数据类型的解析整理
- Cross-entropy Cost Function for Classification Problem