- # -----------python 访问 Redis 集群 -----------------------
- from rediscluster import StrictRedisCluster
- import requests
- startup_nodes = [
- {"host": "192.168.5.111", "port": 6379},
- {"host": "192.168.5.112", "port": 6379},
- {"host": "192.168.5.113", "port": 6379},
- {"host": "192.168.5.114", "port": 6379},
- {"host": "192.168.5.115", "port": 6379},
- {"host": "192.168.5.116", "port": 6379}]
- rc = StrictRedisCluster(startup_nodes=startup_nodes, decode_responses=True)
- xx = rc.info('th:jsevent*')
- x = rc.hgetall('t00')
- y = rc.hgetall('th')
- z = rc.hgetall('th0')
- # -------------python 访问 zk, 并设置或更新 zk 中字典 -----------------------
- from kazoo.client import KazooClient
- import JSON
- import requests
- def login():
- # 登录获取 jwt
- url1 = 'http://192.168.16.511:8100/sys/loginon'
- payload1 = {'username': 'admin',
- 'password': '123456',
- 'validcode': '123548'}
- r = requests.post(url1, data=payload1).cookies
- # print(r['jwt'])
- # 链接 zk 查看 DebugSession
- zk = KazooClient(hosts='192.168.1.1:2181') # 如果是本地那就写 127.0.0.1
- zk.start() # 与 zookeeper 连接
- # node = zk.get_children('/wapn/test/')
- data = {"RecvURL": "...?activityId=%d&destoken=%s",
- "PacketPoolInsert": "...",
- "FileUrl": "file",
- "DomainUrl": "",
- "ImageManaUrl": "he/",
- "ResetLandUrl": "ssion",
- "SSOPath": "sps",
- "IsDebug": bool('true'),
- "DebugSession": "",
- "FileUploadPath": "/ho/files/"}
- print('zk')
- data['DebugSession'] = r['jwt']
- zk.set('/czhhadmin/var', bytes(str(JSON.dumps(data, indent=2)), encoding='utf-8'))
- print(JSON.dumps(data, indent=2))
- login()
来源: http://www.bubuko.com/infodetail-3004975.html