pyquotex is a Python library designed to easily integrate with the Quotex API, enabling automated trading operations. Fully open-source and licensed under MIT, the library provides features like order execution, balance checking, real-time market data collection, and more. Perfect for traders and developers looking to build efficient and customized solutions.
PyQuotex utiliza la librería websocket-client para establecer y mantener conexiones WebSocket con el servidor de Quotex. La implementación principal se encuentra en la clase WebsocketClient.
self.wss = websocket.WebSocketApp(
self.api.wss_url,
on_message=self.on_message,
on_error=self.on_error,
on_close=self.on_close,
on_open=self.on_open,
on_ping=self.on_ping,
on_pong=self.on_pong,
header=self.headers
)
PyQuotex ofrece varios métodos para suscribirse a diferentes tipos de streams:
def start_candles_stream(self, asset, period=0):
self.api.current_asset = asset
self.api.subscribe_realtime_candle(asset, period)
self.api.follow_candle(asset)
async def start_realtime_sentiment(self, asset, period=0):
self.start_candles_stream(asset, period)
while True:
if self.api.realtime_sentiment.get(asset):
return self.api.realtime_sentiment[asset]
await asyncio.sleep(0.2)
async def start_realtime_price(self, asset, period=0):
self.start_candles_stream(asset, period)
while True:
if self.api.realtime_price.get(asset):
return self.api.realtime_price
await asyncio.sleep(0.2)
El sistema soporta los siguientes tipos de streams:
PyQuotex implementa un sistema robusto de reconexión automática:
async def connect(attempts=5):
check, reason = await client.connect()
if not check:
attempt = 0
while attempt <= attempts:
if not await client.check_connect():
check, reason = await client.connect()
if check:
print("Reconectado exitosamente!")
break
else:
print("Error en la reconexión.")
attempt += 1
check_websocket_if_connect = None
check_websocket_if_error = False
check_rejected_connection = False