使用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

主要的问题是，你忘了声明global userfeed两个data_updater和web_handle功能。因此，根据how python resolves scopes，在web_handle中指的是您定义的全局变量，并且data_updater指的是由语句userfeed = [x for x ...创建的本地变量。在这种情况下使用全局变量显式为discouraged，因此有一个示例使用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进行验证）。