后端的服务返回的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')
Quelqu'un a déjà aidé à résoudre le problème :