原始数据过千就 50 GB，不排查一下会不会有内存泄露的问题？

应该是因为你把同个 ClientSession 用在两个不同的 eventloop 上。asyncio.run 跑完后，event_loop 会关闭掉。在新的 event_loop 跑的时候，因为用的同一个 ClientSession，它用了上一个关闭了的 event_loop，导致这个异常抛出。

你这个是旧版的 aiohttp 吧，新版的 async_timeout 不会出现这个问题。

https://stackoverflow.com/questions/6648493/how-to-open-a-file-for-both-reading-and-writing/58925279#58925279

理论上没有覆盖就没问题 ( ´▽｀)

@dongcheng 问题的代码里没见到有这个 semaphore 。再说你这个用法也不对

`async with await s.get(url) as response:` 这行写错了吧，光 async with 就好了

问问题用 gist 展示代码是美德。

单线程可以快的，multiplex

如果不是同步堵塞住的话，用 `asyncio.wait_for` 就好了。同步堵塞的话，建议修改这个函数，通过 `loop.run_in_executor` 用副线程去跑，这样就不会堵塞住了。同时在外部用 `asyncio.wait_for`，且通过在 coro 内部去 try-except 这个超时而抛出的 `asyncio.CancelError` ，再通过 theading.Event 等方式，把取消事件传递给副线程的函数

pip --version 可以看到 package 会安装到哪个 python

了解一下 mdns，同个局域网内就可以通过 .local 域名访问对应设备了。

特别棒的开源项目，支持支持

试一下 WSGI middleware ？

厦门最近很冷啊，多穿点

不要用，就别用就好了呀。orm 什么时候和 web framework 捆绑了呢

1. 让各个 asyncio.Task 带上优先级
可以通过 loop.set_task_factory 让各个 coroutines 有优先级，可以不修改 Task 对象，优先级存在 context 里就好了。这样其产生的新 task 可以继承这个优先级

2. 修改 loop._run_once 使其按优先级执行（不行）
_run_once 是在跑一个个 callbacks，所以没法用来使 asyncio.Task 按优先级执行

所以就只能在 asyncio.Task.__step 这里搞幺蛾子了，维持一个全局的优先级堆，执行 __step 先检查一下自己的优先级在不在堆顶，看该不该继续执行，不该就重新 call_soon 。

按这个思路应该可以搞起来

@abersheeran 233 我对这方面都不关注的。这个库是在 mitmproxy 源码里发现的，还以为这个普通轮子。原来是根正苗红的官方轮子_(:_」∠)_

@abersheeran 今天发现了一个和你开发的，功能一样的轮子 https://github.com/django/asgiref

@abersheeran aio-libs 有个库叫 janus 应该能满足你的要求。

https://github.com/aio-libs/janus

仔细看了一遍，题主应该是需要用个 queue 把 sync_event 串行起来吧。这样就不会先处理第二个消息了。