使用Python3在金字塔使用Websocket

Question

是否有办法使用Python 3在金字塔中使用Websockets ?当服务器上有数据更改时，我想使用它来实时更新表。

我已经考虑过使用长轮询，但我不认为这是最好的方法。

有什么意见或想法吗?

Answer 1

https://github.com/housleyjk/aiopyramid适合我。参见websocket的文档http://aiopyramid.readthedocs.io/features.html#websockets

乌利希期刊指南:

WebSocket server with pyramid environment.

import aiohttp
import asyncio
from aiohttp import web
from webtest import TestApp
from pyramid.config import Configurator
from pyramid.response import Response
async def websocket_handler(request):
    ws = web.WebSocketResponse()
    await ws.prepare(request)
    while not ws.closed:
        msg = await ws.receive()
        if msg.tp == aiohttp.MsgType.text:
            if msg.data == 'close':
                await ws.close()
            else:
                hello = TestApp(request.app.pyramid).get('/')
                ws.send_str(hello.text)
        elif msg.tp == aiohttp.MsgType.close:
            print('websocket connection closed')
        elif msg.tp == aiohttp.MsgType.error:
            print('ws connection closed with exception %s' %
                  ws.exception())
        else:
            ws.send_str('Hi')
    return ws

def hello(request):
    return Response('Hello world!')
async def init(loop):
    app = web.Application(loop=loop)
    app.router.add_route('GET', '/{name}', websocket_handler)
    config = Configurator()
    config.add_route('hello_world', '/')
    config.add_view(hello, route_name='hello_world')
    app.pyramid = config.make_wsgi_app()
    srv = await loop.create_server(app.make_handler(),
                                   '127.0.0.1', 8080)
    print("Server started at http://127.0.0.1:8080")
    return srv
loop = asyncio.get_event_loop()
loop.run_until_complete(init(loop))
try:
    loop.run_forever()
except KeyboardInterrupt:
    pass

WebSocket客户:

import asyncio
import aiohttp
session = aiohttp.ClientSession()

async def client():
    ws = await session.ws_connect('http://0.0.0.0:8080/foo')
    while True:
        ws.send_str('Hi')
        await asyncio.sleep(2)
        msg = await ws.receive()
        if msg.tp == aiohttp.MsgType.text:
            print('MSG: ', msg)
            if msg.data == 'close':
                await ws.close()
                break
            else:
                ws.send_str(msg.data + '/client')
        elif msg.tp == aiohttp.MsgType.closed:
            break
        elif msg.tp == aiohttp.MsgType.error:
            break
loop = asyncio.get_event_loop()
loop.run_until_complete(client())
loop.close()