cassandra.py 文件源码

def nodetool(config_file, cmd):
    """Send commands to Cassandra nodetool | args: config file, nodetool command """
    cfg = helper.get_config(config_file)
    host_config = get_cassandra_host_cfg(cfg)

    env.host_string = helper.get_env_host_string(host_config)
    env.user = helper.get_env_user(host_config)
    env.key_filename = helper.get_env_key_filename(host_config)

    sudo("nodetool {}".format(cmd))