1

我有一个服务器正在尝试将一些内容流式传输到客户端（这是 Kenneth Reitz 优秀的请求库）-（以下代码的道具toastdriven.com）。请注意，在浏览器中，它按预期工作。

from gevent import monkey
monkey.patch_all()

import datetime
import time
from gevent import Greenlet
from gevent import pywsgi
from gevent import queue

import json

def current_time(body):
    current = start = datetime.datetime.now()
    end = start + datetime.timedelta(seconds=60)

    while current < end:
        current = datetime.datetime.now()
        message = json.dumps({'time': current.strftime("%Y-%m-%d %I:%M:%S")})
        body.put(message)
        time.sleep(1)

    body.put('</body></html>')
    body.put(StopIteration)

def handle(environ, start_response):
    start_response('200 OK', [('Content-Type', 'text/html')])
    body = queue.Queue()
    g = Greenlet.spawn(current_time, body)
    return body

server = pywsgi.WSGIServer(('127.0.0.1', 1234), handle)
print "Serving on http://127.0.0.1:1234..."
server.serve_forever()

还有一个客户：

import sys
import requests
import json

my_config = {'verbose': sys.stdout}
r = requests.get('http://127.0.0.1:1234/', config=my_config)

for line in r.iter_lines():
    print json.loads(line)

我不明白为什么 json 行没有出现在终端（OSX）中。当我 ctrl-c 时，响应被转储到屏幕上。

如果我做：

for line in r.iter_content()

我得到了 json，每行上的一个字符，按预期流式传输。

有任何想法吗？

4

1 回答 1

0

您的客户端可能正在缓冲的终端窗口中运行。每次打印后，尝试添加sys.stdout.flush()以刷新输出缓冲区。

于 2012-05-01T14:54:04.820 回答