码迷,mamicode.com
首页 > 其他好文 > 详细

Day3-HAproxy

时间:2016-08-29 12:32:55      阅读:140      评论:0      收藏:0      [点我收藏+]

标签:

HAproxy配置文件操作
1. 根据用户输入输出对应的backend下的server信息
2. 可添加backend 和sever信息
3. 可修改backend 和sever信息
4. 可删除backend 和sever信息
5. 操作配置文件前进行备份
6 添加server信息时,如果ip已经存在则修改;如果backend不存在则创建;若信息与已有信息重复则不操作

 

技术分享
  1 import json
  2 import os
  3 
  4 
  5 def show_all_backend(filename):
  6     try:
  7         l_backend = []
  8         with open(filename, r, encoding=utf-8) as f:
  9             lines = f.readlines()
 10             for line in lines:
 11                 if line.strip().startswith(backend):
 12                     l_backend.append(line)
 13         if l_backend:
 14             for i,j in enumerate(l_backend):
 15                 print (\t%s % (i + 1), j)
 16             return True
 17 
 18         else:
 19             print(No actived backends!)
 20             return False
 21     except EOFError as msg:
 22         print(msg)
 23 
 24 
 25 def show_server_info_under_backend(url):
 26     l_backend = []
 27     f = open(HAproxy, r, encoding=utf-8)
 28     lines = f.readlines()
 29     for i in range(len(lines)):
 30         if lines[i].strip().startswith(backend):
 31             item = lines[i].strip().strip(\n)
 32             new_item = item.strip(backend )
 33             #print (new_item)
 34             l_backend.append(new_item)
 35     #print (l_backend)
 36     if url in l_backend:
 37         for i in range(len(lines)):
 38             if lines[i].strip().startswith(backend %s%url):
 39                 j = lines.index(lines[i])
 40                 #print (lines[j])
 41         i = j+1
 42         l_base = []
 43         if url == l_backend[-1]:
 44             p = lines.index(backend %s\n%l_backend[-1])
 45             for item in lines[p+1:]:
 46                 l_base.append(item.strip().strip(\n))
 47         else:
 48             while True:
 49                 if lines[i].strip().startswith(server):
 50                     l_base.append(lines[i].strip().strip(\n))
 51                     i +=1
 52                     if (lines[i].strip().startswith(backend)):
 53                         break
 54 
 55         for i, j in enumerate(l_base):
 56             print(\t%s % (i + 1), j)
 57         return True
 58     else:
 59         return False
 60 
 61 def is_backend_exists(url):
 62     try:
 63         lbackend = []
 64         f = open(HAproxy, r, encoding=utf-8)
 65         lines = f.readlines()
 66         for i in range(len(lines)):
 67             if lines[i].startswith("backend"):
 68                 lbackend.append(lines[i][len("backend "):].strip(\n))
 69         f.close()
 70 
 71         if url in lbackend:
 72             #print("backend %s exists!Please added server info directly"%url)
 73             return True
 74         else:
 75             return False
 76 
 77     except EOFError as msg:
 78         print(msg)
 79 
 80     finally:
 81         f.close()
 82 
 83 def add_backend(url):
 84     try:
 85         f = open(HAproxy, a+, encoding=utf-8)
 86         if not is_backend_exists(url):
 87             f.writelines("\n\rbackend %s" % url)
 88             print("Add backend %s successfully" % url)
 89         else:
 90             print("Fail to add backend %s since it already exists" % url)
 91 
 92     except EOFError as msg:
 93         print(msg)
 94 
 95     finally:
 96         f.close()
 97 
 98 
 99 def del_backend(url):
