ratelimiter 1.2.0.post0

装潢师

fromratelimiterimportRateLimiter@RateLimiter(max_calls=10,period=1)defdo_something():pass

上下文管理器

fromratelimiterimportRateLimiterrate_limiter=RateLimiter(max_calls=10,period=1)foriinrange(100):withrate_limiter:do_something()

回拨

回调是在它自己的线程中调用的，因此回调可以使用 sleep不延迟速率限制。

importtimefromratelimiterimportRateLimiterdeflimited(until):duration=int(round(until-time.time()))print('Rate limited, sleeping for {:d} seconds'.format(duration))rate_limiter=RateLimiter(max_calls=2,period=3,callback=limited)foriinrange(3):withrate_limiter:print('Iteration',i)

输出：

Iteration 0
Iteration 1
Rate limited, sleeping for 3 seconds
Iteration 2

异步

RateLimiter对象可以在上的async with语句中使用 python 3.5+。注意，在这个上下文中，回调必须是一个协程。 协同程序回调不在单独的线程中调用。

importasyncioimporttimefromratelimiterimportRateLimiterasyncdeflimited(until):duration=int(round(until-time.time()))print('Rate limited, sleeping for {:d} seconds'.format(duration))asyncdefcoro():rate_limiter=RateLimiter(max_calls=2,period=3,callback=limited)foriinrange(3):asyncwithrate_limiter:print('Iteration',i)loop=asyncio.get_event_loop()loop.run_until_complete(coro())

根据apache许可证2.0版（以下简称“许可证”）授权；您可以 除非符合许可证，否则不要使用此文件。你可以获得 在

http://www.apache.org/licenses/LICENSE-2.0

除非适用法律要求或书面同意，否则软件 根据许可证分发是按“原样”分发的， 无任何明示或默示的保证或条件。 有关管理权限的特定语言和 许可下的限制。