Здесь есть страница API GitHub-https://github.com/dhan-oss/dhanhq-py/t ... nhqобразно - 2025-01-29 09: 52: 59,755 - Ошибка - Попытка подписки 1 Не удалось: отправлено 1011 (Внутренняя ошибка) Тайм -аут для пинга; Не получено закрытого кадра < /p>
, а также данные не поступают медленно, тогда цена в реальном времени < /p>
class OptionsDataCollector:
def __init__(self, config: Dict):
# Initialize core components first
self.config = config
self.data_queue = Queue(maxsize=1000) # Moved up in initialization
self.ltp_dict = {}
self.feed = None
self.last_data_time = time.time()
self.connection_timeout = 5
self.reconnect_delay = 5
self.on_close = False
self.subscribed_tokens = set()
self.last_subscription_time = 0
self.subscription_cooldown = 5
# Setup components that don't depend on others
self.setup_logging()
self.setup_mongodb()
# Start processing thread last
self.processing_thread = threading.Thread(target=self._process_queue, daemon=True)
self.processing_thread.start()
def handle_disconnection(self, data: bytes) -> None:
"""Handle websocket disconnection"""
try:
disconnection_packet = struct.unpack('
Подробнее здесь: https://stackoverflow.com/questions/793 ... et-might-b
