{"id":300714,"date":"2020-03-25T15:00:17","date_gmt":"2020-03-25T15:00:17","guid":{"rendered":"http:\/\/savepearlharbor.com\/?p=300714"},"modified":"-0001-11-30T00:00:00","modified_gmt":"2020-03-25T15:00:17","slug":"","status":"publish","type":"post","link":"https:\/\/savepearlharbor.com\/?p=300714","title":{"rendered":"Celery throttling \u2014 \u043d\u0430\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u043c rate limit \u0434\u043b\u044f \u043e\u0447\u0435\u0440\u0435\u0434\u0435\u0439"},"content":{"rendered":"\n<div class=\"post__text post__text-html post__text_v1\" id=\"post-content-body\" data-io-article-url=\"https:\/\/habr.com\/ru\/post\/494090\/\">\n<p>\u200b \u0412 \u044d\u0442\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0435 \u044f \u043f\u043e\u043a\u0430\u0436\u0443 \u043a\u0430\u043a \u0440\u0435\u0448\u0438\u0442\u044c \u043e\u0434\u043d\u0443 \u0438\u0437 \u043f\u0440\u043e\u0431\u043b\u0435\u043c, \u0432\u043e\u0437\u043d\u0438\u043a\u0430\u044e\u0449\u0438\u0445 \u043f\u0440\u0438 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0438 \u0440\u0430\u0441\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u0445 \u043e\u0447\u0435\u0440\u0435\u0434\u0435\u0439 \u0437\u0430\u0434\u0430\u0447 \u2014 \u0440\u0435\u0433\u0443\u043b\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u043f\u0440\u043e\u043f\u0443\u0441\u043a\u043d\u043e\u0439 \u0441\u043f\u043e\u0441\u043e\u0431\u043d\u043e\u0441\u0442\u0438 \u043e\u0447\u0435\u0440\u0435\u0434\u0438, \u0438\u043b\u0438 \u0436\u0435, \u0431\u043e\u043b\u0435\u0435 \u043f\u0440\u043e\u0441\u0442\u044b\u043c \u044f\u0437\u044b\u043a\u043e\u043c, \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0430 \u0435\u0435 rate limit&#8217;a. \u0412 \u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u043f\u0440\u0438\u043c\u0435\u0440\u0430 \u044f \u0432\u043e\u0437\u044c\u043c\u0443 <strong>python<\/strong> \u0438 \u0441\u0432\u043e\u044e \u043b\u044e\u0431\u0438\u043c\u0443\u044e \u0441\u0432\u044f\u0437\u043a\u0443 <strong>Celery+RabbitMQ<\/strong>, \u0445\u043e\u0442\u044f \u0430\u043b\u0433\u043e\u0440\u0438\u0442\u043c, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044e, \u043d\u0438\u043a\u0430\u043a \u043d\u0435 \u0437\u0430\u0432\u0438\u0441\u0438\u0442 \u043e\u0442 \u044d\u0442\u0438\u0445 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u043e\u0432 \u0438 \u043c\u043e\u0436\u0435\u0442 \u0431\u044b\u0442\u044c \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d \u043d\u0430 \u043b\u044e\u0431\u043e\u043c \u0434\u0440\u0443\u0433\u043e\u043c \u0441\u0442\u044d\u043a\u0435.<\/p>\n<p>  <\/p>\n<p><img decoding=\"async\" src=\"https:\/\/habrastorage.org\/webt\/ei\/h-\/pa\/eih-panacwyd8rxigfn7saopzbs.jpeg\" alt=\"Celery+RabbitMQ\"><\/p>\n<p>  <\/p>\n<h2 id=\"so-whats-the-problem\">So what&#8217;s the problem?<\/h2>\n<p>  <\/p>\n<p>\u200b \u0414\u043b\u044f \u043d\u0430\u0447\u0430\u043b\u0430 \u043f\u0430\u0440\u0430 \u0441\u043b\u043e\u0432 \u043e \u0442\u043e\u043c, \u043a\u0430\u043a\u0443\u044e \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0443 \u044f \u0432\u043e\u043e\u0431\u0449\u0435 \u043f\u044b\u0442\u0430\u044e\u0441\u044c \u0440\u0435\u0448\u0438\u0442\u044c. \u0414\u0435\u043b\u043e \u0432 \u0442\u043e\u043c, \u0447\u0442\u043e <em>99.9% \u0441\u0435\u0440\u0432\u0438\u0441\u043e\u0432 \u0432 \u0438\u043d\u0442\u0435\u0440\u043d\u0435\u0442\u0435 \u0437\u0430\u043f\u0440\u0435\u0449\u0430\u044e\u0442 \u0431\u0435\u0441\u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044c\u043d\u043e \u0437\u0430\u043a\u0438\u0434\u044b\u0432\u0430\u0442\u044c \u0438\u0445 \u0441\u043e\u0442\u043d\u044f\u043c\u0438\/\u0442\u044b\u0441\u044f\u0447\u0430\u043c\u0438 \u0437\u0430\u043f\u0440\u043e\u0441\u043e\u0432 \u0432 \u0441\u0435\u043a\u0443\u043d\u0434\u0443<\/em>, \u0443\u0433\u0440\u043e\u0436\u0430\u044f \u0434\u0430\u0442\u044c \u0432 \u043e\u0442\u0432\u0435\u0442 \u043a\u0430\u043a\u043e\u0439-\u043d\u0438\u0431\u0443\u0434\u044c 403 \u0438\u043b\u0438 500. \u041d\u0435\u0442, \u043d\u0443 \u043f\u0440\u0430\u0432\u0434\u0430, \u0436\u0430\u043b\u043a\u043e \u0438\u043c \u0447\u0442\u043e\u043b\u0435? \u0418\u043d\u043e\u0433\u0434\u0430 \u0442\u0430\u043a\u0438\u043c \u0441\u0435\u0440\u0432\u0438\u0441\u043e\u043c \u043c\u043e\u0436\u0435\u0442 \u0432\u044b\u0441\u0442\u0443\u043f\u0430\u0442\u044c \u0434\u0430\u0436\u0435 \u0441\u0432\u043e\u044f \u0441\u043e\u0431\u0441\u0442\u0432\u0435\u043d\u043d\u0430\u044f \u0411\u0414\u2026 \u0412\u043e\u0431\u0449\u0435\u043c, \u0434\u043e\u0432\u0435\u0440\u044f\u0442\u044c \u043d\u044b\u043d\u0447\u0435 \u043d\u0435\u043b\u044c\u0437\u044f \u043d\u0438\u043a\u043e\u043c\u0443, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u043f\u0440\u0438\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0441\u0435\u0431\u044f \u043a\u0430\u043a-\u0442\u043e \u0441\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0442\u044c.<\/p>\n<p>  <\/p>\n<p>\u200b \u041a\u043e\u043d\u0435\u0447\u043d\u043e, \u0435\u0441\u043b\u0438 \u0432\u0441\u044f \u0440\u0430\u0431\u043e\u0442\u0430 \u0432\u0435\u0434\u0435\u0442\u0441\u044f \u0432\u043d\u0443\u0442\u0440\u0438 1\u0433\u043e \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430, \u0442\u043e \u043d\u0438\u043a\u0430\u043a\u043e\u0439 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u044b \u043d\u0435\u0442, \u043d\u043e \u0442.\u043a \u043c\u044b \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u043c \u0441 Celery, \u0442\u043e \u0443 \u043d\u0430\u0441 \u043c\u043e\u0436\u0435\u0442 \u0431\u044b\u0442\u044c \u043d\u0435 \u0442\u043e\u043b\u044c\u043a\u043e N \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u043e\u0432 (\u0434\u0430\u043b\u0435\u0435 <em>\u0432\u043e\u0440\u043a\u0435\u0440\u043e\u0432<\/em>), \u043d\u043e \u0438 M \u043c\u0430\u0448\u0438\u043d, \u0438 \u0437\u0430\u0434\u0430\u0447\u0430 \u0432\u0441\u0435 \u044d\u0442\u043e \u0434\u0435\u043b\u043e \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0443\u0436\u0435 \u043d\u0435 \u043a\u0430\u0436\u0435\u0442\u0441\u044f \u0441\u0442\u043e\u043b\u044c \u0442\u0440\u0438\u0432\u0438\u0430\u043b\u044c\u043d\u043e\u0439.<\/p>\n<p><a name=\"habracut\"><\/a>  <\/p>\n<h2 id=\"whats-in-the-box\">What&#8217;s in the box<\/h2>\n<p>  <\/p>\n<p>\u200b \u041f\u0435\u0440\u0432\u043e\u0435, \u043d\u0430 \u0447\u0442\u043e \u043d\u0430\u0442\u044b\u043a\u0430\u0435\u0448\u044c\u0441\u044f, \u043a\u043e\u0433\u0434\u0430 \u0438\u0449\u0435\u0448\u044c, \u043a\u0430\u043a \u0436\u0435 \u043d\u0430\u0441\u0442\u0440\u043e\u0438\u0442\u044c throttling \u0432 celery, \u044d\u0442\u043e \u0432\u0441\u0442\u0440\u043e\u0435\u043d\u043d\u044b\u0439 \u043f\u0430\u0440\u0430\u043c\u0435\u0442\u0440 <code>rate_limit<\/code> \u043a\u043b\u0430\u0441\u0441\u0430 <code>Task<\/code>. \u0417\u0432\u0443\u0447\u0438\u0442 \u043a\u0430\u043a \u0442\u043e, \u0447\u0442\u043e \u043d\u0430\u0434\u043e, \u043d\u043e, \u043a\u043e\u043f\u043d\u0443\u0432 \u0447\u0443\u0442\u044c \u0433\u043b\u0443\u0431\u0436\u0435, \u0437\u0430\u043c\u0435\u0447\u0430\u0435\u043c, \u0447\u0442\u043e:<\/p>\n<p>  <\/p>\n<blockquote><p>\u041d\u0435\u043b\u044c\u0437\u044f \u0437\u0430\u0434\u0430\u0442\u044c rate limit \u043d\u0430 \u0433\u0440\u0443\u043f\u043f\u0443 \u0437\u0430\u0434\u0430\u0447.<br \/>  \u042d\u0442\u043e \u043d\u0435\u0443\u0434\u043e\u0431\u043d\u043e, \u0442.\u043a \u0437\u0430\u0447\u0430\u0441\u0442\u0443\u044e \u0434\u043e\u0441\u0442\u0443\u043f \u043a \u043a\u0430\u043a\u043e\u043c\u0443-\u0442\u043e \u043b\u0438\u043c\u0438\u0442\u0438\u0440\u043e\u0432\u0430\u043d\u043e\u043c\u0443 \u0440\u0435\u0441\u0443\u0440\u0441\u0443 \u0440\u0430\u0437\u043c\u0430\u0437\u0430\u043d \u043c\u0435\u0436\u0434\u0443 \u0440\u0430\u0437\u043d\u044b\u043c\u0438 \u0442\u0430\u0441\u043a\u0430\u043c\u0438. <\/p><\/blockquote>\n<p>  <\/p>\n<pre><code class=\"python\">   # \u043f\u0440\u0435\u0434\u0441\u0442\u0430\u0432\u0438\u043c \u0447\u0442\u043e \u0443 \u043d\u0430\u0441 \u043b\u0438\u043c\u0438\u0442 \u043d\u0430 \u0432\u044b\u0437\u043e\u0432\u044b API \u0433\u0438\u0442\u0445\u0430\u0431\u0430 60 req\/min    # \u043f\u0440\u0438\u0434\u0435\u0442\u0441\u044f \u043f\u043e\u0434\u0435\u043b\u0438\u0442\u044c \u0432\u044b\u0437\u043e\u0432\u044b \u043f\u043e\u0440\u043e\u0432\u043d\u0443    @app.task(rate_limit='30\/m')    def get_github_api1():        ...     @app.task(rate_limit='30\/m')    def get_github_api2():        ...<\/code><\/pre>\n<p>  <\/p>\n<blockquote><p>\u042d\u0442\u043e\u0442 \u043b\u0438\u043c\u0438\u0442 \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u0442\u043e\u043b\u044c\u043a\u043e \u0432\u043d\u0443\u0442\u0440\u0438 \u0432\u043e\u0440\u043a\u0435\u0440\u0430, \u0442\u043e \u0435\u0441\u0442\u044c \u043e\u043d \u043b\u043e\u043a\u0430\u043b\u044c\u043d\u044b\u0439 \u0438 \u0443 \u043a\u0430\u0436\u0434\u043e\u0433\u043e \u0432\u043e\u0440\u043a\u0435\u0440\u0430 \u0441\u0432\u043e\u0439.<\/p><\/blockquote>\n<p>\u200b \u041a\u043e\u043d\u0435\u0447\u043d\u043e, \u043c\u043e\u0436\u043d\u043e \u0435\u0449\u0435 \u0440\u0430\u0437 \u043f\u043e\u0434\u0435\u043b\u0438\u0442\u044c \u043b\u0438\u043c\u0438\u0442, \u0442\u0435\u043f\u0435\u0440\u044c \u0432\u0437\u044f\u0432 \u0432 \u0440\u0430\u0441\u0447\u0435\u0442 \u0435\u0449\u0435 \u0438 \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u043e \u0432\u043e\u0440\u043a\u0435\u0440\u043e\u0432. \u041d\u043e \u0432\u0441\u0435 \u044d\u0442\u043e \u043d\u0430\u0447\u043d\u0435\u0442 \u0440\u0430\u0431\u043e\u0442\u0430\u0442\u044c \u0434\u0438\u043a\u043e \u043d\u0435\u044d\u0444\u0444\u0435\u043a\u0442\u0438\u0432\u043d\u043e, \u0435\u0441\u043b\u0438 \u0442\u0430\u0441\u043a\u0438 \u0431\u0443\u0434\u0443\u0442 \u043f\u0440\u0438\u043b\u0435\u0442\u0430\u0442\u044c \u043d\u0435\u0440\u0430\u0432\u043d\u043e\u043c\u0435\u0440\u043d\u043e, \u043d\u0430\u043f\u0440\u0438\u043c\u0435\u0440 \u0432 \u043a\u0430\u043a\u0443\u044e-\u0442\u043e \u043c\u0438\u043d\u0443\u0442\u0443 \u043c\u044b \u043f\u043e\u043b\u0443\u0447\u0438\u043c 60 \u0432\u044b\u0437\u043e\u0432\u043e\u0432 <code>get_github_api1()<\/code> \u0438 0 \u0432\u044b\u0437\u043e\u0432\u043e\u0432 <code>get_github_api2()<\/code> \u2014 \u0431\u0443\u0434\u0443\u0442 \u0432\u044b\u043f\u043e\u043b\u043d\u0435\u043d\u044b \u0442\u043e\u043b\u044c\u043a\u043e 30 \u0432\u044b\u0437\u043e\u0432\u043e\u0432 \u043f\u0435\u0440\u0432\u043e\u0433\u043e \u0442\u0438\u043f\u0430, \u0445\u043e\u0442\u044f \u043c\u043e\u0433\u043b\u0438 \u0431\u044b \u0431\u044b\u0442\u044c \u0432\u0441\u0435 60. \u041a \u0442\u043e\u043c\u0443 \u0436\u0435 \u043a\u0430\u0436\u0434\u044b\u0439 \u0440\u0430\u0437, \u043a\u0430\u043a \u043f\u043e\u044f\u0432\u0438\u0442\u0441\u044f \u043d\u043e\u0432\u0430\u044f \u0442\u0430\u0441\u043a\u0430, \u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u043d\u0443\u0436\u0435\u043d \u0434\u043e\u0441\u0442\u0443\u043f \u043a \u044d\u0442\u043e\u043c\u0443 \u0440\u0435\u0441\u0443\u0440\u0441\u0443, \u043f\u0440\u0438\u0434\u0435\u0442\u0441\u044f \u0441\u043d\u043e\u0432\u0430 \u0432\u0435\u0437\u0434\u0435 \u043f\u0435\u0440\u0435\u0441\u0447\u0438\u0442\u044b\u0432\u0430\u0442\u044c \u0432\u0441\u0435 \u043b\u0438\u043c\u0438\u0442\u044b. \u0412\u043e\u0431\u0449\u0435\u043c \u0444\u0438\u0447\u0430 \u043a\u043e\u043d\u0435\u0447\u043d\u043e \u043f\u043e\u043b\u0435\u0437\u043d\u0430\u044f, \u043d\u043e \u0442\u043e\u043b\u044c\u043a\u043e \u0434\u043b\u044f \u0441\u0430\u043c\u044b\u0445 \u043f\u0440\u043e\u0441\u0442\u044b\u0445 \u0432\u0430\u0440\u0438\u0430\u043d\u0442\u043e\u0432.<\/p>\n<p>  <\/p>\n<h2 id=\"bringing-decision\">Bringing decision<\/h2>\n<p>  <\/p>\n<h4 id=\"token-bucket\">Token Bucket<\/h4>\n<p>  <\/p>\n<p>\u200b \u0420\u0435\u0448\u0435\u043d\u0438\u0435\u043c \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u044b \u0434\u043b\u044f \u043c\u0435\u043d\u044f \u0441\u0442\u0430\u043b <a href=\"https:\/\/en.wikipedia.org\/wiki\/Token_bucket\" rel=\"nofollow\">Token Bucket<\/a> \u2014 \u0430\u043b\u0433\u043e\u0440\u0438\u0442\u043c, \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044e\u0449\u0438\u0439\u0441\u044f \u0434\u043b\u044f \u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044f \u043f\u043e\u043b\u043e\u0441\u044b \u043f\u0440\u043e\u043f\u0443\u0441\u043a\u0430\u043d\u0438\u044f \u043a\u0430\u043d\u0430\u043b\u0430 \u0432 \u043a\u043e\u043c\u043f\u044c\u044e\u0442\u0435\u0440\u043d\u044b\u0445 \u0438 \u0442\u0435\u043b\u0435\u043a\u043e\u043c\u0443\u043d\u0438\u043a\u0430\u0446\u0438\u043e\u043d\u043d\u044b\u0445 \u0441\u0435\u0442\u044f\u0445. \u041e\u043f\u0438\u0448\u0443 \u0435\u0433\u043e \u0432 2\u0443\u0445 \u0441\u043b\u043e\u0432\u0430\u0445: \u043f\u0430\u043a\u0435\u0442 \u0434\u0430\u043d\u043d\u044b\u0445, \u0447\u0442\u043e\u0431\u044b \u043f\u0440\u043e\u0439\u0442\u0438 \u043f\u0440\u043e\u0432\u0435\u0440\u043a\u0443 \u043a\u0430\u043d\u0430\u043b\u0430 \u043d\u0430 \u043b\u0438\u043c\u0438\u0442, \u0434\u043e\u043b\u0436\u0435\u043d \u0438\u043c\u0435\u0442\u044c \u043f\u0440\u0438 \u0441\u0435\u0431\u0435 \u0442\u043e\u043a\u0435\u043d, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043e\u043d \u0432\u0437\u044f\u043b \u0438\u0437 \u0445\u0440\u0430\u043d\u0438\u043b\u0438\u0449\u0430; \u0432 \u0442\u043e \u0436\u0435 \u0432\u0440\u0435\u043c\u044f \u0432 \u0445\u0440\u0430\u043d\u0438\u043b\u0438\u0449\u0435 \u0442\u043e\u043a\u0435\u043d\u044b \u043f\u043e\u0441\u0442\u0443\u043f\u0430\u044e\u0442 \u0441 \u043d\u0435\u043a\u043e\u0442\u043e\u0440\u043e\u0439 \u0447\u0430\u0441\u0442\u043e\u0442\u043e\u0439. \u0422\u043e \u0435\u0441\u0442\u044c \u043f\u0440\u043e\u043f\u0443\u0441\u043a\u043d\u0430\u044f \u0441\u043f\u043e\u0441\u043e\u0431\u043e\u043d\u043e\u0441\u0442\u044c \u043a\u0430\u043d\u0430\u043b\u0430 \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0438\u0432\u0430\u0435\u0442\u0441\u044f \u0441\u043a\u043e\u0440\u043e\u0441\u0442\u044c\u044e \u0432\u044b\u043f\u0443\u0441\u043a\u0430 \u0442\u043e\u043a\u0435\u043d\u043e\u0432, \u043a\u043e\u0442\u043e\u0440\u0443\u044e \u043d\u0430\u043c \u0438 \u043d\u0430\u0434\u043e \u0440\u0435\u0433\u0443\u043b\u0438\u0440\u043e\u0432\u0430\u0442\u044c.<br \/>  \u200b \u0412 \u043d\u0430\u0448\u0435\u043c \u0436\u0435 \u0441\u043b\u0443\u0447\u0430\u0435 \u0432\u043c\u0435\u0441\u0442\u043e \u043f\u0430\u043a\u0435\u0442\u0430 \u0434\u0430\u043d\u043d\u044b\u0445 \u043c\u044b \u0438\u043c\u0435\u0435\u043c \u0442\u0430\u0441\u043a\u0443, \u0430 \u0445\u0440\u0430\u043d\u0438\u043b\u0438\u0449\u0435\u043c \u0442\u043e\u043a\u0435\u043d\u043e\u0432 \u0431\u0443\u0434\u0443\u0442 \u0432\u044b\u0441\u0442\u0443\u043f\u0430\u0442\u044c \u043e\u0447\u0435\u0440\u0435\u0434\u0438 RabbitMQ.<\/p>\n<p>  <\/p>\n<p><img decoding=\"async\" src=\"https:\/\/habrastorage.org\/webt\/z4\/ca\/3h\/z4ca3hrv549fh-gyoemrxeszpnm.png\" alt=\"Token Bucket\"><\/p>\n<p>  <\/p>\n<h4 id=\"wrting-some-code\">Wrting some code<\/h4>\n<p>  <\/p>\n<p>\u0427\u0442\u043e\u0436, \u043f\u0440\u0438\u0441\u0442\u0443\u043f\u0438\u043c \u043a \u043d\u0430\u043f\u0438\u0441\u0430\u043d\u0438\u044e \u043a\u043e\u0434\u0430. \u0421\u043e\u0437\u0434\u0430\u0434\u0438\u043c \u0444\u0430\u0439\u043b <code>main.py<\/code> \u0438 \u0437\u0430\u0434\u0430\u0434\u0438\u043c \u0431\u0430\u0437\u043e\u0432\u044b\u0435 \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0438:<\/p>\n<p>  <\/p>\n<pre><code class=\"python\">from celery import Celery from kombu import Queue  app = Celery('Test app', broker='amqp:\/\/guest@localhost\/\/')  # 1 \u043e\u0447\u0435\u0440\u0435\u0434\u044c \u043f\u043e\u0434 \u0441\u0430\u043c\u0438 \u0442\u0430\u0441\u043a\u0438 \u0438 1 \u043e\u0447\u0435\u0440\u0435\u0434\u044c \u043f\u043e\u0434 \u0442\u043e\u043a\u0435\u043d\u044b \u0434\u043b\u044f \u043d\u0438\u0445 app.conf.task_queues = [     Queue('github'),     # \u044f \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0438\u043b \u0434\u043b\u0438\u043d\u0443 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 \u0434\u043e 2\u0443\u0445, \u0447\u0442\u043e\u0431\u044b \u0442\u043e\u043a\u0435\u043d\u044b \u043d\u0435 \u0441\u043a\u0430\u043f\u043b\u0438\u0432\u0430\u043b\u0438\u0441\u044c     # \u0438\u043d\u0430\u0447\u0435 \u044d\u0442\u043e \u043c\u043e\u0436\u0435\u0442 \u043f\u0440\u0438\u0432\u0435\u0441\u0442\u0438 \u043a \u043f\u0440\u043e\u0431\u043e\u044e \u043d\u0430\u0448\u0435\u0433\u043e rate limit'a     Queue('github_tokens', max_length=2) ]  # \u044d\u0442\u043e \u0442\u0430\u0441\u043a\u0430 \u0431\u0443\u0434\u0435\u0442 \u0438\u0433\u0440\u0430\u0442\u044c \u0440\u043e\u043b\u044c \u043d\u0430\u0448\u0435\u0433\u043e \u0442\u043e\u043a\u0435\u043d\u0430 # \u043e\u043d\u0430 \u043d\u0438\u043a\u043e\u0433\u0434\u0430 \u043d\u0435 \u0431\u0443\u0434\u0435\u0442 \u0437\u0430\u043f\u0443\u0449\u0435\u043d\u0430, \u043c\u044b \u043f\u0440\u043e\u0441\u0442\u043e \u0431\u0443\u0434\u0435\u043c \u0437\u0430\u0431\u0438\u0440\u0430\u0442\u044c \u0435\u0435 \u043a\u0430\u043a \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u0435 \u0438\u0437 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 @app.task def token():     return 1  # \u043d\u0430\u0441\u0442\u0440\u0430\u0438\u0432\u0430\u0435\u043c \u043f\u043e\u0441\u0442\u043e\u044f\u043d\u043d\u044b\u0439 \u0432\u044b\u043f\u0443\u0441\u043a \u043d\u0430\u0448\u0435\u0433\u043e \u0442\u043e\u043a\u0435\u043d\u0430 @app.on_after_configure.connect def setup_periodic_tasks(sender, **kwargs):     # \u043c\u044b \u0431\u0443\u0434\u0435\u043c \u0432\u044b\u043f\u0443\u0441\u043a\u0430\u0442\u044c \u043f\u043e 1\u043c\u0443 \u0442\u043e\u043a\u0435\u043d\u0443 \u0432 \u0441\u0435\u043a\u0443\u043d\u0434\u0443     # \u044d\u0442\u043e \u0437\u043d\u0430\u0447\u0438\u0442 \u0447\u0442\u043e rate limit \u0434\u043b\u044f \u043e\u0447\u0435\u0440\u0435\u0434\u0438 github - 60 \u0437\u0430\u0434\u0430\u0447 \u0432 \u043c\u0438\u043d\u0443\u0442\u0443     sender.add_periodic_task(1.0, token.signature(queue='github_tokens'))<\/code><\/pre>\n<p>  <\/p>\n<p>\u041d\u0435 \u0437\u0430\u0431\u0443\u0434\u044c\u0442\u0435 \u0440\u0430\u0437\u0432\u0435\u0440\u043d\u0443\u0442\u044c Rabbit, \u044f \u043f\u0440\u0435\u0434\u043f\u043e\u0447\u0438\u0442\u0430\u044e \u0434\u0435\u043b\u0430\u0442\u044c \u044d\u0442\u043e 1\u043e\u0439 \u0441\u0442\u0440\u043e\u0447\u043a\u043e\u0439 \u0434\u043e\u043a\u0435\u0440\u0430:<\/p>\n<p>  <\/p>\n<pre><code class=\"bash\">docker run -d --rm --name rabbit -p 15672:15672 -p 5672:5672 rabbitmq:3-management<\/code><\/pre>\n<p>  <\/p>\n<p>\u0422\u0435\u043f\u0435\u0440\u044c \u0437\u0430\u043f\u0443\u0441\u0442\u0438\u043c <code>celery beat<\/code> \u2014 \u044d\u0442\u043e \u0441\u043f\u0435\u0446\u0438\u0430\u043b\u044c\u043d\u044b\u0439 \u0432\u043e\u0440\u043a\u0435\u0440 <code>celery<\/code>, \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u043c\u044b\u0439 \u0432\u0441\u0435\u0433\u0434\u0430 \u0432 \u0435\u0434\u0438\u043d\u0441\u0442\u0432\u0435\u043d\u043d\u043e\u043c \u044d\u043a\u0437\u0435\u043c\u043f\u043b\u044f\u0440\u0435 \u0438 \u043e\u0442\u0432\u0435\u0447\u0430\u044e\u0449\u0438\u0439 \u0437\u0430 \u0437\u0430\u043f\u0443\u0441\u043a \u043f\u0435\u0440\u0438\u043e\u0434\u0438\u0447\u0435\u0441\u043a\u0438\u0445 \u0437\u0430\u0434\u0430\u0447.<\/p>\n<p>  <\/p>\n<pre><code class=\"bash\">celery -A main beat --loglevel=info<\/code><\/pre>\n<p>  <\/p>\n<p>\u041f\u043e\u0441\u043b\u0435 \u044d\u0442\u043e\u0433\u043e \u0432 \u043a\u043e\u043d\u0441\u043e\u043b\u0438 \u0440\u0430\u0437 \u0432 \u0441\u0435\u043a\u0443\u043d\u0434\u0443 \u043d\u0430\u0447\u043d\u0443\u0442 \u043f\u043e\u044f\u0432\u043b\u044f\u0442\u044c\u0441\u044f \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f:<\/p>\n<p>  <\/p>\n<pre><code class=\"bash\">[2020-03-22 22:49:00,992: INFO\/MainProcess] Scheduler: Sending due task main.token() (main.token)<\/code><\/pre>\n<p>  <\/p>\n<p>\u041e\u0442\u043b\u0438\u0447\u043d\u043e, \u043c\u044b \u043d\u0430\u043b\u0430\u0434\u0438\u043b\u0438 \u0432\u044b\u043f\u0443\u0441\u043a \u0442\u043e\u043a\u0435\u043d\u043e\u0432 \u0434\u043b\u044f \u043d\u0430\u0448\u0435\u0433\u043e &#8216;\u0432\u0435\u0434\u0440\u0430&#8217;. \u041e\u0441\u0442\u0430\u043b\u043e\u0441\u044c \u0442\u043e\u043b\u044c\u043a\u043e \u043d\u0430\u0443\u0447\u0438\u0442\u044c \u043d\u0430\u0448\u0438\u0445 \u0432\u043e\u0440\u043a\u0435\u0440\u043e\u0432 \u0438\u0437 \u043d\u0435\u0433\u043e \u0431\u0440\u0430\u0442\u044c. \u041f\u043e\u043f\u0440\u043e\u0431\u0443\u0435\u043c \u043e\u043f\u0442\u0438\u043c\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u043a\u043e\u0434, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u043c\u044b \u043d\u0430\u043f\u0438\u0441\u0430\u043b\u0438 \u0440\u0430\u043d\u0435\u0435 \u0434\u043b\u044f \u0437\u0430\u043f\u0440\u043e\u0441\u043e\u0432 \u0432 github. \u0414\u043e\u0431\u0430\u0432\u0438\u043c \u044d\u0442\u0438 \u0441\u0442\u0440\u043e\u0447\u043a\u0438 \u043a <code>main.py<\/code>:<\/p>\n<p>  <\/p>\n<pre><code class=\"python\"># \u041d\u0430\u043f\u0438\u0448\u0435\u043c \u0444\u0443\u043d\u043a\u0446\u0438\u044e \u0434\u043b\u044f \u0432\u0437\u044f\u0442\u0438\u044f \u0442\u043e\u043a\u0435\u043d\u0430 \u0438\u0437 \u043e\u0447\u0435\u0440\u0435\u0434\u0438 def rate_limit(task, task_group):     # \u0431\u0435\u0440\u0435\u043c \u0441\u043e\u0435\u0434\u0438\u043d\u0435\u043d\u0438\u0435 \u0441 \u0431\u0440\u043e\u043a\u0435\u0440\u043e\u043c \u0438\u0437 \u043f\u0443\u043b\u0430     with task.app.connection_for_read() as conn:         # \u0437\u0430\u0431\u0438\u0440\u0430\u0435\u043c \u0442\u043e\u043a\u0435\u043d         msg = conn.default_channel.basic_get(task_group+'_tokens', no_ack=True)         # \u043f\u043e\u043b\u0443\u0447\u0438\u043b\u0438 None - \u043e\u0447\u0435\u0440\u0435\u0434\u044c \u043f\u0443\u0441\u0442\u0430, \u0442\u043e\u043a\u0435\u043d\u043e\u0432 \u043d\u0435\u0442         if msg is None:             # \u043f\u043e\u0432\u0442\u043e\u0440\u0438\u0442\u044c \u0442\u0430\u0441\u043a\u0443 \u0447\u0435\u0440\u0435\u0437 1 \u0441\u0435\u043a             task.retry(countdown=1)  # \u0414\u043e\u0431\u0430\u0432\u0438\u043c print \u0432 \u0442\u0430\u0441\u043a\u0438 \u0434\u043b\u044f \u043b\u043e\u0433\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u044f # \u0417\u0434\u0435\u0441\u044c \u044f \u043f\u043e\u0441\u0442\u0430\u0432\u0438\u043b max_retries=None, \u0442\u0430\u043a \u0447\u0442\u043e \u0442\u0430\u0441\u043a\u0438 \u0431\u0443\u0434\u0443\u0442 # \u043f\u043e\u0432\u0442\u043e\u0440\u044f\u0442\u044c\u0441\u044f, \u043f\u043e\u043a\u0430 \u043d\u0435 \u0431\u0443\u0434\u0443\u0442 \u0432\u044b\u043f\u043e\u043b\u043d\u0435\u043d\u044b @app.task(bind=True) def get_github_api1(self, max_retries=None):     rate_limit(self, 'github')     print ('Called Api 1')  @app.task(bind=True) def get_github_api2(self, max_retries=None):     rate_limit(self, 'github')     print ('Called Api 2')<\/code><\/pre>\n<p>  <\/p>\n<p>\u0410 \u0442\u0435\u043f\u0435\u0440\u044c \u043f\u0440\u043e\u0432\u0435\u0440\u0438\u043c, \u043a\u0430\u043a \u044d\u0442\u043e \u0432\u0441\u0435 \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442. \u0412 \u0434\u043e\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u0435 \u043a \u0443\u0436\u0435 \u0437\u0430\u043f\u0443\u0449\u0435\u043d\u043d\u043e\u043c\u0443 <code>beat<\/code> \u0434\u043e\u0431\u0430\u0432\u0438\u043c 8 \u0432\u043e\u0440\u043a\u0435\u0440\u043e\u0432:<\/p>\n<p>  <\/p>\n<pre><code class=\"bash\">celery -A main worker -\u0441 8 -Q github<\/code><\/pre>\n<p>  <\/p>\n<p>\u0418 \u0441\u043e\u0437\u0434\u0430\u0434\u0438\u043c \u043e\u0442\u0434\u0435\u043b\u044c\u043d\u044b\u0439 \u043c\u0430\u043b\u0435\u043d\u044c\u043a\u0438\u0439 \u0441\u043a\u0440\u0438\u043f\u0442 \u0434\u043b\u044f \u0437\u0430\u043f\u0443\u0441\u043a\u0430 \u044d\u0442\u0438\u0445 \u0437\u0430\u0434\u0430\u0447, \u043d\u0430\u0437\u043e\u0432\u0435\u043c \u0435\u0433\u043e <code>producer.py<\/code>:<\/p>\n<p>  <\/p>\n<pre><code class=\"python\">from main import get_github_api1, get_github_api2  tasks = [get_github_api1, get_github_api2]  for  i in range(100):     # \u0437\u0430\u043f\u0443\u0441\u043a\u0430\u044e \u0442\u0430\u0441\u043a\u0438 \u0432 \u043f\u0435\u0440\u0435\u043c\u0435\u0448\u043a\u0443     tasks[i % 2].apply_async(queue='github')<\/code><\/pre>\n<p>  <\/p>\n<p>\u0417\u0430\u043f\u0443\u0441\u043a\u0430\u0435\u043c \u2014 <code>python producer.py<\/code>, \u0438 \u0441\u043c\u043e\u0442\u0440\u0438\u043c \u0432 \u043b\u043e\u0433\u0438 \u0432\u043e\u0440\u043a\u0435\u0440\u043e\u0432:<\/p>\n<p>  <\/p>\n<pre><code class=\"bash\">[2020-03-23 13:04:15,017: WARNING\/ForkPoolWorker-3] Called Api 2 [2020-03-23 13:04:16,053: WARNING\/ForkPoolWorker-8] Called Api 2 [2020-03-23 13:04:17,112: WARNING\/ForkPoolWorker-1] Called Api 2 [2020-03-23 13:04:18,187: WARNING\/ForkPoolWorker-1] Called Api 1 ... (96 more lines)<\/code><\/pre>\n<p>  <\/p>\n<p>\u041d\u0435\u0441\u043c\u043e\u0442\u0440\u044f \u043d\u0430 \u0442\u043e, \u0447\u0442\u043e \u0443 \u043d\u0430\u0441 \u0446\u0435\u043b\u044b\u0445 8 \u0440\u0430\u0431\u043e\u0447\u0438\u0445 \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u043e\u0432, \u0442\u0430\u0441\u043a\u0438 \u0432\u044b\u043f\u043e\u043b\u043d\u044f\u044e\u0442\u0441\u044f \u043f\u0440\u0438\u043c\u0435\u0440\u043d\u043e \u0440\u0430\u0437 \u0432 \u0441\u0435\u043a\u0443\u043d\u0434\u0443, \u043e\u0442\u043f\u0440\u0430\u0432\u043b\u044f\u044f\u0441\u044c \u0432 \u043a\u043e\u043d\u0435\u0446 \u043e\u0447\u0435\u0440\u0435\u0434\u0438, \u0435\u0441\u043b\u0438 \u043d\u0430 \u043c\u043e\u043c\u0435\u043d\u0442 \u0438\u0445 \u0432\u044b\u043f\u043e\u043b\u043d\u0435\u043d\u0438\u044f \u043d\u0435 \u043e\u043a\u0430\u0437\u0430\u043b\u043e\u0441\u044c \u0442\u043e\u043a\u0435\u043d\u0430. \u0422\u0430\u043a\u0436\u0435, \u044f \u0434\u0443\u043c\u0430\u044e, \u0432\u044b \u0443\u0436\u0435 \u0437\u0430\u043c\u0435\u0442\u0438\u043b\u0438, \u0447\u0442\u043e \u043d\u0430 \u0441\u0430\u043c\u043e\u043c \u0434\u0435\u043b\u0435 \u043c\u044b \u043d\u0430\u043a\u043b\u0430\u0434\u044b\u0432\u0430\u0435\u043c rate limit \u043d\u0435 \u0441\u043e\u0432\u0441\u0435\u043c \u043d\u0430 \u043e\u0447\u0435\u0440\u0435\u0434\u044c, \u0430 \u0441\u043a\u043e\u0440\u0435\u0435 \u043d\u0430 \u043a\u0430\u043a\u0443\u044e-\u0442\u043e \u043b\u043e\u0433\u0438\u0447\u0435\u0441\u043a\u0438 \u0441\u0432\u044f\u0437\u0430\u043d\u043d\u0443\u044e \u0433\u0440\u0443\u043f\u043f\u0443 \u0437\u0430\u0434\u0430\u0447, \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043d\u0430 \u0441\u0430\u043c\u043e\u043c \u0434\u0435\u043b\u0435 \u043c\u043e\u0433\u0443\u0442 \u043d\u0430\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u043a\u0430\u043a \u0432 \u0440\u0430\u0437\u043d\u044b\u0445 \u043e\u0447\u0435\u0440\u0435\u0434\u044f\u0445, \u0442\u0430\u043a \u0438 \u0432 \u043e\u0434\u043d\u043e\u0439. \u0422\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c \u043d\u0430\u0448 <u>\u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044c \u0441\u0442\u0430\u043d\u043e\u0432\u0438\u0442\u0441\u044f \u0434\u0430\u0436\u0435 \u0431\u043e\u043b\u0435\u0435 \u0434\u0435\u0442\u0430\u043b\u044c\u043d\u044b\u043c \u0438 \u0433\u0440\u0430\u043d\u0443\u043b\u0438\u0440\u043e\u0432\u0430\u043d\u043d\u044b\u043c<\/u>.<\/p>\n<p>  <\/p>\n<h4 id=\"putting-it-all-together\">Putting it all together<\/h4>\n<p>  <\/p>\n<p>\u200b \u041a\u043e\u043d\u0435\u0447\u043d\u043e, \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u043e \u0442\u0430\u043a\u0438\u0445 \u0433\u0440\u0443\u043f\u043f \u0437\u0430\u0434\u0430\u0447 \u043d\u0435 \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d\u043e (\u0440\u0430\u0437\u0432\u0435 \u0447\u0442\u043e \u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e\u0441\u0442\u044f\u043c\u0438 \u0431\u0440\u043e\u043a\u0435\u0440\u0430). \u0421\u043e\u0431\u0435\u0440\u0435\u043c \u0432\u0435\u0441\u044c \u043a\u043e\u0434 \u0432 \u043a\u0443\u0447\u043a\u0443, \u0440\u0430\u0441\u0448\u0438\u0440\u0438\u043c \u0438 \u043f\u0440\u0438\u0447\u0435\u0448\u0438\u043c \u0435\u0433\u043e:<\/p>\n<p>  <\/p>\n<pre><code class=\"python\">from celery import Celery from kombu import Queue from queue import Empty from functools import wraps  app = Celery('hello', broker='amqp:\/\/guest@localhost\/\/')  task_queues = [     Queue('github'),     Queue('google') ]  # \u043a\u043e\u043b\u0438\u0447\u0435\u0441\u0442\u0432\u043e \u0437\u0430\u043f\u0443\u0441\u043a\u043e\u0432 \u0432 \u043c\u0438\u043d\u0443\u0442\u0443 rate_limits = {     'github': 60,     'google': 100 }  # \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u0441\u0433\u0435\u043d\u0435\u0440\u0438\u0440\u0443\u0435\u043c \u043e\u0447\u0435\u0440\u0435\u0434\u0438 \u0441 \u0442\u043e\u043a\u0435\u043d\u0430\u043c\u0438 \u043f\u043e\u0434 \u0432\u0441\u0435 \u0433\u0440\u0443\u043f\u043f\u044b, \u043d\u0430 \u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u043d\u0443\u0436\u0435\u043d \u043b\u0438\u043c\u0438\u0442 task_queues += [Queue(name+'_tokens', max_length=2) for name, limit in rate_limits.items()]  app.conf.task_queues = task_queues  @app.task def token():     return 1  @app.on_after_configure.connect def setup_periodic_tasks(sender, **kwargs):     # \u0430\u0432\u0442\u043e\u043c\u0430\u0442\u0438\u0447\u0435\u0441\u043a\u0438 \u043d\u0430\u0441\u0442\u0440\u043e\u0438\u043c \u0432\u044b\u043f\u0443\u0441\u043a \u0442\u043e\u043a\u0435\u043d\u043e\u0432 \u0441 \u043d\u0443\u0436\u043d\u043e\u0439 \u0441\u043a\u043e\u0440\u043e\u0441\u0442\u044c\u044e     for name, limit in rate_limits.items():         sender.add_periodic_task(60 \/ limit, token.signature(queue=name+'_tokens'))  # \u041a\u0430\u043a \u043c\u043e\u0436\u043d\u043e \u043d\u0435 \u043b\u044e\u0431\u0438\u0442\u044c \u0434\u0435\u043a\u043e\u0440\u0430\u0442\u043e\u0440\u044b? def rate_limit(task_group):     def decorator_func(func):         @wraps(func)         def function(self, *args, **kwargs):             with self.app.connection_for_read() as conn:                 # \u0442\u0443\u0442 \u044f \u0434\u043b\u044f \u043f\u0440\u0438\u043c\u0435\u0440\u0430 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043b \u0434\u0440\u0443\u0433\u043e\u0439 \u0431\u043e\u043b\u0435\u0435 \u0432\u044b\u0441\u043e\u043a\u043e\u0443\u0440\u043e\u0432\u043d\u0435\u0432\u044b\u0439 \u043f\u043e\u0434\u0445\u043e\u0434:                 # \u0432 \u0437\u0430\u043c\u0435\u043d \u043d\u0430 \u043f\u043e\u043b\u0443\u0447\u0435\u043d\u0438\u0435 \u043f\u043e\u043b\u043d\u043e\u0446\u0435\u043d\u043d\u043e\u0433\u043e \u0438\u043d\u0442\u0435\u0440\u0444\u0435\u0439\u0441\u0430 \u043e\u0447\u0435\u0440\u0435\u0434\u0438                 # \u043c\u044b \u043d\u0435\u043c\u043d\u043e\u0433\u043e \u0442\u0435\u0440\u044f\u0435\u043c \u0432 \u043f\u0435\u0440\u0444\u043e\u043c\u0430\u043d\u0441\u0435, \u0442.\u043a \u043f\u043e\u0434 \u043a\u0430\u043f\u043e\u0442\u043e\u043c \u043f\u0440\u043e\u0438\u0441\u0445\u043e\u0434\u0438\u0442 \u043e\u0431\u043c\u0435\u043d                 # \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u043c\u0438 \u0441\u043e\u043e\u0431\u0449\u0435\u043d\u0438\u044f\u043c\u0438 \u0441 \u0431\u0440\u043e\u043a\u0435\u0440\u043e\u043c                 with conn.SimpleQueue(task_group+'_tokens', no_ack=True, queue_opts={'max_length':2}) as queue:                     try:                         # \u0438\u0437 \u043f\u043b\u044e\u0441\u043e\u0432 \u0442\u0430\u043a\u0436\u0435 - \u043d\u0430\u043b\u0438\u0447\u0438\u0435 \u0432\u043e\u0442 \u0442\u0430\u043a\u043e\u0433\u043e \u0431\u043b\u043e\u043a\u0438\u0440\u0443\u044e\u0449\u0435\u0433\u043e \u0432\u044b\u0437\u043e\u0432\u0430                         # \u044d\u0442\u043e \u043c\u043e\u0436\u0435\u0442 \u0431\u044b\u0442\u044c \u0443\u0434\u043e\u0431\u043d\u0435\u0435, \u0447\u0435\u043c \u043f\u043e\u0441\u0442\u043e\u044f\u043d\u043d\u0430\u044f \u0440\u043e\u0442\u0430\u0446\u0438\u044f \u0441 retry()                         # \u0432\u043f\u0440\u043e\u0447\u0435\u043c, \u044d\u0442\u043e \u043d\u0443\u0436\u043d\u043e \u043f\u043e\u0434\u0431\u0438\u0440\u0430\u0442\u044c \u043f\u043e\u0434 \u043a\u0435\u0439\u0441                         queue.get(block=True, timeout=5)                         return func(self, *args, **kwargs)                     except Empty:                         self.retry(countdown=1)         return function     return decorator_func  # \u0441 \u0434\u0435\u043a\u043e\u0440\u0430\u0442\u043e\u0440\u0430\u043c\u0438 \u0432\u0441\u0435-\u0442\u0430\u043a\u0438 \u043d\u0430\u043c\u043d\u043e\u0433\u043e \u043a\u0440\u0430\u0441\u0438\u0432\u0435\u0435 \u0438 \u0447\u0438\u0442\u0430\u0431\u0435\u043b\u044c\u043d\u0435\u0435, \u0441\u043e\u0433\u043b\u0430\u0441\u0438\u0442\u0435\u0441\u044c? ;) @app.task(bind=True, max_retries=None) @rate_limit('github') def get_github_api1(self):     print ('Called github Api 1')  @app.task(bind=True, max_retries=None) @rate_limit('github') def get_github_api2(self):     print ('Called github Api 2')  @app.task(bind=True, max_retries=None) @rate_limit('google') def query_google_api1(self):     print ('Called Google Api 1')  @app.task(bind=True, max_retries=None) @rate_limit('google') def query_google_api1(self):     print ('Called Google Api 2')<\/code><\/pre>\n<p>  <\/p>\n<p>\u0422\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c \u0441\u0443\u043c\u043c\u0430\u0440\u043d\u044b\u0435 \u0432\u044b\u0437\u043e\u0432\u044b \u0437\u0430\u0434\u0430\u0447 \u0433\u0440\u0443\u043f\u043f\u044b <code>google<\/code> \u043d\u0435 \u043f\u0440\u0435\u0432\u044b\u0441\u044f\u0442 100\/\u043c\u0438\u043d, \u0430 \u0433\u0440\u0443\u043f\u043f\u044b <code>github<\/code> \u2014 60\/\u043c\u0438\u043d. \u0417\u0430\u043c\u0435\u0442\u044c\u0442\u0435, \u0447\u0442\u043e \u0434\u043b\u044f \u0442\u043e\u0433\u043e, \u0447\u0442\u043e\u0431\u044b \u043d\u0430\u0441\u0442\u0440\u043e\u0438\u0442\u044c \u0442\u0430\u043a\u043e\u0439 throttling, <strong>\u043f\u043e\u043d\u0430\u0434\u043e\u0431\u0438\u043b\u043e\u0441\u044c \u043c\u0435\u043d\u044c\u0448\u0435 50 \u0441\u0442\u0440\u043e\u043a<\/strong>. \u041a\u0430\u043a \u043f\u043e \u043c\u043d\u0435, \u0434\u043e\u0441\u0442\u0430\u0442\u043e\u0447\u043d\u043e \u043f\u0440\u043e\u0441\u0442\u043e.<\/p>\n<p>  <\/p>\n<h2 id=\"moving-further\">Moving further<\/h2>\n<p>  <\/p>\n<p>\u200b \u041d\u0443, \u0432\u043e\u0442 \u0432\u0441\u0435 \u0438 \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u0442 \u043a\u0430\u043a \u043d\u0430\u0434\u043e, \u043f\u0440\u0438\u0447\u0435\u043c<strong> \u0431\u0435\u0437 \u043a\u0430\u043a\u0438\u0445-\u043b\u0438\u0431\u043e \u0441\u0442\u043e\u0440\u043e\u043d\u043d\u0438\u0445 \u043f\u0440\u0438\u043c\u043e\u0447\u0435\u043a, \u0441\u0440\u0435\u0434\u0441\u0442\u0432\u0430\u043c\u0438 \u0442\u043e\u043b\u044c\u043a\u043e \u0441\u0430\u043c\u043e\u0433\u043e \u0431\u0440\u043e\u043a\u0435\u0440\u0430<\/strong>. \u041d\u043e \u0437\u0430\u0447\u0435\u043c \u043e\u0441\u0442\u0430\u043d\u0430\u0432\u043b\u0438\u0432\u0430\u0442\u044c\u0441\u044f \u043d\u0430 \u0434\u043e\u0441\u0442\u0438\u0433\u043d\u0443\u0442\u043e\u043c ;)? \u0413\u0440\u0430\u043c\u043e\u0442\u043d\u043e \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044f \u0434\u0430\u043d\u043d\u044b\u0439 \u0430\u043b\u0433\u043e\u0440\u0438\u0442\u043c, \u043c\u043e\u0436\u043d\u043e \u043f\u043e\u0439\u0442\u0438 \u0434\u0430\u043b\u044c\u0448\u0435 \u0438 \u0441\u043e\u0437\u0434\u0430\u0442\u044c \u043d\u0430\u043c\u043d\u043e\u0433\u043e \u0431\u043e\u043b\u0435\u0435 \u0441\u043b\u043e\u0436\u043d\u044b\u0435 \u0438 \u0433\u0438\u0431\u043a\u0438\u0435 \u0441\u0442\u0440\u0430\u0442\u0435\u0433\u0438\u0438. \u041d\u0430\u043f\u0440\u0438\u043c\u0435\u0440, \u043d\u0435\u043a\u043e\u0442\u043e\u0440\u044b\u0435 \u0442\u0430\u0441\u043a\u0438 \u043c\u043e\u0433\u0443\u0442 \u0431\u0440\u0430\u0442\u044c \u043d\u0435 1, \u0430 \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u043e \u0442\u043e\u043a\u0435\u043d\u043e\u0432 (\u0432\u043e\u0437\u043c\u043e\u0436\u043d\u043e \u0434\u0430\u0436\u0435 \u0438\u0437 \u0440\u0430\u0437\u043d\u044b\u0445 \u043e\u0447\u0435\u0440\u0435\u0434\u0435\u0439, \u0435\u0441\u043b\u0438 \u043e\u0431\u0440\u0430\u0449\u0435\u043d\u0438\u0435 \u0438\u0434\u0435\u0442 \u043a \u043d\u0435\u0441\u043a\u043e\u043b\u044c\u043a\u0438\u043c \u0441\u0435\u0440\u0432\u0438\u0441\u0430\u043c), \u0442\u0430\u043a\u0438\u043c \u043e\u0431\u0440\u0430\u0437\u043e\u043c \u0443 \u043d\u0430\u0441 \u043f\u043e\u044f\u0432\u0438\u0442\u0441\u044f \u043f\u043e\u043d\u044f\u0442\u0438\u0435 &#8216;\u0432\u0435\u0441\u0430&#8217; \u0437\u0430\u0434\u0430\u0447\u0438, \u0438\u043b\u0438 \u0436\u0435 \u0440\u0430\u0441\u0448\u0438\u0440\u0438\u0442\u044c \u0440\u0430\u0437\u043c\u0435\u0440 \u043d\u0430\u0448\u0435\u0433\u043e &#8216;\u0432\u0435\u0434\u0440\u0430&#8217; \u0442\u043e\u043a\u0435\u043d\u043e\u0432, \u043f\u043e\u0437\u0432\u043e\u043b\u0438\u0432 \u0438\u043c \u043d\u0430\u043a\u0430\u043f\u043b\u0438\u0432\u0430\u0442\u044c\u0441\u044f, \u0442\u0435\u043c \u0441\u0430\u043c\u044b\u043c \u043a\u043e\u043c\u043f\u0435\u043d\u0441\u0438\u0440\u0443\u044f \u043f\u0435\u0440\u0438\u043e\u0434\u044b \u043f\u0440\u043e\u0441\u0442\u043e\u044f. \u0412\u043e\u0431\u0449\u0435\u043c, <strong>\u043f\u0440\u043e\u0441\u0442\u0440\u0430\u043d\u0441\u0442\u0432\u043e \u0434\u043b\u044f \u043c\u0430\u043d\u0435\u0432\u0440\u0430 \u043f\u0440\u043e\u0441\u0442\u043e \u043e\u0433\u0440\u043e\u043c\u043d\u043e\u0435 \u0438 \u043e\u0433\u0440\u0430\u043d\u0438\u0447\u0435\u043d\u043e \u0442\u043e\u043b\u044c\u043a\u043e \u0432\u0430\u0448\u0438\u043c \u0432\u043e\u043e\u0431\u0440\u0430\u0436\u0435\u043d\u0438\u0435\u043c<\/strong> \u0438 \u0438\u043d\u0436\u0435\u043d\u0435\u0440\u043d\u044b\u043c\u0438 \u043d\u0430\u0432\u044b\u043a\u0430\u043c\u0438) \u0412\u0441\u0435\u043c \u0441\u043f\u0430\u0441\u0438\u0431\u043e, \u0432\u0441\u0435\u043c \u0443\u0434\u0430\u0447\u0438!<\/p>\n<p>  <\/p>\n<p>P.s. \u041f\u043e\u0434\u0435\u043b\u0438\u0442\u0435\u0441\u044c \u043a\u0442\u043e \u043a\u0430\u043a \u0440\u0435\u0448\u0430\u043b \u043f\u043e\u0434\u043e\u0431\u043d\u0443\u044e \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0443, \u0431\u0443\u0434\u0435\u0442 \u0438\u043d\u0442\u0435\u0440\u0435\u0441\u043d\u043e \u0443\u0441\u043b\u044b\u0448\u0430\u0442\u044c \ud83d\ude09<\/p>\n<\/div>\n<p> \u0441\u0441\u044b\u043b\u043a\u0430 \u043d\u0430 \u043e\u0440\u0438\u0433\u0438\u043d\u0430\u043b \u0441\u0442\u0430\u0442\u044c\u0438 <a href=\"https:\/\/habr.com\/ru\/post\/494090\/\"> https:\/\/habr.com\/ru\/post\/494090\/<\/a><\/p>\n","protected":false},"excerpt":{"rendered":"\n<div class=\"post__text post__text-html post__text_v1\" id=\"post-content-body\" data-io-article-url=\"https:\/\/habr.com\/ru\/post\/494090\/\">\n<p>\u200b \u0412 \u044d\u0442\u043e\u0439 \u0441\u0442\u0430\u0442\u044c\u0435 \u044f \u043f\u043e\u043a\u0430\u0436\u0443 \u043a\u0430\u043a \u0440\u0435\u0448\u0438\u0442\u044c \u043e\u0434\u043d\u0443 \u0438\u0437 \u043f\u0440\u043e\u0431\u043b\u0435\u043c, \u0432\u043e\u0437\u043d\u0438\u043a\u0430\u044e\u0449\u0438\u0445 \u043f\u0440\u0438 \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u043e\u0432\u0430\u043d\u0438\u0438 \u0440\u0430\u0441\u043f\u0440\u0435\u0434\u0435\u043b\u0435\u043d\u043d\u044b\u0445 \u043e\u0447\u0435\u0440\u0435\u0434\u0435\u0439 \u0437\u0430\u0434\u0430\u0447 \u2014 \u0440\u0435\u0433\u0443\u043b\u0438\u0440\u043e\u0432\u0430\u043d\u0438\u0435 \u043f\u0440\u043e\u043f\u0443\u0441\u043a\u043d\u043e\u0439 \u0441\u043f\u043e\u0441\u043e\u0431\u043d\u043e\u0441\u0442\u0438 \u043e\u0447\u0435\u0440\u0435\u0434\u0438, \u0438\u043b\u0438 \u0436\u0435, \u0431\u043e\u043b\u0435\u0435 \u043f\u0440\u043e\u0441\u0442\u044b\u043c \u044f\u0437\u044b\u043a\u043e\u043c, \u043d\u0430\u0441\u0442\u0440\u043e\u0439\u043a\u0430 \u0435\u0435 rate limit&#8217;a. \u0412 \u043a\u0430\u0447\u0435\u0441\u0442\u0432\u0435 \u043f\u0440\u0438\u043c\u0435\u0440\u0430 \u044f \u0432\u043e\u0437\u044c\u043c\u0443 <strong>python<\/strong> \u0438 \u0441\u0432\u043e\u044e \u043b\u044e\u0431\u0438\u043c\u0443\u044e \u0441\u0432\u044f\u0437\u043a\u0443 <strong>Celery+RabbitMQ<\/strong>, \u0445\u043e\u0442\u044f \u0430\u043b\u0433\u043e\u0440\u0438\u0442\u043c, \u043a\u043e\u0442\u043e\u0440\u044b\u0439 \u044f \u0438\u0441\u043f\u043e\u043b\u044c\u0437\u0443\u044e, \u043d\u0438\u043a\u0430\u043a \u043d\u0435 \u0437\u0430\u0432\u0438\u0441\u0438\u0442 \u043e\u0442 \u044d\u0442\u0438\u0445 \u0438\u043d\u0441\u0442\u0440\u0443\u043c\u0435\u043d\u0442\u043e\u0432 \u0438 \u043c\u043e\u0436\u0435\u0442 \u0431\u044b\u0442\u044c \u0440\u0435\u0430\u043b\u0438\u0437\u043e\u0432\u0430\u043d \u043d\u0430 \u043b\u044e\u0431\u043e\u043c \u0434\u0440\u0443\u0433\u043e\u043c \u0441\u0442\u044d\u043a\u0435.<\/p>\n<p>  <\/p>\n<p><img decoding=\"async\" src=\"https:\/\/habrastorage.org\/webt\/ei\/h-\/pa\/eih-panacwyd8rxigfn7saopzbs.jpeg\" alt=\"Celery+RabbitMQ\"><\/p>\n<p>  <\/p>\n<h2 id=\"so-whats-the-problem\">So what&#8217;s the problem?<\/h2>\n<p>  <\/p>\n<p>\u200b \u0414\u043b\u044f \u043d\u0430\u0447\u0430\u043b\u0430 \u043f\u0430\u0440\u0430 \u0441\u043b\u043e\u0432 \u043e \u0442\u043e\u043c, \u043a\u0430\u043a\u0443\u044e \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u0443 \u044f \u0432\u043e\u043e\u0431\u0449\u0435 \u043f\u044b\u0442\u0430\u044e\u0441\u044c \u0440\u0435\u0448\u0438\u0442\u044c. \u0414\u0435\u043b\u043e \u0432 \u0442\u043e\u043c, \u0447\u0442\u043e <em>99.9% \u0441\u0435\u0440\u0432\u0438\u0441\u043e\u0432 \u0432 \u0438\u043d\u0442\u0435\u0440\u043d\u0435\u0442\u0435 \u0437\u0430\u043f\u0440\u0435\u0449\u0430\u044e\u0442 \u0431\u0435\u0441\u043a\u043e\u043d\u0442\u0440\u043e\u043b\u044c\u043d\u043e \u0437\u0430\u043a\u0438\u0434\u044b\u0432\u0430\u0442\u044c \u0438\u0445 \u0441\u043e\u0442\u043d\u044f\u043c\u0438\/\u0442\u044b\u0441\u044f\u0447\u0430\u043c\u0438 \u0437\u0430\u043f\u0440\u043e\u0441\u043e\u0432 \u0432 \u0441\u0435\u043a\u0443\u043d\u0434\u0443<\/em>, \u0443\u0433\u0440\u043e\u0436\u0430\u044f \u0434\u0430\u0442\u044c \u0432 \u043e\u0442\u0432\u0435\u0442 \u043a\u0430\u043a\u043e\u0439-\u043d\u0438\u0431\u0443\u0434\u044c 403 \u0438\u043b\u0438 500. \u041d\u0435\u0442, \u043d\u0443 \u043f\u0440\u0430\u0432\u0434\u0430, \u0436\u0430\u043b\u043a\u043e \u0438\u043c \u0447\u0442\u043e\u043b\u0435? \u0418\u043d\u043e\u0433\u0434\u0430 \u0442\u0430\u043a\u0438\u043c \u0441\u0435\u0440\u0432\u0438\u0441\u043e\u043c \u043c\u043e\u0436\u0435\u0442 \u0432\u044b\u0441\u0442\u0443\u043f\u0430\u0442\u044c \u0434\u0430\u0436\u0435 \u0441\u0432\u043e\u044f \u0441\u043e\u0431\u0441\u0442\u0432\u0435\u043d\u043d\u0430\u044f \u0411\u0414\u2026 \u0412\u043e\u0431\u0449\u0435\u043c, \u0434\u043e\u0432\u0435\u0440\u044f\u0442\u044c \u043d\u044b\u043d\u0447\u0435 \u043d\u0435\u043b\u044c\u0437\u044f \u043d\u0438\u043a\u043e\u043c\u0443, \u043f\u043e\u044d\u0442\u043e\u043c\u0443 \u043f\u0440\u0438\u0445\u043e\u0434\u0438\u0442\u0441\u044f \u0441\u0435\u0431\u044f \u043a\u0430\u043a-\u0442\u043e \u0441\u0434\u0435\u0440\u0436\u0438\u0432\u0430\u0442\u044c.<\/p>\n<p>  <\/p>\n<p>\u200b \u041a\u043e\u043d\u0435\u0447\u043d\u043e, \u0435\u0441\u043b\u0438 \u0432\u0441\u044f \u0440\u0430\u0431\u043e\u0442\u0430 \u0432\u0435\u0434\u0435\u0442\u0441\u044f \u0432\u043d\u0443\u0442\u0440\u0438 1\u0433\u043e \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u0430, \u0442\u043e \u043d\u0438\u043a\u0430\u043a\u043e\u0439 \u043f\u0440\u043e\u0431\u043b\u0435\u043c\u044b \u043d\u0435\u0442, \u043d\u043e \u0442.\u043a \u043c\u044b \u0440\u0430\u0431\u043e\u0442\u0430\u0435\u043c \u0441 Celery, \u0442\u043e \u0443 \u043d\u0430\u0441 \u043c\u043e\u0436\u0435\u0442 \u0431\u044b\u0442\u044c \u043d\u0435 \u0442\u043e\u043b\u044c\u043a\u043e N \u043f\u0440\u043e\u0446\u0435\u0441\u0441\u043e\u0432 (\u0434\u0430\u043b\u0435\u0435 <em>\u0432\u043e\u0440\u043a\u0435\u0440\u043e\u0432<\/em>), \u043d\u043e \u0438 M \u043c\u0430\u0448\u0438\u043d, \u0438 \u0437\u0430\u0434\u0430\u0447\u0430 \u0432\u0441\u0435 \u044d\u0442\u043e \u0434\u0435\u043b\u043e \u0441\u0438\u043d\u0445\u0440\u043e\u043d\u0438\u0437\u0438\u0440\u043e\u0432\u0430\u0442\u044c \u0443\u0436\u0435 \u043d\u0435 \u043a\u0430\u0436\u0435\u0442\u0441\u044f \u0441\u0442\u043e\u043b\u044c \u0442\u0440\u0438\u0432\u0438\u0430\u043b\u044c\u043d\u043e\u0439.<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[],"tags":[],"class_list":["post-300714","post","type-post","status-publish","format-standard","hentry"],"_links":{"self":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/300714","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=300714"}],"version-history":[{"count":0,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=\/wp\/v2\/posts\/300714\/revisions"}],"wp:attachment":[{"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=300714"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=300714"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/savepearlharbor.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=300714"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}