Je me demande si la fonction utilisant websockets qui contient ʻasyncio se répandra au sommet et deviendra ʻasync / await pour toujours ... Je pensais j'ai réussi à le faire avec ma propre bibliothèque, donc un mémorandum de cette partie

Solution

--J'ai utilisé un décorateur

environnement

Python 3.8.5
websockets 8.1

code

my_library.py

import websockets
import asyncio

class EntitySpec(object):
    def __init__(self, ctx):
        self.ctx = ctx
        self.uri = "ws://{}:{}".format(
            ctx.hostname, ctx.port,
        )

    def __call__(self, func):
        async def stream(func):
            async with websockets.connect(self.uri) as ws:
                while not ws.closed:
                    try:
                        response = await ws.recv()
                        func(response)
                    except websockets.exceptions.ConnectionClosedOK:
                        self.loop.stop()
        self.loop = asyncio.get_event_loop()
        self.loop.create_task(stream(func))
        return stream

    def run(self):
        self.loop.run_forever()

class Context(object):
    def __init__(
        self,
        hostname='localhost',
        port=8765,
    ):
        self.hostname = hostname
        self.port = port        
        self.websocket = EntitySpec(self)

main.py

import my_library

api = my_library.Context(
    hostname = 'localhost',
    port = 8765,  #exemple de port standard de serveur websockets
)

@api.websocket
def reciever(msg):
    print(msg)

api.websocket.run()

Masquer les websockets async / attendent dans Python3

Solution

environnement

code