溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要講解了“怎么用python + Element實現作業任務Job操作”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“怎么用python + Element實現作業任務Job操作”吧！
<div id="app"> <div class="col-md-10 col-md-offset-1"> <div class="container-fluid mb0 " > <div class="row"> <div class="col-md-4"> <form class="form-horizontal"> <div class="form-group clearfix "> <label class="col-sm-4 control-label bk-lh40 pt0">任務類型：</label> <div class="col-sm-8"> <el-select v-model="searchJobType" placeholder="請選擇任務類型" > <el-option v-for="item in jobType" :label="item.title" :value="item.title"></el-option> </el-select> </div> </div> </form> </div> <div class="col-md-4"> <form class="form-horizontal"> <div class="form-group clearfix "> <label class="col-sm-4 control-label bk-lh40 pt0">任務名稱：</label> <div class="col-sm-8"> <el-input v-model="searchJobName" placeholder="請輸入任務名稱" ></el-input> </div> </div> </form> </div> <div class="col-md-4"> <form class="form-horizontal"> <div class="form-group clearfix "> <div class="col-sm-8"> <el-button type="primary" @click="getSearch">搜索</el-button> <el-button type="success" @click="addDialog = true">添加</el-button> </div> </div> </form> </div> </div> </div> <el-table :data="jobData" border > <el-table-column prop="bk_biz_id" label="業務ID"></el-table-column> <el-table-column prop="bk_biz_name" label="業務名稱"></el-table-column> <el-table-column prop="temp_name" label="模板名稱"></el-table-column> <el-table-column prop="job_name" label="作業名稱"></el-table-column> <el-table-column prop="type" label="類型"></el-table-column> <el-table-column prop="interval" label="間隔時間"></el-table-column> <el-table-column prop="host_ip" label="主機IP"></el-table-column> <el-table-column prop="create_time" label="添加時間"></el-table-column> <el-table-column label="操作"> <template slot-scope="scope"> <el-button type="primary" size="small" @click="editJobMethod(scope.row)">修改</el-button> <el-button type="danger" size="small" @click="deleteJobMethod(scope.row)">刪除</el-button> </template> </el-table-column> </el-table> <!-- 新增的對話框 --> <el-dialog title="添加作業任務" :visible.sync="addDialog" width="40%"> <el-form ref="addForm" :model="addForm" label-width="100px"> <el-form-item label="選擇業務"> <el-select v-model="addForm.add_biz" placeholder="請選擇業務" > <el-option v-for="item in bkBizData" :label="item.bk_biz_name" :value="item.bk_biz_id +':'+item.bk_biz_name"></el-option> </el-select> </el-form-item> <el-form-item label="巡檢模板"> <el-select v-model="addForm.add_temp" placeholder="請選擇巡檢模板" > <el-option v-for="item in TempData" :label="item.temp_name" :value="item.pk +':'+item.temp_name"></el-option> </el-select> </el-form-item> <el-form-item label="任務名稱"> <el-input v-model="addForm.add_job_name"></el-input> </el-form-item> <el-form-item label="任務類型"> <el-radio-group v-model="addForm.add_type"> <el-radio label="立即">立即</el-radio> <el-radio label="周期">周期-----每隔 <el-input v-model="addForm.add_interval" ></el-input> 分鐘執行一次 </el-radio> </el-radio-group> </el-form-item> <el-form-item label="巡檢服務器"> <el-select v-model="addForm.add_host_ip" placeholder="請選擇巡檢服務器" > <el-option v-for="item in HostData" :label="item.host_name" :value="item.ip"></el-option> </el-select> </el-form-item> <el-form-item> <el-button type="primary" @click="addDialogOk">立即創建</el-button> <el-button @click="addTempDialog = false">取消</el-button> </el-form-item> </el-form> </el-dialog> <el-dialog title="修改作業任務" :visible.sync="editDialog" width="40%"> <el-form ref="editForm" :model="editForm" label-width="100px"> <el-form-item label="選擇業務"> <el-select v-model="editForm.edit_bk_biz" placeholder="請選擇業務" > <el-option v-for="item in bkBizData" :label="item.bk_biz_name" :value="item.bk_biz_id +':'+item.bk_biz_name"></el-option> </el-select> </el-form-item> <el-form-item label="巡檢模板"> <el-select v-model="editForm.edit_temp_name" placeholder="請選擇巡檢模板" > <el-option v-for="item in TempData" :label="item.temp_name" :value="item.pk +':'+item.temp_name"> </el-option> </el-select> </el-form-item> <el-form-item label="任務名稱"> <el-input v-model="editForm.edit_job_name"></el-input> </el-form-item> <el-form-item label="任務類型"> <el-radio-group v-model="editForm.edit_type"> <el-radio label="立即">立即</el-radio> <el-radio label="周期">周期-----每隔 <el-input v-model="editForm.edit_interval" ></el-input>分鐘執行一次 </el-radio> </el-radio-group> </el-form-item> <el-form-item label="巡檢服務器"> <el-select v-model="editForm.edit_host_ip" placeholder="請選擇巡檢服務器" > <el-option v-for="item in HostData" :label="item.host_name" :value="item.ip"></el-option> </el-select> </el-form-item> <el-form-item> <el-button type="primary" @click="editDialogOk">立即創建</el-button> <el-button @click="editDialog = false">取消</el-button> </el-form-item> </el-form> </el-dialog> <!-- 設置面板End --> </div> </div>
<script type="text/javascript">
new Vue({
el: '#app',
data: {
bkBizData: [],
jobData: [],
HostData: [],
TempData: [],
editDialog:false,
addDialog:false,
addForm: {
add_biz: '',
add_temp: '',
add_job_name: '',
add_type: '',
add_interval: '',
add_host_ip: ''
},
editForm: {
pk:'',
edit_bk_biz: '',
edit_temp_name: '',
edit_job_name: '',
edit_type: '',
edit_interval: '',
edit_host_ip: ''
},
jobType:[
{
title: '全部',
key: '全部'
},
{
title: '立即',
key: '立即'
},
{
title: '周期',
key: '周期'
}
],
searchJobType: '',
searchJobName:''
},
mounted() {
// 頁面加載就獲取所有模板
this.init()
},
methods: {
init() {
axios.get(site_url + "get_biz_list/").then(res => {
if (res.data.result){
this.bkBizData = res.data.data;
}else{
this.$message.error('獲取業務失敗');
}
},'json');
axios.get(site_url + "temp_view/").then(res => {
if (res.data.result){
this.TempData = res.data.data;
}else{
this.$message.error('獲取模板失敗');
}
},'json');
axios.get(site_url + "get_bk_hosts/").then(res => {
if (res.data.result){
this.HostData = res.data.data;
}else{
this.$message.error('獲取模板失敗');
}
},'json');
this.getSearch();
},
getSearch() {
axios.get(site_url + "job_view/?search_type=" + this.searchJobType + "&query_str=" + this.searchJobName).then(res => {
if (res.data.result){
this.jobData = res.data.data;
console.log(this.jobData)
}else{
this.$message.error('獲取模板失敗');
}
},'json');
},
addDialogOk() {
axios.post(site_url + "job_view/", this.addForm).then(res => {
if (res.data.result) {
this.$message.success('添加作業任務成功');
this.addDialog = false;
this.init();
this.addForm = {
add_biz: '',
add_temp: '',
add_job_name: '',
add_type: '',
add_interval: '',
add_host_ip: ''
}
} else {
this.$message.error('添加作業任務失敗');
}
}, 'json');
},
editJobMethod(row) {
this.editForm.edit_bk_biz = row.bk_biz_id + ":" + row.bk_biz_name;
this.editForm.edit_temp_name = row.temp_id + ":" + row.temp_name;
this.editForm.edit_job_name = row.job_name;
this.editForm.edit_type = row.type;
this.editForm.edit_interval = row.interval;
this.editForm.edit_host_ip = row.host_ip;
this.editForm.pk = row.pk;
this.editDialog = true;
},
deleteJobMethod(row) {
this.$confirm('正在刪除作業任務, 是否繼續?', '提示', {
confirmButtonText: '確定',
cancelButtonText: '取消',
type: 'warning'
}).then(() => {
axios.delete('/job_view/',{data:{id:row.pk}}).then(res => {
if (res.data.result) {
this.$message.success('刪除作業任務成功');
this.init();
} else {
this.$message.error('刪除作業任務失敗');
}
}, 'json');
}).catch(() => {
this.$message({
type: 'info',
message: '已取消刪除'
});
});
},
editDialogOk() {
axios.put(site_url + "job_view/", this.editForm).then(res => {
if (res.data.result) {
this.$message.success('更新作業任務成功');
this.editDialog = false;
this.init();
} else {
this.$message.error('更新作業任務失敗');
}
}, 'json');
}
}
})
</script>urls.py文件內容
from django.conf.urls import patterns from home_application.temp import views as temp_view from home_application.job import views as job_view urlpatterns = patterns( 'home_application.views', (r'^$', job_view.job), (r'^get_biz_list/$', job_view.get_biz_list), (r'^get_bk_hosts/$', job_view.get_bk_hosts), (r'^temp_view/$', temp_view.TemplateView.as_view()), (r'^job_view/$', job_view.JobView.as_view()), ... )
job\views.py文件內容
import json
from django.views.generic import View
from django.views.decorators.csrf import csrf_exempt
from django.utils.decorators import method_decorator
from django.http import JsonResponse
from common.mymako import render_mako_context
from home_application.models import Job
def cc_search_host():
"""
根據條件查詢主機
:return:
"""
url = "{0}/api/c/compapi/v2/cc/search_host/".format(BK_PAAS_HOST)
kwargs = {
"bk_app_code": APP_ID,
"bk_app_secret": APP_TOKEN,
"bk_username": "admin",
"condition": [
{
"bk_obj_id": "host",
"fields": ["bk_host_name", "bk_host_innerip", "bk_host_id", "bk_cloud_id", ],
},
{
"bk_obj_id": "biz",
"fields": ["bk_biz_id", "bk_biz_name"],
}
],
# "page": {"start": 0, "limit": 10}
}
response = requests.post(url=url, data=json.dumps(kwargs), verify=False)
if response.status_code == 200:
return json.loads(response.content).get("data")
# 獲取所有業務,測試OK
def cc_search_business(fields=[]):
"""
獲取業務列表
:param request:
:return:
"""
client = get_client_by_user("admin")
params = {'fields': fields}
res = client.cc.search_business(**params)
if res.get('code') == 0:
return res.get('data', {}).get('info', [])
def job(request):
return render_mako_context(request, '/home_application/job_center.html')
def get_biz_list(request):
fields = ["bk_biz_id", "bk_biz_name"]
return JsonResponse({"result": True, "data": data})
def get_bk_hosts(request):
from home_application.utils.cc_by_request import cc_search_host
res_data = cc_search_host()
return JsonResponse({"result": True, "data": res_data})
class CsrfExemptView(View):
@method_decorator(csrf_exempt)
def dispatch(self, request, *args, **kwargs):
return super(CsrfExemptView, self).dispatch(request, *args, **kwargs)
class JobView(CsrfExemptView):
def get(self, request, *args, **kwargs):
search_type = request.GET.get("search_type")
query_str = request.GET.get("query_str")
try:
job_query = Job.objects.all()
except Exception:
return JsonResponse({"result": False})
if search_type:
job_query = job_query.filter(type=search_type)
if query_str:
job_query = job_query.filter(job_name__icontains=query_str)
res_data = [i.to_dict() for i in job_query]
return JsonResponse({"result": True, "data": res_data})
def post(self, request, *args, **kwargs):
data = json.loads(request.body)
job_obj = {
"bk_biz_id": data.get("add_biz").split(":")[0],
"bk_biz_name": data.get("add_biz").split(":")[1],
"temp_id": data.get("add_temp").split(":")[0],
"temp_name": data.get("add_temp").split(":")[1],
"job_name": data.get("add_job_name"),
"type": data.get("add_type"),
"interval": data.get("add_interval"),
"host_ip": data.get("add_host_ip"),
}
try:
Job.objects.create(**job_obj)
return JsonResponse({"result": True})
except Exception as e:
print(e)
return JsonResponse({"result": False})
def put(self, request, *args, **kwargs):
data = json.loads(request.body)
pk = data.get("pk")
bk_biz_id = data.get("edit_bk_biz").split(":")[0]
temp_id = data.get("edit_temp_name").split(":")[0]
temp_name = data.get("edit_temp_name").split(":")[1]
bk_biz_name = data.get("edit_bk_biz").split(":")[1]
job_name = data.get("edit_job_name")
type = data.get("edit_type")
interval = data.get("edit_interval")
host_ip = data.get("edit_host_ip")
job_obj = {
"bk_biz_id": bk_biz_id,
"bk_biz_name": bk_biz_name,
"temp_id": temp_id,
"temp_name": temp_name,
"job_name": job_name,
"type": type,
"interval": interval,
"host_ip": host_ip,
}
try:
Job.objects.filter(pk=pk).update(**job_obj)
return JsonResponse({"result": True})
except Exception as e:
return JsonResponse({"result": False})
def delete(self, request, *args, **kwargs):
data = json.loads(request.body)
pk = data.get("id")
try:
Job.objects.filter(pk=pk).delete()
return JsonResponse({"result": True})
except Exception:
return JsonResponse({"result": False})models.py文件內容
class Job(models.Model):
bk_biz_id = models.CharField(u"業務ID", max_length=8, blank=True, null=True)
bk_biz_name = models.CharField(u"業務名稱", max_length=32, blank=True, null=True)
temp_id = models.CharField(u"模板ID", max_length=8, blank=True, null=True)
temp_name = models.CharField(u"模板名稱", max_length=32, blank=True, null=True)
job_name = models.CharField(u"作業名稱", max_length=16, blank=True, null=True)
type = models.CharField(u"類型", max_length=8, blank=True, null=True)
interval = models.CharField(u"間隔時間", max_length=4, blank=True, null=True)
host_ip = models.CharField(u"主機IP", max_length=32, blank=True, null=True)
create_time = models.DateTimeField(u"創建時間", auto_now_add=True)
def to_dict(self):
return {
"pk": self.pk,
"bk_biz_id": self.bk_biz_id,
"bk_biz_name": self.bk_biz_name,
"temp_id": self.temp_id,
"temp_name": self.temp_name,
"job_name": self.job_name,
"type": self.type,
"interval": self.interval,
"host_ip": self.host_ip,
"create_time": parse_datetime_to_timestr(self.create_time),
}實現效果
感謝各位的閱讀，以上就是“怎么用python + Element實現作業任務Job操作”的內容了，經過本文的學習后，相信大家對怎么用python + Element實現作業任務Job操作這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
