使用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進行驗證）。