(zk_client, node_path)
| 22 | print "updated zk node[{node_path}]".format(node_path=node_path) |
| 23 | |
| 24 | def node_get(zk_client, node_path): |
| 25 | theValue = None |
| 26 | if zk_client.exists(node_path): |
| 27 | theValue = zk_client.get(node_path) |
| 28 | theValue = theValue[0] |
| 29 | return theValue.strip() if theValue != None else theValue |
| 30 |