レスポンスコードを同期して処理する際に、どのように非同期的にトルネードでストリーミングデータを処理するのですか？

Question

私のtornado APIコールは、別のURLを呼び出してから、結果をクライアントにストリーミングします。ただし、内部URLからエラーコードが返された場合は、独自のエラーを個別に処理し、エラー内容をクライアントにストリームしたいと考えています。私が現在持っていることはこれです：

@web.asynchronous 
@gen.coroutine 
def get(self, job_id): 
    url = ... 
    client = httpclient.AsyncHTTPClient() 

    # handle_chunk will forward received bytes to the client, allowing 
    # other HTTP requests to be handled concurrently 
    response = yield client.fetch(httpclient.HTTPRequest(
     url=url, 
     streaming_callback=self._handle_chunk)) 
    self.finish() 

def _handle_chunk(self, chunk): 
    self.write(chunk) 
    self.flush() 

私は応答コードが200家族であるが、全体の要求が完了するまで応答がclient.fetchによって得られたされていない場合は、転送チャンクを起動するだけにこれを変更する必要があります。どのようにこれを行うにはどのようなアイデア？

Answer 1

streaming_callbackとheader_callbackの両方を使用してください。ヘッダーコールバックは、最初の呼び出しがstreaming_callbackになる前に実行され、ヘッダーは文字列のリストとして表示されます。ヘッダーには、あなた自身を解析する必要がありますステータス行で始まる：

@gen.coroutine 
def get(self, job_id): 
    url = ... 
    client = httpclient.AsyncHTTPClient() 

    response = yield client.fetch(httpclient.HTTPRequest(
     url=url, 
     header_callback=self._handle_headers, 
     streaming_callback=self._handle_chunk)) 
    if response.code != 200: 
     # handle error 
    self.finish() 

def _handle_headers(self, headers): 
    self._start_line = tornado.httputil.parse_response_start_line(headers[0]) 

def _handle_chunk(self, chunk): 
    if self._start_line.code == 200: 
     self.write(chunk) 
     self.flush() 

それはきれいに要求をキャンセルすることはできません。ステータスコードが200ではない場合、コールバックはストリーミングチャンクを受け入れ、無視します（そして、別の場所でエラーを返します）。