taskmanage.py
1.16 KB
#!/x/app/python3/bin/python3
# -*- coding: utf-8 -*-
import urllib.request
import urllib.parse
import urllib.error
import json
class TaskManage:
def __init__(self):
self.__header = {"Content-Type": "application/json-rpc"}
#get请求
def get_request(self,GetUrl,Param):
request = urllib.request.Request(GetUrl+Param)
result = urllib.request.urlopen(request).read().decode('utf-8')
json=eval(result)
return json
#post请求
def post_request(self,PostUrl,data):
request = urllib.request.Request(PostUrl,json.dumps(data).encode('utf-8'),self.__header)
result = urllib.request.urlopen(request).read().decode('utf-8')
#改切片状态
def change_slice_status(self,PostUrl,TaskId,Status,slice_server,slice_error_desc):
data={"task_id" : TaskId, "status": Status, "slice_server": slice_server, "slice_error_desc": slice_error_desc}
return self.post_request(PostUrl,data)
#改发布状态
def change_push_status(self,PostUrl,TaskId,Status,slice_server,source_cdn_error_desc):
data={"task_id" : TaskId, "source_cdn_status": Status, "source_cdn_server": slice_server,"source_cdn_error_desc":source_cdn_error_desc}
return self.post_request(PostUrl,data)