Добрый день господа программисты прошу помощи. Сам что то не могу разобраться. Честно пробовал это сделать, поратил полдня и не получилось. У меня есть код socket-клиента и он работает так как я хочу, но в нем я использую (from tornado import gen и @gen.coroutine). А это не рекомендуется введите сюда описание ссылки
Native coroutines are the recommended form whenever possible. Only use decoratedcoroutines when compatibility with older versions of Python is required.
Вот код моего клиента:
from tornado.ioloop import IOLoop, PeriodicCallback
from tornado import gen
from tornado.websocket import websocket_connect
import time
class Client(object):
def __init__(self, url, timeout):
self.url = url
self.timeout = timeout
self.ioloop = IOLoop.instance()
self.ws = None
self.connect()
PeriodicCallback(self.keep_alive,1000).start()
#PeriodicCallback(self.keep_alive, 20000, io_loop=self.ioloop).start()
self.ioloop.start()
@gen.coroutine
def connect(self):
print ("trying to connect")
try:
self.ws = yield websocket_connect(self.url)
except Exception:
print ("connection error")
else:
print ("connected")
self.run()
@gen.coroutine
def run(self):
while True:
msg = yield self.ws.read_message()
if msg is None:
print ("connection closed")
self.ws = None
break
print("from server: {}".format(msg))
def keep_alive(self):
if self.ws is None:
self.connect()
else:
self.ws.write_message("Hello")
def report():
try:
if time.time() - report.T > 2:
report.T = time.time()
print (round(report.T-report.start_value))
except AttributeError:
report.T = time.time()
report.start_value = time.time()
if __name__ == "__main__":
PeriodicCallback(report,100).start()
client = Client("ws://localhost:8881", 5)
И теперь я захотел модифицировать код клиента согласно новым правилам принятым в Python 3.7. У меня получилось вот что:
from tornado.ioloop import IOLoop, PeriodicCallback
from tornado.websocket import websocket_connect
import time
class Client(object):
def __init__(self, url, timeout):
self.url = url
self.timeout = timeout
self.ioloop = IOLoop.instance()
self.ws = None
self.connect()
PeriodicCallback(self.keep_alive,1000).start()
#PeriodicCallback(self.keep_alive, 20000, io_loop=self.ioloop).start()
self.ioloop.start()
async def connect(self):
print ("trying to connect")
try:
self.ws = await websocket_connect(self.url)
return self.ws
except Exception:
print ("connection error")
else:
print ("connected")
self.run()
async def run(self):
while True:
msg = await self.ws.read_message()
if msg is None:
print ("connection closed")
self.ws = None
break
print("from server: {}".format(msg))
def keep_alive(self):
if self.ws is None:
self.connect()
else:
self.ws.write_message("Hello")
def report():
try:
if time.time() - report.T > 2:
report.T = time.time()
print (round(report.T-report.start_value))
except AttributeError:
report.T = time.time()
report.start_value = time.time()
if __name__ == "__main__":
PeriodicCallback(report,100).start()
client = Client("ws://localhost:8881", 5)
Но, вот, после такой модификации мой код перестал работать. И вот что я вижу в консоле.
PS C:\workspace_ilya\polyna> cd 'c:\workspace_ilya\polyna'; ${env:PYTHONIOENCODING}='UTF-8'; ${env:PYTHONUNBUFFERED}='1'; & 'C:\Users\BenisovichIS\AppData\Local\Programs\Python\Python37\python.exe' 'c:\Users\BenisovichIS\.vscode-insiders\extensions\ms-python.python-2019.1.0\pythonFiles\ptvsd_launcher.py' '--default' '--client' '--host' 'localhost' '--port' '52425' 'C:\workspace_ilya\sandbox\tornado_client_1.py'
C:\workspace_ilya\sandbox\tornado_client_1.py:15: RuntimeWarning: coroutine 'Client.connect' was never awaited
self.connect()
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
C:\workspace_ilya\sandbox\tornado_client_1.py:43: RuntimeWarning: coroutine 'Client.connect' was never awaited
self.connect()
RuntimeWarning: Enable tracemalloc to get the object allocation traceback
2
4
6
8
Под дебаггером я вижу, что программа в мою ф-цию connect() вообще не заходит. Странно почему так происходит. Ребята объясните мне пожалуйста почему так происходит, если вам не сложно?
await
. Возлеself.connect()
иself.run()
у васawait
отсутствует__init__
await
не стаботает. нужен такс