支持Aria2 rpc客户端和async/await管理服务器
aioaria2的Python项目详细描述
提供aria2异步客户端的包
本模块提供与aria2异步通信的客户端与管理aria2进程的服务端
pypi地址
使用方法：
示例如下
importaioaria2importasynciofrompprintimportpprintasyncdefmain():asyncwithaioaria2.Aria2HttpClient("id","http://192.168.0.107:6800/jsonrpc","normal",token="admin")asclient:pprint(awaitclient.getVersion())asyncio.run(main())
相关ip地址应该换成自己的
client对象的相关方法见aria2手册
importaioaria2importasynciofrompprintimportpprintasyncdefmain():asyncwithaioaria2.Aria2HttpClient("id","http://192.168.0.107:6800/jsonrpc","normal",token="admin")asclient:pprint(awaitclient.addUri(["http://www.demo.com"]))#即可下载asyncio.run(main())
运行该协程函数即可，方法对应aria2jsonrpc的方法
对于服务端，每一个实例对应一个aria2进程
importaioaria2importasyncioasyncdefmain():server=aioaria2.AsyncAria2Server(r"128aria2c.exe",r"--conf-path=aria2.conf","--rpc-secret=admin",daemon=True)awaitserver.start()awaitserver.wait()asyncio.run(main())
即可启动一个aria2进程
todolist
- [x] 异步http通信
- [x] 异步websocket通信
- [x] 修复server类的bug
- [ ] 单元测试
jsonrpc 本模块在其之上构建，提供了异步支持，以级websocket支持
windows用户应该加上以下设置
asyncio.set_event_loop_policy(asyncio.WindowsProactorEventLoopPolicy())
asyncio.set_event_loop(asyncio.ProactorEventLoop())
python3.8以后默认是ProactorEventLoop因此可以不用修改
Notice
在最终v1.0发布之前不建议直接setup安装
v1.2.0更新
新增Aria2WebsocketTrigger类，可以监听websocket消息, 使用on*方法注册自定义回调函数,既可以是同步也可以是异步的
如下
@trigger.onDownloadStart
async def onDownloadStart(trigger, future):
print("下载开始{0}".format(future.result()))
v1.2.3更新
可以给一个事件注册多个回调,现在只能是协程函数,同步函数需要自行从utils.run_sync包装
@trigger.onDownloadStart
async def callback1(trigger, future):
print("第一个回调{0}".format(future.result()))
@trigger.onDownloadStart
@run_sync
def callback2(trigger, future):
print("第二个回调{0}".format(future.result()))
- 项目
标签：
欢迎加入QQ群-->： 979659372
