DeepSeek网页版入口 · 在线免登录对话

针对您的高并发调度需求，推荐使用 asyncio + aiohttp 配合令牌桶速率限制器实现。核心代码结构如下：

import asyncio
import time

class AsyncRateLimiter:
    def __init__(self, rate: int, per: float = 1.0):
        self.rate = rate
        self.per = per
        self.semaphore = asyncio.Semaphore(rate)

    async def __aenter__(self):
        await self.semaphore.acquire()
        return self

    async def __aexit__(self, exc_type, exc_val, exc_tb):
        asyncio.create_task(self._release_after())

    async def _release_after(self):
        await asyncio.sleep(self.per)
        self.semaphore.release()