后端的服务返回的response类型是x-mixed-replace,也就是会需要和客户端建立一个长连接,持续不断的推送数据。
但通过nginx做代理转发后,这个数据推送不是连续的,而是等nginx缓冲区满了之后才会把数据返回给客户端。
请问如何配置nginx让后端服务返回的数据不经过nginx缓冲区直接返回给客户端?
代码:
@expose('/get_log/')
def get_log(self):
def gen(consumer):
while True:
for message in consumer:
yield b'--frame\r\n' + str(message.value) + b'\r\n'
break
return Response(gen(consumer=get_kafka_consumer()),
mimetype='multipart/x-mixed-replace; boundary=frame')
巴扎黑2017-04-18 09:56:55
Someone has already helped solve the problem:
_headers = dict()
_headers['X-Accel-Buffering'] = 'no' # nginx不对此请求做缓冲
return Response(gen(consumer=get_kafka_consumer()), headers=_headers)