В ответ на комментарий читателя в предыдущей статье, требуется пример программы для мониторинга переводов контрактных счетов. В этом выпуске мы будем использовать Binance Exchange в качестве тестового объекта для достижения этого требования и научимся его проектировать.
Криптовалютные биржи ежедневно обрабатывают большое количество транзакций, включая переводы активов между различными кошельками. Мониторинг этих переводов в режиме реального времени имеет решающее значение для трейдеров и разработчиков. В этой статье мы рассмотрим фрагмент кода JavaScript, предназначенный для мониторинга последних переводов активов на криптовалютной бирже, а также обсудим его ключевые компоненты.
Анализировать требования
Изучив документацию Binance Exchange, я обнаружил, что существует интерфейс истории переводов, который может запрашивать всю информацию о переводах. Поскольку мы отслеживаем только возможные записи о переводах, нам не нужно получать все истории переводов. Нам нужно только проверить последние записи о переводах в определенном диапазоне с определенной частотой. Если будут обнаружены новые записи о переводах, они будут обновлены и уведомлены.
Используйте этот интерфейс:
javascript
// GET /sapi/v1/asset/transfer type, size : 100
Так как же проверить недавно добавленные записи о переводах? После прочтения документации Binance я обнаружил, что данные, возвращаемые этим интерфейсом, содержат временные метки. Очень просто использовать временные метки для оценки. Пока есть запись с временной меткой, большей, чем текущая запись, это означает, что новый перевод произошло. . Просто используйте это, чтобы активировать его.
/sapi/v1/asset/transferИнтерфейс запрашивает максимум 100 фрагментов данных каждый раз. Это обнаружение не вызовет проблем для низкочастотных переводов, если только у учетной записи не будет более 100 операций перевода между окончанием одного обнаружения и началом следующего обнаружения. В это время некоторые новые записи об операциях могут быть пропущены, что достаточно для сценариев общего спроса (как правило, не будет никаких стратегий для сумасшедшего перевода средств...).
Конечно, в фактическом дизайне есть много деталей. Например, при проверке документа мы обнаруживаем, что есть много направлений вращения, поэтому нам нужно контролировать каждое направление вращения. Кодекс определяетvar dicType = {...}Для управления всеми направлениями переводов.
Для лучшего отображения контента мы используем таблицу строки состояния для вывода информации о последних пяти трансферах в интерфейсе стратегии, поэтому мы создаем таблицу под названием:monitorОбъект, используемый для записи данных. Конечно, вы не можете записывать информацию о переводах бесконечно, поэтому мы сохраняем только 100 записей для каждого направления перевода. Если записей больше 100, преждевременные записи будут удалены.
Примеры кода
javascript
function getRecentTransferHistory(TransType, typeDesc) {
// GET /sapi/v1/asset/transfer type, size : 100
var rows = null
var ret = exchange.IO("api", "GET", "/sapi/v1/asset/transfer", `type=${TransType}&size=100`)
Log("/sapi/v1/asset/transfer" + `type=${TransType}&size=100`)
if (ret && typeof(ret.rows) != "undefined" && Array.isArray(ret.rows)) {
rows = ret.rows
} else if (ret && typeof(ret.total) != "undefined" && ret.total == 0) {
rows = []
} else {
Log(TransType, typeDesc, "查询失败", ret)
}
return rows
}
var monitor = {}
function monitorTransfers() {
var dicType = {
"MAIN_UMFUTURE": "现货钱包 --> U本位合约钱包",
"MAIN_CMFUTURE": "现货钱包 --> 币本位合约钱包",
"UMFUTURE_MAIN": "U本位合约钱包 --> 现货钱包",
"UMFUTURE_MARGIN": "U本位合约钱包 --> 杠杆全仓钱包",
"CMFUTURE_MAIN": "币本位合约钱包 --> 现货钱包",
"MARGIN_UMFUTURE": "杠杆全仓钱包 --> U本位合约钱包",
"MARGIN_CMFUTURE": "杠杆全仓钱包 --> 币本位合约钱包",
"CMFUTURE_MARGIN": "币本位合约钱包 --> 杠杆全仓钱包",
"FUNDING_UMFUTURE": "资金钱包 --> U本位合约钱包",
"UMFUTURE_FUNDING": "U本位合约钱包 --> 资金钱包",
"FUNDING_CMFUTURE": "资金钱包 --> 币本位合约钱包",
"CMFUTURE_FUNDING": "币本位合约钱包 --> 资金钱包",
"UMFUTURE_OPTION": "U本位合约钱包 --> 期权钱包",
"OPTION_UMFUTURE": "期权钱包 --> U本位合约钱包",
// 统一账户
"MAIN_PORTFOLIO_MARGIN": "现货钱包 --> 统一账户钱包",
"PORTFOLIO_MARGIN_MAIN": "统一账户钱包 --> 现货钱包"
}
Log("开始检测")
_.each(dicType, function(v, k) {
var rows = getRecentTransferHistory(k, v)
var maxTS = 0
_.each(rows, function(row) {
if (typeof(monitor[k]) == "undefined") {
monitor[k] = {"transType": k, "typeDesc": v, "recentRecords": [], "lastTS": 0}
}
if (row["timestamp"] > monitor[k]["lastTS"]) {
monitor[k]["recentRecords"].push(row)
if (monitor[k]["lastTS"] != 0) {
Log("检测到新增划转记录", k, v, row, "#FF0000")
}
}
maxTS = Math.max(maxTS, row["timestamp"])
})
if (rows && rows.length == 0) {
return
}
monitor[k]["lastTS"] = maxTS
var sortedArrayAscending = monitor[k]["recentRecords"].slice().sort((a, b) => a.timestamp - b.timestamp)
monitor[k]["recentRecords"] = sortedArrayAscending
if (monitor[k]["recentRecords"].length > 100) {
monitor[k]["recentRecords"].shift()
}
Sleep(1000)
})
Log("开始结束")
}
function main() {
LogReset()
while (true) {
monitorTransfers()
var tbls = []
_.each(monitor, function(v, k) {
var tbl = {
"type": "table",
"title": v["typeDesc"],
"cols": ["asset", "amount", "status", "tranId", "time"],
"rows": []
}
var arr = v["recentRecords"].slice().sort((a, b) => b.timestamp - a.timestamp)
for (var i = 0; i < arr.length; i++) {
if (i < 5) {
tbl["rows"].push([arr[i]["asset"], arr[i]["amount"], arr[i]["status"], arr[i]["tranId"], _D(arr[i]["timestamp"])])
}
}
tbls.push(tbl)
})
LogStatus(_D(), "\n", "`" + JSON.stringify(tbls) + "`")
Sleep(1000 * 30)
}
}
Обзор кода:
Предоставленный код JavaScript включает несколько функций, которые вместе создают систему мониторинга последних переводов активов. Давайте разберем основные компоненты:
-
Функция getRecentTransferHistory:
Цель: Получить недавнюю историю переводов активов из API биржи в соответствии с указанными параметрами.
Параметры: TransType (тип передачи), typeDesc (описание типа).
Конечная точка API: /sapi/v1/asset/transfer. -
Функция monitorTransfers:
Назначение: выполняет итерацию по предопределенным типам передач, извлекает последнюю историю передач и регистрирует все новые передачи.
Используйте словарь (dicType) для сопоставления типов переводов с понятными человеку описаниями.
Обновите объект монитора, чтобы отслеживать последние передачи каждого типа. -
основная функция:
Цель: Запустить бесконечный цикл, который непрерывно отслеживает передачи и отображает последние данные.
Периодически используйте функцию monitorTransfers.
Создайте таблицу для каждого типа перевода, включая такие столбцы, как актив, сумма, статус, идентификатор транзакции и временная метка.
Основные характеристики:
-
Динамическое отображение типа передачи:
Код использует словарь (dicType) для сопоставления типов передачи с описательными именами, предоставляя четкое описание характера каждой передачи.
-
Мониторинг в реальном времени:
Система постоянно проверяет наличие новых передач, обновляет объект мониторинга и регистрирует любые обнаруженные изменения.
-
Представление данных:
Используйте таблицу для представления каждого типа данных о переводе, включая соответствующие сведения, такие как актив, сумма, статус, идентификатор транзакции и временная метка.
-
Управление историей последних переводов:
Ведите прокручиваемый список последних переводов для каждого типа, обеспечивая краткое и своевременное отображение.
Реальный тест
Передача была выполнена вручную, и программа обнаружила операцию передачи.
END:
Предоставленный код JavaScript представляет собой мощное решение для мониторинга последних переводов активов на криптовалютных биржах. Его динамичность и работа в режиме реального времени делают его ценным инструментом для трейдеров и разработчиков, стремящихся понять перемещение активов между различными кошельками. Этот код можно изменять и настраивать в соответствии с конкретными потребностями, что обеспечивает надежную основу для тех, кто хочет улучшить свои стратегии торговли криптовалютой или разработать дополнительные возможности мониторинга.
Эта статья — всего лишь отправная точка для идеи дизайна. Надеюсь, ваш криптовалютный бизнес будет и информативным, и успешным!
- 1