是否有一个“块接收”的回调在扭曲的网络

Question

我试过render_GET，它只会在整个块体收到和缓冲时调用。

如何获取部分中继数据？我需要连续处理数据（如流），它是一个长期存在的连接（> 10分钟）。

有人可以帮助我！

Answer 1

render_GET通常在网络服务器上实现，但根据您的问题，似乎您正试图从Web服务器使用数据而不是服务它。

你想要的东西很容易使用Agent API实现。请从Twisted Web documentation中查看此示例。

from __future__ import print_function 

from pprint import pformat 

from twisted.internet import reactor 
from twisted.internet.defer import Deferred 
from twisted.internet.protocol import Protocol 
from twisted.web.client import Agent 
from twisted.web.http_headers import Headers 

class BeginningPrinter(Protocol): 
    def __init__(self, finished): 
     self.finished = finished 
     self.remaining = 1024 * 10 

    def dataReceived(self, bytes): 
     if self.remaining: 
      display = bytes[:self.remaining] 
      print('Some data received:') 
      print(display) 
      self.remaining -= len(display) 

    def connectionLost(self, reason): 
     print('Finished receiving body:', reason.getErrorMessage()) 
     self.finished.callback(None) 

agent = Agent(reactor) 
d = agent.request(
    'GET', 
    'http://example.com/', 
    Headers({'User-Agent': ['Twisted Web Client Example']}), 
    None) 

def cbRequest(response): 
    print('Response version:', response.version) 
    print('Response code:', response.code) 
    print('Response phrase:', response.phrase) 
    print('Response headers:') 
    print(pformat(list(response.headers.getAllRawHeaders()))) 
    finished = Deferred() 
    response.deliverBody(BeginningPrinter(finished)) 
    return finished 
d.addCallback(cbRequest) 

def cbShutdown(ignored): 
    reactor.stop() 
d.addBoth(cbShutdown) 

reactor.run() 

当某物到达时，会调用dataReceived事件。

希望这会有所帮助。