python - 使用webpy流式传输连续数据

Question

我想使用 python 和 web.py 将连续传感器数据流式传输到小型 Web 套接字。但我无法更新数据。

最小工作示例如下所示:

#!/usr/bin/env python
import web
from time import sleep

# 1. Data part, create some csv-string
streamString = "x,y\n"
streamString = streamString + "123,123\n"

# 2. webpy part, create a minimum server
urls = ('/', 'index')
class index:
    def GET(self):
        return streamString

if __name__ == "__main__":
    app = web.application(urls, globals())
    app.run()
    # simulate some sensor data that is read continuously
    i = 0 
    while True:
        newString = "{0},{1}\n".format(i, i+1)
        i = i + 2
        streamString = streamString + newString
        sleep(1)

这将创建显示第一个条目 (x,y\n123,123\n) 的应用程序，但它无法显示“实时”数据(我假设这是 app.run() 出现在循环之前)

知道如何才能完成这项工作吗？

Answer 1

首先，你是对的:你的 while True: 永远不会执行，因为它在 app.run() 之后。

基本策略是使用 yield 使 GET() 成为生成器，而不是返回字符串。例如:

class index:
    def GET(self):
      web.header('Transfer-Encoding', 'chunked')
      yield "Here we go!"
      i = 0
      while True:
          newString = "{0},{1}\n".format(i, i+1)
          i = i + 2
          sleep(1)
          yield newString

1. 使用传输编码“分块”告诉浏览器并非所有数据都会同时传入。
2. 仅生成新值(您的示例连接了字符串)。
3. 因为您使用 yield，所以在 GET() 中，该 GET 返回的所有数据都必须使用 yield(因此我的 yield 'Here we go!' 示例。)

它工作正常，但您的浏览器将缓冲结果:它确实会“永远”以一秒的间隔接收数据，但浏览器不会在每次接收时更新。例如，Chrome 似乎会等到收到初始 1k 数据为止。然后它对浏览器进行第一次写入，然后将在每次新接收时更新窗口(因此它仅缓冲第一位)。

所以，尝试更新的代码并等待。

另请参阅http://webpy.org/cookbook/streaming_large_files