有没有类似onDownloadComplete、onDownloadError或类似的aria2通知侦听示例

Question

我正试图用aria2工具编排文件下载。文档中有一个示例，如：

import urllib2, json
jsonreq = json.dumps({'jsonrpc':'2.0', 'id':'qwer',
'method':'aria2.addUri',
'params':[['http://example.org/file']]})
c = urllib2.urlopen('http://localhost:6800/jsonrpc', jsonreq)
c.read()
# The result:
# '{"id":"qwer","jsonrpc":"2.0","result":"2089b05ecca3d829"}'

它开始下载http://example.org/file并返回一些GID(下载ID(2089b05ecca3d829。。。

Aria2支持通知。但没有任何关于如何获得通知的例子，例如onDownloadComplete、onDownloadError等。我认为，有一种方法可以请求aria2通过某些(我的(IP和端口上的JSON-RPC(HTTP(调用我。但我找不到如何请求aria2来做这件事的方法(如何用我的IP、端口订阅通知(。Python、Ruby或类似语言中的任何示例都将非常有用。

Answer 1

参考aria2文档您应该使用websocket与RPC服务器进行通信：

import websocket
from pprint import pprint
ws_server = "ws://localhost:6800/jsonrpc"
socket = websocket.create_connection(ws_server)
while 1:
message = socket.recv()
pprint(message)
time.sleep(3)

socket.close()

在您得到消息(json对象(后，您将得到onDownloadComplete事件，然后您可以做任何您喜欢的事情。我建议你使用咏叹调(上面@RandomB提到过(，https://pawamoy.github.io/aria2p/reference/api/#aria2p.api.API.listen_to_notifications

使用回调设置通知。

......
def start_listen(self):
self.api.listen_to_notifications(
threaded=True,
on_download_complete=self.done,
timeout=1,
handle_signals=False
)
def done(self, api, gid):
down = api.get_download(gid)
dataMedia = str(down.files[0].path)
def stop_listen(self):
while len(self.links) > 0:
gids = list(self.links.keys())
for down in self.api.get_downloads(gids):
if down.status in ['waiting', 'active']:
time.sleep(5)
break
else:
del self.links[down.gid]
if down.status in ['complete']:
#print(f'>>>>>{down.gid} Completed')
pass
else:
print(Back.RED + f'{down.gid}|{down.files[0]}|{down.status}|error msg: {down.error_message}', end = '')
print(Style.RESET_ALL)

print('all finished!!!!')
self.api.stop_listening()