Skip to content

Latest commit

 

History

History
35 lines (25 loc) · 856 Bytes

File metadata and controls

35 lines (25 loc) · 856 Bytes

Agent

import asyncio
import ssl
import logging

from binance_common.configuration import ConfigurationWebSocketStreams
from binance_sdk_derivatives_trading_options.derivatives_trading_options import DerivativesTradingOptions

logging.basicConfig(level=logging.INFO)

configuration_ws_streams = ConfigurationWebSocketStreams(
    https_agent=ssl.create_default_context(),
)

client = DerivativesTradingOptions(config_ws_streams=configuration_ws_streams)


async def connect():
    connection = None
    try:
        connection = await client.websocket_streams.create_connection()

        await asyncio.sleep(5)
    except Exception as e:
        logging.error(f"connect error: {e}")
    finally:
        if connection:
            await connection.close_connection(close_session=True)


if __name__ == "__main__":
    asyncio.run(connect)