寫在片頭：2011年接觸到了Puppet 权均，感嘆老美對自動化的理解高了咱不是一個檔次侍筛。2015年接觸到了Saltstack，再次感嘆葫督。當(dāng)時Saltstack還沒有類似Puppet Foreman之類的Web管理竭鞍，板惑，從那時起，我就有了一個小小目標(biāo)偎快，我要山寨Foreman.....
Saltstack Web分為幾塊冯乘，下面用與Puppet Foreman對比的方式進(jìn)行說明：
對比圖
圖1
圖2
圖3
i圖4
圖5
圖6
一、 環(huán)境
- Master和遍歷程序在同一臺服務(wù)器（Saltstack是否有對應(yīng)的API可以遠(yuǎn)程操作models晒夹，暫時沒研究）
- Django運行版本1.6.1
- Python運行版本2.7.1
二裆馒、 食用過程
思路：在Saltstack master 寫好相應(yīng)的模塊，按照一定的格式放到對應(yīng)的目錄中惋戏，通過遍歷將類的名稱领追，路徑，sls名稱寫入Mysql中响逢，然后通過Web方式進(jìn)行展現(xiàn)绒窑。先取出所有本地模塊列表，組成一個本地模塊列表舔亭。然后用本地模塊列表的數(shù)量和遠(yuǎn)端數(shù)據(jù)庫內(nèi)所存的模塊列表數(shù)量進(jìn)行比較些膨。本地多了，就在遠(yuǎn)端數(shù)據(jù)庫添加钦铺，本地少了订雾，就在遠(yuǎn)端數(shù)據(jù)庫刪除。
1.導(dǎo)入模塊代碼如下（根據(jù)實際情況調(diào)整目錄）
def salt_model_import(request):
if request.method == 'POST':
os_list = []
add_count = 0
del_count = 0
try:
for i in os.listdir('/srv/salt/'):
""""遍歷一級目錄矛洞，判斷目錄下是否為目錄"""
if os.path.isdir('/srv/salt/%s/'%i):
for ii in os.listdir('/srv/salt/%s/'%i):
""""遍歷二級目錄洼哎，判斷目錄下是否為文件且為sls結(jié)尾"""
if os.path.isfile('/srv/salt/%s/%s' %(i,ii)) and str('/srv/salt/%s/%s' %(i,ii)).endswith('sls'):
os_list.append('%s.%s' %(i,ii.split('.')[0]))
else:
pass
for i in os.listdir('/srv/salt/'):
""""遍歷一級目錄，判斷目錄下是否為目錄"""
if os.path.isdir('/srv/salt/%s/'%i):
for ii in os.listdir('/srv/salt/%s/'%i):
""""遍歷二級目錄沼本，判斷目錄下是否為文件且為sls結(jié)尾"""
if os.path.isfile('/srv/salt/%s/%s' %(i,ii)) and str('/srv/salt/%s/%s' %(i,ii)).endswith('sls'):
"""與數(shù)據(jù)庫內(nèi)容進(jìn)行匹對"""
if len(os_list) > Salt_model.objects.all().count():
if Salt_model.objects.filter(salt_model_name=i, salt_model_sls_name=ii, salt_model_dir='/srv/salt/%s/%s' %(i,ii)):
pass
else:
Salt_model(salt_model_name=i, salt_model_sls_name=ii, salt_model_dir='/srv/salt/%s/%s' %(i,ii)).save()
add_count = add_count + 1
elif len(os_list) < Salt_model.objects.all().count():
for i in Salt_model.objects.all():
if '%s.%s'%(i.salt_model_name,i.salt_model_sls_name.split('.')[0]) not in os_list:
Salt_model.objects.filter(salt_model_name=i.salt_model_name, salt_model_sls_name=i.salt_model_sls_name).delete()
del_count = del_count + 1
else:
pass
else:
pass
else:
pass
return HttpResponse('{"status":1,"add_action":%s,"del_action":%s}' % (add_count, del_count))
except Exception as err:
return HttpResponse('{"status":0,"err":%s}' % err)
else:
return HttpResponse('{"status":0}')
數(shù)據(jù)結(jié)果存儲如下：
image.png
2.模塊組代碼如下（根據(jù)實際情況調(diào)整目錄）
思路：數(shù)據(jù)庫已經(jīng)存儲了對應(yīng)的模塊名稱和路徑噩峦，我們只需要借助模塊組的概念，讓目標(biāo)主機挨個通過State.sls挨個去執(zhí)行對應(yīng)的模塊即可抽兆。
def salt_models_group_edit(request):
if request.method == 'GET':
edit_group_id = request.GET['edit_group_id']
salt_models_group = Salt_models_group.objects.get(id = edit_group_id)
salt_models_group_member_list = salt_models_group.salt_models_group_member.split(',')
salt_model = Salt_model.objects.all().order_by('salt_model_name')
salt_model_list = []
for i in salt_model:
salt_model_list.append('%s.%s'%(i.salt_model_name,i.salt_model_sls_name.split(".")[0]))
list = []
for ii in salt_model_list:
if ii in salt_models_group_member_list:
list.append('<option selected>%s</option>' % str(ii))
else:
list.append('<option>%s</option>' % str(ii))
return render_to_response("mysalt/salt_models_group_edit.html",{'list':list},context_instance=RequestContext(request))
else:
edit_group_id = request.META['QUERY_STRING'].split('=')[-1]
salt_models_select_list = request.POST.getlist('salt_models_select',[])
salt_models_group = Salt_models_group.objects.get(id = edit_group_id)
salt_models_group_member_list = salt_models_group.salt_models_group_member.split(',')
for i in salt_models_select_list:
if i not in salt_models_group_member_list:
salt_models_group_member_list.append(i)
for i in salt_models_group_member_list:
if i not in salt_models_select_list:
salt_models_group_member_list.remove(i)
Salt_models_group.objects.filter(id=edit_group_id).update(salt_models_group_member=(','.join(salt_models_group_member_list)).lstrip(','))
return HttpResponseRedirect('/cmdb/salt_models_group/')
def salt_models_group_add (request):
"""1為添加成功识补，0為不成功"""
if request.method == 'POST':
salt_models_group_name = request.POST['salt_models_group_name']
Salt_models_group(salt_models_group_name = salt_models_group_name).save()
return HttpResponse('{"status":1}')
else:
return HttpResponse('{"status":0}')
def salt_models_group_del (request):
"""1為添加成功，0為不成功"""
if 'salt_models_group' in request.GET:
salt_models_group = request.GET['salt_models_group']
Salt_models_group.objects.filter(salt_models_group_name = salt_models_group).delete()
return HttpResponse('{"status":1}')
else:
return HttpResponse('{"status":0}')
數(shù)據(jù)結(jié)果存儲如下：
image.png
