/
swift.py
70 lines (56 loc) · 1.84 KB
/
swift.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
from fabric.api import *
@task
def swift_all_start():
with settings(parallel=True):
run("swift-init all start")
@task
def swift_all_stop():
with settings(parallel=True, warn_only=True):
run("swift-init all stop")
@task
def swift_all_restart():
run("swift-init all restart")
@task
@roles('swift_proxy')
def swift_proxy_start():
run("swift-init proxy start")
@task
@roles('swift_proxy')
def swift_proxy_stop():
run("swift-init proxy stop")
def swift_rest_start():
run("swift-init rest start")
def swift_rest_stop():
run("swift-init rest stop")
def swift_proxy_restart():
run("swift-init proxy restart")
def swift_rest_restart():
run("swift-init rest restart")
@roles('swift_proxy')
def copy_ring_files():
for node in env.roledefs['swift_nodes_public']:
run('scp /etc/swift/*.ring.gz root@{0}:/etc/swift'.format(node))
@roles('swift_proxy')
def _add_nodes_to_ring():
with cd('/etc/swift'):
for node in env.roledefs['swift_nodes_private']:
run('swift-ring-builder account.builder add z1-{0}:6002/sdb1 2000'.format(node))
run('swift-ring-builder container.builder add z1-{0}:6001/sdb1 2000'.format(node))
run('swift-ring-builder object.builder add z1-{0}:6000/sdb1 2000'.format(node))
@roles('swift_proxy')
def ring_rebalance():
with cd('/etc/swift'):
run('swift-ring-builder account.builder rebalance')
run('swift-ring-builder container.builder rebalance')
run('swift-ring-builder object.builder rebalance')
@task
def add_nodes_to_ring():
_add_nodes_to_ring()
ring_rebalance()
copy_ring_files()
def delete_data():
with settings(parallel=True):
run("umount /srv/node/sdb1")
run("mkfs.xfs -i size=1024 -f /dev/sdb1")
run("mount /srv/node/sdb1")
run("chown -R swift:swift /srv/node/sdb1")