本文整理汇总了Python中zookeeper.conf.CLUSTERS类的典型用法代码示例。如果您正苦于以下问题：Python CLUSTERS类的具体用法？Python CLUSTERS怎么用？Python CLUSTERS使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
在下文中一共展示了CLUSTERS类的13个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Python代码示例。
示例1: test_get_global_overview
def test_get_global_overview(self):
"""Beware: this test is not testing, need to better mock the config."""
finish = CLUSTERS.set_for_testing({'default': {'localhost:2181': {}}})
try:
_get_global_overview()
finally:
finish()
finish = CLUSTERS.set_for_testing({'default': {'localhost:2181,localhost:2182': {}}})
try:
_get_global_overview()
finally:
finish()
开发者ID:10sr，项目名称:hue，代码行数:15，代码来源:tests.py
示例2: zkensemble
def zkensemble():
"""
Try to guess the value if no values are specified.
"""
from django.conf import settings
if 'zookeeper' in settings.INSTALLED_APPS:
try:
# Backward compatibility until Hue 4
from zookeeper.conf import CLUSTERS
clusters = CLUSTERS.get()
if clusters['default'].HOST_PORTS.get() != 'localhost:2181':
return '%s' % clusters['default'].HOST_PORTS.get()
except:
LOG.warn('Could not get zookeeper ensemble from the zookeeper app')
if 'search' in settings.INSTALLED_APPS:
try:
from search.conf import SOLR_URL
parsed = urlparse(SOLR_URL.get())
return "%s:2181" % (parsed.hostname or 'localhost')
except:
LOG.warn('Could not get zookeeper ensemble from the search app')
return "localhost:2181"
开发者ID:orenmazor，项目名称:hue，代码行数:26，代码来源:conf.py
示例3: view
def view(request, id):
cluster = get_cluster_or_404(id)
stats = _get_overview(cluster['host_ports'])
leader, followers = _group_stats_by_role(stats)
return render('view.mako', request, {
'cluster': cluster, 'all_stats': stats, 'leader': leader, 'followers': followers,
'clusters': CLUSTERS.get(),
})
开发者ID:Web5design，项目名称:hue，代码行数:10，代码来源:views.py
示例4: get_cluster_or_404
def get_cluster_or_404(id):
try:
name = id
cluster = CLUSTERS.get()[name]
except (TypeError, ValueError):
raise Http404()
cluster = {
'id': id,
'nice_name': id,
'host_ports': cluster.HOST_PORTS.get(),
'rest_url': cluster.REST_URL.get(),
}
return cluster
开发者ID:10sr，项目名称:hue，代码行数:15，代码来源:utils.py
示例5: zkensemble
def zkensemble():
"""
ZooKeeper Ensemble
"""
try:
from zookeeper.conf import CLUSTERS
clusters = CLUSTERS.get()
if clusters['default'].HOST_PORTS.get() != 'localhost:2181':
return '%s/solr' % clusters['default'].HOST_PORTS.get()
except:
pass
from search.conf import SOLR_URL
parsed = urlparse(SOLR_URL.get())
return "%s:2181/solr" % (parsed.hostname or 'localhost')
开发者ID:9629831527，项目名称:hue，代码行数:15，代码来源:conf.py
示例6: clients
def clients(request, id, host):
cluster = get_cluster_or_404(id)
parts = host.split(':')
if len(parts) != 2:
raise Http404
host, port = parts
zks = stats.ZooKeeperStats(host, port)
clients = zks.get_clients()
return render('clients.mako', request, {
'clusters': CLUSTERS.get(),
'cluster': cluster,
'host': host,
'port': port,
'clients': clients
})
开发者ID:Web5design，项目名称:hue，代码行数:18，代码来源:views.py
示例7: zkensemble
def zkensemble():
"""
Try to guess the value if no values are specified.
"""
try:
# Backward compatibility until Hue 4
from zookeeper.conf import CLUSTERS
clusters = CLUSTERS.get()
if clusters['default'].HOST_PORTS.get() != 'localhost:2181':
return '%s/solr' % clusters['default'].HOST_PORTS.get()
except:
LOG.exception('failed to get zookeeper ensemble')
try:
from search.conf import SOLR_URL
parsed = urlparse(SOLR_URL.get())
return "%s:2181/solr" % (parsed.hostname or 'localhost')
except:
LOG.exception('failed to get solr url')
return "localhost:2181"
开发者ID:cyc821211，项目名称:hue，代码行数:21，代码来源:conf.py
示例8: _get_global_overview
def _get_global_overview():
clusters = CLUSTERS.get()
return dict([(c, _get_overview(clusters[c].HOST_PORTS.get())) for c in clusters])
开发者ID:Web5design，项目名称:hue，代码行数:3，代码来源:views.py
示例9: edit_as_text
def edit_as_text(request, id, path):
cluster = get_cluster_or_404(id)
zk = ZooKeeper(cluster['rest_url'])
node = zk.get(path)
if request.method == 'POST':
form = EditZNodeForm(request.POST)
if form.is_valid():
zk.set(path, form.cleaned_data['data'])
return tree(request, id, path)
else:
form = EditZNodeForm(dict(data=node.get('data64', '').decode('base64').strip(), version=node.get('version', '-1')))
return render('edit.mako', request, {'cluster': cluster, 'path': path, 'form': form, 'clusters': CLUSTERS.get(),})
开发者ID:Web5design，项目名称:hue，代码行数:15，代码来源:views.py
示例10: create
def create(request, id, path):
cluster = get_cluster_or_404(id)
if request.method == 'POST':
form = CreateZNodeForm(request.POST)
if form.is_valid():
zk = ZooKeeper(cluster['rest_url'])
full_path = ("%s/%s" % (path, form.cleaned_data['name'])).replace('//', '/')
zk.create(full_path, form.cleaned_data['data'], sequence = form.cleaned_data['sequence'])
return tree(request, id, path)
else:
form = CreateZNodeForm()
return render('create.mako', request, {'cluster': cluster, 'path': path, 'form': form, 'clusters': CLUSTERS.get(),})
开发者ID:Web5design，项目名称:hue，代码行数:16，代码来源:views.py
示例11: tree
def tree(request, id, path):
cluster = get_cluster_or_404(id)
zk = ZooKeeper(cluster['rest_url'])
znode = zk.get(path)
children = sorted(zk.get_children_paths(path))
return render('tree.mako', request, {'cluster': cluster, 'path': path, 'znode': znode, 'children': children, 'clusters': CLUSTERS.get(),})
开发者ID:Web5design，项目名称:hue，代码行数:8，代码来源:views.py
示例12: index
leader = stats
elif stats.get('zk_server_state') == 'follower':
followers.append(stats)
return leader, followers
def index(request):
try:
overview = _get_global_overview()
except Exception, e:
raise PopupException(_('Could not correctly connect to Zookeeper.'), detail=e)
return render('index.mako', request, {
'clusters': CLUSTERS.get(),
'overview': overview
})
def view(request, id):
cluster = get_cluster_or_404(id)
stats = _get_overview(cluster['host_ports'])
leader, followers = _group_stats_by_role(stats)
return render('view.mako', request, {
'cluster': cluster, 'all_stats': stats, 'leader': leader, 'followers': followers,
'clusters': CLUSTERS.get(),
})
开发者ID:Web5design，项目名称:hue，代码行数:30，代码来源:views.py
示例13: edit_as_base64
def edit_as_base64(request, id, path):
cluster = get_cluster_or_404(id)
zk = ZooKeeper(cluster['rest_url'])
node = zk.get(path)
if request.method == 'POST':
if not request.user.is_superuser:
raise PopupException(_('You are not a superuser'))
form = EditZNodeForm(request.POST)
if form.is_valid():
# TODO is valid base64 string?
data = form.cleaned_data['data'].decode('base64')
zk.set(path, data, form.cleaned_data['version'])
return tree(request, id, path)
else:
form = EditZNodeForm(dict(\
data=node.get('data64', ''),
version=node.get('version', '-1')))
return render('edit.mako', request, {'cluster': cluster, 'path': path, 'form': form, 'clusters': CLUSTERS.get(),})
开发者ID:15580056814，项目名称:hue，代码行数:21，代码来源:views.py
注：本文中的zookeeper.conf.CLUSTERS类示例由纯净天空整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论