denis/QuikPy
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Попытки обеспечить стабильный парсинг

Browse Source
This commit is contained in:
denis
2024-04-16 15:32:58 +00:00
parent 6d210d20e0
commit fc1f4ebacc
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
QuikPy.py
View File

@@ -43,6 +43,8 @@ class QuikPy(metaclass=Singleton): # Singleton класс
print("Истёк таймаут чтения из буфера") print("Истёк таймаут чтения из буфера")
except ConnectionResetError: except ConnectionResetError:
print("Соединение сброшено") print("Соединение сброшено")
self.OnClose({})
else: else:
fragments.append(fragment.decode('cp1251')) # Переводим фрагмент в Windows кодировку 1251, добавляем в список fragments.append(fragment.decode('cp1251')) # Переводим фрагмент в Windows кодировку 1251, добавляем в список
if len(fragment) < self.bufferSize: # Если в принятом фрагменте данных меньше чем размер буфера if len(fragment) < self.bufferSize: # Если в принятом фрагменте данных меньше чем размер буфера
@@ -117,13 +119,14 @@ class QuikPy(metaclass=Singleton): # Singleton класс
def ProcessRequest(self, Request): def ProcessRequest(self, Request):
"""Отправляем запрос в QUIK, получаем ответ из QUIK""" """Отправляем запрос в QUIK, получаем ответ из QUIK"""
rawData = json.dumps(Request) # Переводим запрос в формат JSON rawData = json.dumps(Request) # Переводим запрос в формат JSON
# self.socketRequests.settimeout(1) self.socketRequests.settimeout(1)
print(rawData)
# print(self.socketRequests.timeout) # print(self.socketRequests.timeout)
# self.socketRequests.sendall(f'{rawData}\r\n'.encode()) # Отправляем запрос в QUIK # self.socketRequests.sendall(f'{rawData}\r\n'.encode()) # Отправляем запрос в QUIK
try: try:
self.socketRequests.sendall(f'{rawData}\r\n'.encode()) # Отправляем запрос в QUIK self.socketRequests.sendall(f'{rawData}\r\n'.encode()) # Отправляем запрос в QUIK
except Exception: except TimeoutError:
# raise TimeoutError("Истёк таймаут подключения к QUIK") raise TimeoutError("Истёк таймаут подключения к QUIK")
print("Истёк таймаут подключения к QUIK") print("Истёк таймаут подключения к QUIK")
data = {"data": "error"} data = {"data": "error"}
return data return data