本文整理汇总了Python中utils.utils函数的典型用法代码示例。如果您正苦于以下问题:Python utils函数的具体用法?Python utils怎么用?Python utils使用的例子?那么恭喜您, 这里精选的函数代码示例或许可以为您提供帮助。
在下文中一共展示了utils函数的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: install
def install(self, env):
Logger.info("install ResourceMonitor")
excludePackage = ['haproxy-ng', 'hadoop-ng', 'portal_api_server', 'docker-ng']
self.install_packages(env,excludePackage)
Logger.info("grant node privilege")
utils().grant_local_privilege(env)
开发者ID:chinpeng,项目名称:ambari,代码行数:7,代码来源:resourcemonitor.py
示例2: stop
def stop(self, env):
import params
env.set_params(params)
Logger.info("stop Agent")
utils().exe(params.agent_stop)
time.sleep(5)
开发者ID:chinpeng,项目名称:ambari,代码行数:7,代码来源:agent.py
示例3: start
def start(self, env):
Logger.info("start the pg")
import params
env.set_params(params)
self.configure(env)
utils().exe(params.pg_start)
开发者ID:chinpeng,项目名称:ambari,代码行数:7,代码来源:pg_server.py
示例4: install
def install(self, env):
Logger.info("install Pg")
excludePackage = ['pgxzm-center']
self.install_packages(env,excludePackage)
# create dba user for pg
# configinit().create_pg_dba(env)
# get a best avilable dir for pg data
# configinit().get_avilable_dir(env)
import params
Logger.info("create user and passwd")
Logger.info(params.pgxx_passwd)
Logger.info("create install dir")
Logger.info(params.pgxx_install_path)
utils().exe(params.create_install_dir)
utils().exe(params.chown_install_dir)
Logger.info("create log dir")
Logger.info(params.pgxx_log_path)
utils().exe(params.create_log_dir)
utils().exe(params.chown_log_dir)
Logger.info("process initdb")
utils().exe(params.pg_init_db)
Logger.info("update configure parameters")
self.configure(env)
self.start(env)
self.createdbsuperuser(env)
开发者ID:chinpeng,项目名称:ambari,代码行数:32,代码来源:pg_server.py
示例5: stop
def stop(self, env):
import params
env.set_params(params)
Logger.info("stop Center")
utils().exe(params.center_stop)
开发者ID:fanzhidongyzby,项目名称:ambari,代码行数:7,代码来源:center.py
示例6: start
def start(self, env):
import params
env.set_params(params)
self.configure(env)
Logger.info("start Haproxy on NodeManager")
utils().exe(params.nmhaproxy_start)
开发者ID:chinpeng,项目名称:ambari,代码行数:8,代码来源:nmhaproxy.py
示例7: stop
def stop(self, env, rolling_restart=False):
import params
import status_params
env.set_params(params)
cmd = "su {0} -c '{1}/stop-nimbus.sh'".format(params.storm_user, params.bin_dir)
Logger.info("stop nimbus")
utils().exe(cmd)
utils().check_stop(status_params.proc_nimbus_name)
开发者ID:chinpeng,项目名称:ambari,代码行数:8,代码来源:nimbus.py
示例8: start
def start(self, env):
import params
env.set_params(params)
self.configure(env)
Logger.info("start JobHistory")
utils().exe(params.jobhistory_start)
开发者ID:chinpeng,项目名称:ambari,代码行数:8,代码来源:jobhistory.py
示例9: stop
def stop(self, env):
import os
import params
Logger.info("stop mysql")
cmd = "sudo service mysqld stop"
utils().exe(cmd)
开发者ID:fanzhidongyzby,项目名称:ambari,代码行数:8,代码来源:mysql_server.py
示例10: start
def start(self, env):
import params
env.set_params(params)
self.configure(env)
Logger.info("start Docker")
utils().exe(params.docker_start)
开发者ID:chinpeng,项目名称:ambari,代码行数:8,代码来源:docker.py
示例11: start
def start(self, env):
import params
env.set_params(params)
self.configure(env)
Logger.info("start Cgi")
utils().exe(params.cgi_start)
开发者ID:chinpeng,项目名称:ambari,代码行数:8,代码来源:cgi.py
示例12: start
def start(self, env):
import params
env.set_params(params)
self.configure(env)
Logger.info("start ResourceManager")
utils().exe(params.rm_start)
开发者ID:chinpeng,项目名称:ambari,代码行数:8,代码来源:resourcemanager.py
示例13: install
def install(self, env):
import params
Logger.info("check local host")
utils().check_local_environment(env,params.master)
Logger.info("install hadoop")
excludePackage = ['docker-ng','haproxy-ng','resource_monitor','portal_api_server']
self.install_packages(env,excludePackage)
开发者ID:chinpeng,项目名称:ambari,代码行数:8,代码来源:resourcemanager.py
示例14: start
def start(self, env):
import params
env.set_params(params)
self.configure(env)
Logger.info("start Haproxy on ResourceManager")
utils().exe(params.rmhaproxy_start_command)
开发者ID:fanzhidongyzby,项目名称:ambari,代码行数:8,代码来源:rmhaproxy.py
示例15: start
def start(self, env):
import os
import params
env.set_params(params)
self.configure(env)
Logger.info("start hwi")
utils().exe(params.hwi_start_command)
开发者ID:fanzhidongyzby,项目名称:ambari,代码行数:8,代码来源:hwi.py
示例16: start
def start(self, env):
import params
env.set_params(params)
cmd = params.etcd_start_cmd
cmd = cmd + " -initial-cluster-state existing >>/gaia/etcd/backup/etcd.log 2>&1 &"
cmd = "su gaia -c '{}'".format(cmd)
Logger.info("start etcd")
utils().exe(cmd)
开发者ID:fanzhidongyzby,项目名称:ambari,代码行数:9,代码来源:etcd.py
示例17: start
def start(self, env):
import params
Logger.info("create gtm config")
self.configure(env)
Logger.info("start gtm")
#su pgxz -c '/usr/local/pgxz/bin/gtm_ctl -Z gtm -D /usr/local/pgxz/nodes/gtm start'
utils().exe(params.gtm_start)
utils().check_start(params.gtm_pid)
开发者ID:chinpeng,项目名称:ambari,代码行数:9,代码来源:gtm.py
示例18: start
def start(self, env):
import params
Logger.info("create datanode config")
self.configure(env)
Logger.info("start datanode")
#su pgxz -c '/usr/local/pgxz/bin/pg_ctl start -D /usr/local/pgxz/nodes/datanode -Z datanode'
utils().exe(params.datanode_start)
utils().check_start(params.datanode_pid)
开发者ID:fanzhidongyzby,项目名称:ambari,代码行数:9,代码来源:datanode.py
示例19: install
def install(self, env):
import params
self.install_packages(env)
Logger.info("init datanode")
#su pgxz -c '/usr/local/pgxz/bin/initdb -D /usr/local/pgxz/nodes/datanode --nodename datanode'
utils().exe(params.datanode_install)
utils().check_install(params.datanode_path)
Links(params.new_pgxz_install_path, params.pgxz_install_path)
Links(params.new_pgxz_conf_path_datanode, params.pgxz_conf_path_datanode)
Links(params.new_pgxz_data_path_datanode, params.pgxz_data_path_datanode)
开发者ID:fanzhidongyzby,项目名称:ambari,代码行数:11,代码来源:datanode.py
示例20: install
def install(self, env):
import params
self.install_packages(env)
Logger.info("init gtm")
#su pgxz -c '/usr/local/pgxz/bin/initgtm -Z gtm -D /usr/local/pgxz/nodes/gtm'
utils().exe(params.gtm_install)
utils().check_install(params.gtm_path)
Links(params.new_pgxz_install_path, params.pgxz_install_path)
Links(params.new_pgxz_conf_path_gtm, params.pgxz_conf_path_gtm)
Links(params.new_pgxz_data_path_gtm, params.pgxz_data_path_gtm)
开发者ID:chinpeng,项目名称:ambari,代码行数:11,代码来源:gtm.py
注:本文中的utils.utils函数示例由纯净天空整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论