1
我使用httpclient.HTTPRequest庫發送異步請求,但需要在請求之間添加延遲。 這意味着可以說我配置RPS(請求每秒)= 5。然後我發送一個請求每個0.2但異步。如何在不等待每個請求響應的情況下異步發送請求。延遲HTTP客戶端異步調用
這是我的代碼:
def process_campaign(self, campaign_instance):
ioloop.IOLoop.current().run_sync(lambda: start_campaign(campaign_instance))
@gen.coroutine
def start_campaign(campaign_instance):
...
while True:
try:
log.info("start_campaign() Requests in Queue: {}".format(len(web_requests)))
web_request = web_requests.pop()
time.sleep(delay)
headers = {'Content-Type': 'application/json'}
request = httpclient.HTTPRequest(auth_username=settings.api_account,
auth_password=settings.api_password,
url=settings.api_url,
body=json.dumps(web_request),
headers=headers,
request_timeout=15,
method="POST")
response = yield http_client.fetch(request)
except httpclient.HTTPError, e:
log.exception("start_campaign() " + str(e))
except IndexError:
log.info('start_campaign() Campaign web requests completed. Errors {}'.format(api_errors))
break
但似乎等待在繼續之前的HTTP響應。
如何處理在這種新的生活方式我的錯誤? – californian