使用asyncio及时更新一些数据，并通过aiohttp呈现

Question

我在尝试写一个片段来研究Python asyncio。基本思想是:

1. 使用一个"简单"的web服务器(aiohttp)向用户呈现一些数据

2. 返回给用户的数据会及时改变

下面是代码:

import asyncio
import random
from aiohttp import web
userfeed = [] # the data suppose to return to the user via web browsers 
async def data_updater():  #to simulate data change promptly
    while True:
        await asyncio.sleep(3)
        userfeed = [x for x in range(random.randint(1, 20))]
        print('user date updated: ', userfeed)

async def web_handle(request):
    text = str(userfeed)
    #print('in handler:', text)  # why text is empty?
    return web.Response(text=text)
async def init(loop):
    app = web.Application(loop=loop)
    app.router.add_route('GET', '/', web_handle)
    srv = await loop.create_server(app.make_handler(), '127.0.0.1', 8000)
    print('Server started @ http://127.0.0.1:8000...')
    return srv
loop = asyncio.get_event_loop()
asyncio.ensure_future(data_updater())  
asyncio.ensure_future(init(loop))
loop.run_forever()

问题是，代码正在运行(python 3.5)，但userfeed在浏览器和web_handler()中始终为空:-(

)

1. 为什么userfeed没有更新?
2. 关于这个timely date update函数，因为更新机制可能会更复杂以后说异步IO等待可能涉及，有一个更好的方法，而不是使用while True: await asyncio.sleep(3)在data_updater()获得"更粗略精确"的定时器?

Answer 1

主要问题是在data_updater和web_handle函数中都忘记了语句global userfeed。因此，根据python解析作用域的方式，在web_handle中它指的是您定义的全局变量，在data_updater中指的是由语句userfeed = [x for x ...创建的局部变量。在这种情况下使用全局变量是不被鼓励的，所以这里有一个使用aiohttp.web.Application对象的dict接口来安全地引用函数之间的变量的例子。

import asyncio
import random
from aiohttp import web

async def data_updater(app):
    while True:
        await asyncio.sleep(3)
        app["userfeed"] = [x for x in range(random.randint(1, 20))]
async def web_handle(request):
    userfeed = request.app["userfeed"]
    return web.Response(text=str(userfeed))
async def init(loop, port=8000):
    app = web.Application(loop=loop)
    app.router.add_route('GET', '/', web_handle)
    handler = app.make_handler()
    srv = await loop.create_server(
        handler, '127.0.0.1', port=port)
    return srv, app, handler
if __name__ == "__main__":
    loop = asyncio.get_event_loop()
    srv, app, handler = loop.run_until_complete(init(loop, 8000))
    app['userfeed'] = []
    asyncio.ensure_future(data_updater(app))
    try:
        loop.run_forever()
    except KeyboardInterrupt:
        pass
    finally:
        srv.close()
        loop.run_until_complete(srv.wait_closed())
        loop.run_until_complete(app.shutdown())
        loop.run_until_complete(handler.finish_connections(60.0))
        loop.run_until_complete(app.cleanup())
    loop.close()

当你在127.0.0.1:8000上刷新页面时，你应该有一些新的随机数，因为它们每3秒更新一次服务器端(你可以把print语句放回data_updater来验证它)。