Парсинг и сохранения данных с бирж BingX и WEEX
Написать скрипт для парсинга и сохранения данных с бирж BingX и WEEX на python 3.12.X
Нужно написать 4 класса (BingxFuturesWS, BingxSpotWS, WeexFuturesWS, WeexSpotWS)
У меня уже есть подключения для многих бирж, как должна выглядеть структура:
Я использую базу данных PostgreSQL и класс получает пул бд (def __init__(self, db_pool):)
Затем мы должны подключится к вебсокету и подписаться на все символы и записывать в базу данных:
Для Futures:
create TABLE IF NOT exists {exchange}_history_futures (
symbol TEXT,
ask1 FLOAT,
bid1 FLOAT,
funding_rate FLOAT,
timestamp bigint
);
Для Spot:
create TABLE IF NOT exists {exchange}_history_spot (
symbol TEXT,
ask1 FLOAT,
bid1 FLOAT,
timestamp bigint
);
После получения данных мы их добавляем в массив, чтобы инсертить массив в базу данных.
таймстемп (в UTC) мы округляем до интервала 2 секунды (переменная с интервалом должна быть в __init__)
Подключение к БД ассинхронное
await conn.executemany("""
insert INTO {биржа}_history_futures
(symbol, ask1, bid1, funding_rate, timestamp)
values ($1, $2, $3, $4, $5)
""", values)
Важно чтобы при появлении нового символа мы подписывались на него в вебсокете и при сбое переподключались
Все вебсокеты и API запросы берутся из веба
Примеры как должно работать и структуру одной из бирж я скину исполнителю
Скрипты и боты