Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Commit1454a5d

Browse files
committed
script to run transfers in parallel
1 parent3e444eb commit1454a5d

File tree

1 file changed

+18
-63
lines changed

1 file changed

+18
-63
lines changed

‎contrib/pg_dtm/tests/transfers.yml‎

Lines changed: 18 additions & 63 deletions
Original file line numberDiff line numberDiff line change
@@ -1,81 +1,36 @@
11
---
22

3-
# - hosts: 158.250.29.4
4-
# gather_facts: no
5-
# tasks:
6-
# # # - shell: echo "host={{item}} user=s.kelvich port=15432 dbname=postgres"
7-
# # register: source
8-
# # with_items: groups['workers']
9-
10-
# # - debug: var=source
11-
12-
# - set_fact:
13-
# connstr: "{{ groups['workers'] | ~'=' }}"
14-
15-
# - debug: var=connstr
16-
17-
# - name: copy transfers binary
18-
# copy: src=transfers.linux dest=~/transfers mode=a+x
19-
20-
# - hosts: blade3
21-
# gather_facts: no
22-
# tasks:
23-
# - name: setup the databases
24-
# shell: "./transfers -d 'host=158.250.29.10 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.9 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.8 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.6 user=s.kelvich port=15432 dbname=postgres' -f -g -m -w 140 -r 0"
25-
# register: transfers_result
26-
# - debug: var=transfers_result
27-
28-
# - hosts: blade3
29-
# gather_facts: no
30-
# tasks:
31-
# - name: run transfers
32-
# shell: "./transfers -d 'host=158.250.29.10 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.9 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.8 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.6 user=s.kelvich port=15432 dbname=postgres' -s -g -m -w 140 -u 14000 -r 0"
33-
# register: transfers_result
34-
# - debug: var=transfers_result
35-
3+
-hosts:clients
4+
gather_facts:no
5+
tasks:
366

37-
# - hosts: blade3
38-
# gather_facts: no
39-
# tasks:
40-
# - name: setup the databases
41-
# shell: "./transfers -d 'host=blade8 user=stas port=15432 dbname=postgres' -d 'host=blade7 user=stas port=15432 dbname=postgres' -d 'host=blade6 user=stas port=15432 dbname=postgres' -d 'host=blade5 user=stas port=15432 dbname=postgres' -d 'host=blade4 user=stas port=15432 dbname=postgres' -f -g -w 200 -r 0"
42-
# register: transfers_result
43-
# - debug: var=transfers_result
7+
-name:generate connstrings
8+
set_fact:
9+
connstr:"-d 'host={{item}} user=cluster port=15432 dbname=postgres'"
10+
with_items:
11+
groups['nodes'] | reverse | batch(nnodes | d(2) | int) | first
12+
register:connstrs
4413

45-
# - hosts: blade3
46-
# gather_facts: no
47-
# tasks:
48-
# - name: run transfers
49-
# shell: "./transfers -d 'host=blade8 user=stas port=15432 dbname=postgres' -d 'host=blade7 user=stas port=15432 dbname=postgres' -d 'host=blade6 user=stas port=15432 dbname=postgres' -d 'host=blade5 user=stas port=15432 dbname=postgres' -d 'host=blade4 user=stas port=15432 dbname=postgres' -s -g -w 200 -u 2500 -r 0"
50-
# register: transfers_result
51-
# - debug: var=transfers_result
14+
-name:make a list
15+
set_fact:
16+
connections:"{{ connstrs.results | map(attribute='ansible_facts.connstr') | join }}"
5217

18+
-name:copy transfers binary
19+
copy:src=transfers.linux dest=~/transfers mode=a+x
5320

54-
-hosts:158.250.29.4
21+
-hosts:clients[0]
5522
gather_facts:no
5623
tasks:
57-
-name:setup the databases
58-
shell:"./transfers-d 'host=158.250.29.10 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.8 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.9 user=s.kelvich port=15432 dbname=postgres' -f -g -m -w 105 -r 0"
24+
-name:fill the databases
25+
shell:"./transfers{{connections}} -f -g"
5926
register:transfers_result
6027
-debug:var=transfers_result
6128

6229
-hosts:clients
6330
gather_facts:no
6431
tasks:
6532
-name:run transfers
66-
shell:"./transfers-d 'host=158.250.29.10 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.8 user=s.kelvich port=15432 dbname=postgres' -d 'host=158.250.29.9 user=s.kelvich port=15432 dbname=postgres' -s -g -m -w 105 -u 4000 -r 0"
33+
shell:"./transfers{{connections}} -s {{runkeys | d('-g -w 90 -o -u 10000 -r 0')}} -k {{hostvars[inventory_hostname]['offset']}}"
6734
register:transfers_result
6835
-debug:var=transfers_result
6936

70-
71-
72-
73-
74-
75-
76-
77-
78-
79-
80-
81-

0 commit comments

Comments
 (0)

[8]ページ先頭

©2009-2025 Movatter.jp