100     try:
101         if is_backend_exists(url):
102             f = open(HAproxy, r+, encoding=utf-8)
103             lines = f.readlines()
104             f.close()
105 
106             if url in lines[-1].strip():
107                 lines[-1]=""
108             else:
109                 for i in range(len(lines)):
110                     if lines[i].startswith(backend) and (url in lines[i]):
111                         lines[i] = ""
112                         j = i + 1
113                         while True:
114                             if lines[-1].strip().startswith(server):
115                                 break
116                             elif lines[j].strip().startswith(server):
117                                 lines[j] = ""
118                                 j += 1
119                             else:
120                                 break
121             f = open(HAproxy, w+, encoding=utf-8)
122             f.writelines(lines)
123             f.close()
124             print(Delete backend %s sucessfully!%url)
125             return True
126         else:
127             print(Delete Failed - No such backend sever exits)
128             return False
129 
130     except EOFError as msg:
131          print(msg)
132 
133 
134 def show_all_active_server_info(filename):
135     try:
136         l_server = []
137         with open(filename, r, encoding=utf-8) as f:
138             lines = f.readlines()
139             for line in lines:
140                 if line.strip().startswith(server):
141                     l_server.append(line)
142         if l_server:
143             str = "The active server info as below:"
144             print(str.center(60,*))
145             for i, j in enumerate(l_server):
146                 print(\t%s % (i + 1), j)
147             return True
148 
149         else:
150             print(No actived servers!)
151             return False
152     except EOFError as msg:
153         print(msg)
154 
155 def add_server_info_under_backend(str):
156     # Tranfer inside str to dict
157     try:
158         dict = json.loads(str)
159         # print (dict)
160         item = "server {server} weight {weight} maxconn {maxconn}".format(**dict[record])
161         #print(type(item))
162         i = 0
163         if is_backend_exists(dict[backend]):
164             f = open(HAproxy, r+, encoding=utf-8)
165             lines = f.readlines()
166             f.close()
167             #print (lines)
168             l_backend = []
169             for line in lines:
170                 if dict[backend] in line.strip(\n):
171                     index = lines.index(line)
172                     i = index
173                     # print(lines[i])
174                     break
175 
176             for line in lines:
177                 if line.strip().startswith(backend):
178                     l_backend.append(line)
179 
180             if dict[backend] in l_backend[-1]:
181                 l_set = []
182                 for line in lines[i:]:
183                     l_set.append(line.strip().strip(\n))
184                 # print(l_set)
185                 # print(item)
186                 if item in l_set:
187                     return False
188 
189                 else:
190                     with open(HAproxy, r, encoding=utf-8) as f1:
191                         lines = f1.readlines()
192                     l_ip = []
193                     #print(dict[‘record‘][‘server‘])
194                     for n in range(len(lines)):
195                         if lines[n].startswith(\t\tserver %s  % dict[record][server]):
196                             l_ip.append(lines[n])
197                     if l_ip:
198                         dict = json.loads(str)
199                         item2 = "server {server} weight {weight} maxconn {maxconn}".format(**dict[record])
200                         with open(HAproxy, r+, encoding=utf-8) as f2:
201                             new_lines = f2.readlines()
202                             p = 0
203                             for line in new_lines:
204                                 if \t\tserver %s  % dict[record][server] in line:
205                                     p = new_lines.index(line)
206 
207                             new_lines[p] = \t\t%s\n % item2
208                         with open(HAproxy, w+, encoding=utf-8) as f3:
209                             f3.writelines(new_lines)
210                             print(Update server info successfully!)
211                             return True
212 
213                     else:
214                         f = open(HAproxy, a+, encoding=utf-8)
215                         line = "\n\t\tserver {server} weight {weight} maxconn {maxconn}".format(**dict[record])
216                         f.writelines(line)
217                         f.close()
218             else:
219                 j=i+1
220                 l_server = []
221                 while True:
222                     if lines[j].strip().startswith(server):
223                         l_server.append(lines[j].strip().strip(\n))
224                         j +=1
225                         if lines[j].strip().startswith(backend):
226                             break
227                 if item in l_server:
228                     return False
229                 else:
230                     with open(HAproxy, r, encoding=utf-8) as f1:
231                         lines = f1.readlines()
232                     l_ip = []
233                     #print(dict[‘record‘][‘server‘])
234                     for n in range(len(lines)):
235                         if lines[n].startswith(\t\tserver %s %dict[record][server]):
236                             l_ip.append(lines[n])
237                     if l_ip:
238                         dict = json.loads(str)
239                         item2 = "server {server} weight {weight} maxconn {maxconn}".format(**dict[record])
240                         with open(HAproxy, r+, encoding=utf-8) as f2:
241                             new_lines = f2.readlines()
242                             p = 0
243                             for line in new_lines:
244                                 if \t\tserver %s %dict[record][server] in line:
245                                     p = new_lines.index(line)
246 
247                             new_lines[p] = \t\t%s\n%item2
248                         with open(HAproxy, w+, encoding=utf-8) as f3:
249                             f3.writelines(new_lines)
250                             print(hello?)
251                             return True
252 
253                     else:
254                         lines.insert(j,"\t\tserver {server} weight {weight} maxconn {maxconn}\n".format(**dict[record]))
255                         f = open(HAproxy, w+, encoding=utf-8)
256                         f.writelines(lines)
257                         f.close()
258                     return True
259 
260         else:
261             add_backend(dict[backend])
262             print(dict[record])
263             f = open(HAproxy, a+, encoding=utf-8)
264             line = "\n\t\tserver {server} weight {weight} maxconn {maxconn}".format(**dict[record])
265             f.writelines(line)
266             f.close()
267 
268     except EOFError as msg:
269         print(msg)
270 
271 def del_server_info_under_backend(str):
272     try:
273         f = open(HAproxy, r+, encoding=utf-8)
274         lines = f.readlines()
275         l_backend = []
276         for line in lines:
277             if line.strip().startswith(backend):
278                 l_backend.append(line.strip())
279         f.close()
280 
281         for i in range(len(lines)):
282             if str in lines[i].strip():
283                 print(Delete server info: %s % str)
284                 p = lines.index(lines[i])
285                 if (lines[p-1].strip().startswith(backend)) and (lines[p].strip() in lines[-1]):
286                     lines.remove(lines[p])
287                     # print(‘No actived server under %s, remove backend‘%lines[p-1].strip().strip(‘\n‘))
288                     lines.remove(lines[p - 1])
289                     break
290                 elif (lines[p-1].strip().startswith(backend))and (lines[p+1].strip().startswith(backend)):
291                     lines.remove(lines[p])
292                     # print(‘No actived server under %s, remove backend!‘%lines[p - 1].strip().strip(‘\n‘))
293                     lines.remove(lines[p - 1])
294                     break
295                 else:
296                     lines.remove(lines[p])
297                     break
298         f = open(HAproxy, w+, encoding=utf-8)
299         f.writelines(lines)
300         return True
301 
302     except EOFError as msg:
303         print(msg)
304 
305 
306 def backup_server_file(original_file,new_file):
307     try:
308         with open(original_file,r,encoding=utf-8) as f1, open(new_file,w,encoding=utf-8) as f2:
309             lines = f1.readlines()
310             for line in lines:
311                 f2.writelines(line)
312         str = Backing up is Done!
313         print(str.center(40,*))
314     except EOFError as msg:
315         print(msg)
316 
317 
318 if __name__ == "__main__":
319     counter = 0
320     bValue = True
321     while True:
322         counter +=1
323         if counter == 3:
324             print(You`ve entered invalid info for 3 times, system quit!)
325             exit()
326 
327         else:
328 
329             row_input = input("Do you want to operate server file?(y/n) ")
330             if row_input in [n,N,q,Q]:
331                 print(Quit)
332                 exit()
333             elif row_input in [y,Y]:
334                 bValue = True
335                 while True:
336                     print(Backing up your server file as HAproxy_bak on your server..)
337                     backup_server_file(HAproxy, HAproxy_bak)
338                     # row_input = input("1.Show all backend  | 2.Add new backend | 3.Delete backend ")
339                     if bool(show_all_backend(HAproxy)) == True:
340                         while True:
341                             str = The active backends as below:
342                             print(str.center(60,*))
343                             show_all_backend(HAproxy)
344                             row_input = input(1.Add backend server info | 2.Delete backend | 3 View server info under backend | 4 Show all actived server info  )
345                             if row_input in [q,Q]:
346                                 print(Quit)
347                                 exit()
348                             elif row_input == "1":
349                             #     row_input = input(‘Enter the backend url you want to add here -> : ‘)
350                             #     if row_input in [‘q‘, ‘Q‘]:
351                             #         print(‘Quit‘)
352                             #     else:
353                             #         add_backend(row_input)
354                             #         continue
355                                 print(You should add sever info like {"backend": "test.oldboy.org","record":{"server": "100.1.7.9","weight": 20,"maxconn": 30}})
356                                 row_input = input(Enter your new server info here->: )
357                                 if row_input in [q, Q]:
358                                     print(Quit)
359                                     exit()
360                                 else:
361                                     backup_server_file(HAproxy, HAproxy_bak)
362                                     add_server_info_under_backend(row_input)
363                                     continue
364 
365                             elif row_input == "2":
366                                 row_input = input(Enter the backend url you want to delete here -> : )
367                                 if row_input in [q, Q]:
368                                     print(Quit)
369                                     exit()
370                                 else:
371                                     backup_server_file(HAproxy, HAproxy_bak)
372                                     del_backend(row_input)
373                                     continue
374 
375                             elif row_input == "3":
376                                 row_input = input(Enter the backend url under which you want to check server info here-> : )
377                                 if row_input in [q, Q]:
378                                     print(Quit)
379                                 else:
380                                     backup_server_file(HAproxy, HAproxy_bak)
381                                     while True:
382                                         if bool(show_server_info_under_backend(row_input)):
383                                             row_input = input(1.Add or Update sever info | 2. Delete server info | 3. Return to the previous menu)
384                                             if row_input in [q, Q]:
385                                                 print(Quit)
386                                                 exit()
387                                             elif row_input == 1:
388                                                 print(You should add sever info like {"backend": "test.oldboy.org","record":{"server": "100.1.7.9","weight": 20,"maxconn": 30}})
389                                                 row_input = input(Enter your new server info here->: )
390                                                 if row_input in [q, Q]:
391                                                     print(Quit)
392                                                     exit()
393                                                 else:
394                                                     backup_server_file(HAproxy, HAproxy_bak)
395                                                     add_server_info_under_backend(row_input)
396                                                     continue
397                                             # elif row_input == ‘2‘:
398                                             #     pass
399 
400                                             elif row_input == 2:
401 
402                                                 if row_input in [q, Q]:
403                                                     print(Quit)
404                                                     exit()
405                                                 else:
406 
407                                                     if row_input in [q, Q]:
408                                                         print(Quit)
409                                                         exit()
410 
411                                                     else:
412                                                         backup_server_file(HAproxy, HAproxy_bak)
413                                                         row_input = input(Please enter your server info you want to delete here->)
414                                                         del_server_info_under_backend(row_input)
415                                                         continue
416                                             elif row_input == 3:
417                                                 continue
418                                             else:
419                                                 print(Invalid input choice, please re-enter)
420                                                 continue
421 
422                                         else:
423                                             break
424 
425 
426                             elif  row_input == "4":
427                                 if bool(show_all_active_server_info(HAproxy)) == True:
428 
429                                      #show_all_active_server_info(‘HAproxy‘)
430                                      continue
431                                 else:
432                                     backup_server_file(HAproxy, HAproxy_bak)
433                                     row_input = input(There is no actived server info exists, want to add? (y/n))
434                                     if row_input in [q, Q]:
435                                         print(Quit)
436                                         exit()
437                                     elif row_input in [y, Y]:
438                                         print(You should add sever info like {"backend": "test.oldboy.org","record":{"server": "100.1.7.9","weight": 20,"maxconn": 30}})
439                                         row_input = input(Enter your new server info here->: )
440                                         if row_input in [q, Q]:
441                                             print(Quit)
442                                             exit()
443                                         else:
444                                             add_server_info_under_backend(row_input)
445                                             continue
446 
447                             else:
448                                 print(Not invalid choice, please re-enter again.)
449                                 continue
450 
451                     else:
452                         row_input = input(There is no actived server info exists, want to add? (y/n))
453                         if row_input in [q, Q]:
454                             print(Quit)
455                             exit()
456                         elif row_input in [y, Y]:
457                             print(
458                                 You should add sever info like {"backend": "test.oldboy.org","record":{"server": "100.1.7.9","weight": 20,"maxconn": 30}})
459                             row_input = input(Enter your new server info here->: )
460                             if row_input in [q, Q]:
461                                 print(Quit)
462                                 exit()
463                             else:
464                                 backup_server_file(HAproxy, HAproxy_bak)
465                                 add_server_info_under_backend(row_input)
466                                 continue
467                         else:
468                             continue
469 
470 
471 
472 
473             else:
474                 print(Not invalid choice , please re-enter again\n)
475                 continue
View Code

技术分享

Day3-HAproxy

标签:

原文地址:http://www.cnblogs.com/blademaster/p/5817393.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!