如何对一个协程进行评级，并在该限值后调用该协程？

Question

我一直在阅读这里的回复：What's a good rate limiting algorithm?

Carlos A.Ibarra的回复在没有异步功能的情况下工作得很好，但是我有什么方法可以修改它来异步工作吗？在

import time

def RateLimited(maxPerSecond):
    minInterval = 1.0 / float(maxPerSecond)
    def decorate(func):
        lastTimeCalled = [0.0]
        def rateLimitedFunction(*args,**kargs):
            elapsed = time.clock() - lastTimeCalled[0]
            leftToWait = minInterval - elapsed
            if leftToWait>0:
                time.sleep(leftToWait)
            ret = func(*args,**kargs)
            lastTimeCalled[0] = time.clock()
            return ret
        return rateLimitedFunction
    return decorate

@RateLimited(2)  # 2 per second at most
def PrintNumber(num):
    print num

if __name__ == "__main__":
    print "This should print 1,2,3... at about 2 per second."
    for i in range(1,100):
        PrintNumber(i)

将time.sleep(leftToWait)更改为await asyncio.sleep(leftToWait)并等待PrintNumber(i)对第一个实例有效，但之后就不起作用了。我是Python的新手，我尽力遵守API的速率限制。在

我的实现：

^{pr2}$

Answer 1

这里有一个简单的不和.py解决方案。这将使用on_command_error事件来保存命令并永远运行它，直到冷却问题得到解决，基本上是通过使用asyncio.sleep等待冷却时间：

bot = commands.Bot('?')

@bot.command(hidden=True, pass_context=True)
@commands.cooldown(1, 5, commands.BucketType.user)  # means "allow to be called 1 time every 5 seconds for this user, anywhere"
async def test(ctx):
    print("TEST")

@bot.event
async def on_command_error(exc, context: commands.Context):
    if isinstance(exc, commands.errors.CommandOnCooldown):
        while True:
            await asyncio.sleep(exc.retry_after)
            try:
                return await context.command.invoke(context)
            except commands.errors.CommandOnCooldown as e:
                exc = e

示例

在不一致（假设前缀是?）：

^{pr2}$

在控制台中：

0s> TEST
5s> TEST
10s> TEST