欢迎！我白天是个邮递员，晚上就是个有抱负的演员。这是我的网站。我住在天朝的帝都，有条叫做Jack的狗。
import requestsimport json class Aria2Download: def __init__(self): self.api = "http://localhost:6800/jsonrpc" # 消息id，aria2会原样返回这个id，可以自动生成也可以用其他唯一标识 self.id = "QXJpYU5nXzE2NzUxMzUwMDFfMC42Mzc0MDA5MTc2NjAzNDM=" def addUri(self, url, path, file=None, proxy=None): """ 添加任务 :param url: 文件下载地址 :param path: 文件保存路径 :param file: 文件保存名称 :param proxy: 代{过}{滤}理地址 :return: """ data = { "id": self.id, "jsonrpc": "2.0", "method": "aria2.addUri", "params": [[url], {"dir": path, "out": file, "all-proxy": proxy}] } req = requests.post(url=self.api, data=json.dumps(data)) return_json = req.json() req.close() # print("addUri", return_json) return return_json def getGlobalStat(self): """ 获取全部下载信息 :return: """ data = { "jsonrpc": "2.0", "method": "aria2.getGlobalStat", "id": self.id } req = requests.post(url=self.api, data=json.dumps(data)) return_json = req.json() req.close() # print("getGlobalStat", return_json) return return_json def tellActive(self): """ 正在下载 :return: """ data = { "jsonrpc": "2.0", "method": "aria2.tellActive", "id": self.id, "params": [ ["gid", "totalLength", "completedLength", "uploadSpeed", "downloadSpeed", "connections", "numSeeders", "seeder", "status", "errorCode", "verifiedLength", "verifyIntegrityPending", "files", "bittorrent", "infoHash"]] } req = requests.post(url=self.api, data=json.dumps(data)) return_json = req.json() req.close() # print("getGlobalStat", return_json) return return_json def tellWaiting(self): """ 正在等待 :return: """ data = {"jsonrpc": "2.0", "method": "aria2.tellWaiting", "id": self.id, "params": [0, 1000, ["gid", "totalLength", "completedLength", "uploadSpeed", "downloadSpeed", "connections", "numSeeders", "seeder", "status", "errorCode", "verifiedLength", "verifyIntegrityPending"] ] } req = requests.post(url=self.api, data=json.dumps(data)) return_json = req.json() req.close() print("tellWaiting", return_json) return return_json def tellStopped(self): """ 已完成/已停止 :return: """ data = {"jsonrpc": "2.0", "method": "aria2.tellStopped", "id": self.id, "params": [-1, 1000, ["gid", "totalLength", "completedLength", "uploadSpeed", "downloadSpeed", "connections", "numSeeders", "seeder", "status", "errorCode", "verifiedLength", "verifyIntegrityPending"]] } req = requests.post(url=self.api, data=json.dumps(data)) return_json = req.json() req.close() # print("tellStopped", return_json) return return_json def tellStatus(self, gid): """ 任务状态 :param gid: 任务ID :return: """ data = {"jsonrpc": "2.0", "method": "aria2.tellStatus", "id": self.id, "params": [gid]} req = requests.post(url=self.api, data=json.dumps(data)) return_json = req.json() req.close() # print("tellWaiting", return_json) return return_json def removeDownloadResult(self, gid): """ 删除下载结束的任务 :param gid: 任务ID :return: """ data = {"jsonrpc": "2.0", "method": "aria2.removeDownloadResult", "id": self.id, "params": [gid]} req = requests.post(url=self.api, data=json.dumps(data)) return_json = req.json() req.close() # print("removeDownloadResult", return_json) return return_json
