Блог

Я хотел бы использовать модуль Python (python-kucoin), который использует asyncio существующий скрипт Python, который этого не делает, предпочтительно без необходимости переписывать вещи. Я никогда не использовал asyncio раньше, и учебные пособия, которые я видел до сих пор, были совершенно ошеломляющими.

Это упрощенная версия примера в документах python-kucoin:

 async def main():
    global loop

    async def handle_evt(msg):
        print(msg)

    client = Client(None, None, None)

    ksm = await KucoinSocketManager.create(loop=loop, client=client, callback=handle_evt)

    await ksm.subscribe('/market/level2:BTC-USDT')

    while True:
        print("sleeping to keep loop open")
        await asyncio.sleep(20, loop=loop)

loop = asyncio.get_event_loop()
loop.run_until_complete(main())
 

В идеале я хочу написать класс, который выглядит примерно так:

 class KucoinSocket():
    def _init_(self):
        self.messages = []
        # create KucoinSocketManager passing self.handle_evt as callback
        # subscribe to the '/market/level2:BTC-USDT' stream

    def handle_evt(self, msg):
        self.messages.append(msg)

    def get_messages(self):
        return self.messages

ks = KucoinSocket()

# Do other stuff ...

ks.get_messages()
 

Возможно ли это, и если да, не могли бы вы привести мне пример?