websocket 流式传输 交易订单更新

这篇具有很好参考价值的文章主要介绍了websocket 流式传输 交易订单更新。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。


对于从事加密货币行业的任何人来说,使用 REST api 从交易所查询实时数据并不总是最佳做法,原因有很多:
  • 效率低下:每个查询都需要时间,并且会显着影响性能,尤其是对于高频策略。
  • 交易所施加的限制很容易被打破,例如Binance的硬限制为每分钟 1200 个请求权重。
  • 您只能检索有限数量的历史数据,这也限制了回测的可能性。

因此,本文将介绍一种使用Websocket的替代方法,与 REST 相比,它具有更高的效率,并让您有机会从交易所流式传输实时数据并存储它以供将来分析或回测。

那么下面,就让我们一起来使用websocket来推送我们的账户信息


1.获取Binance API和Secret

如果您熟悉这些步骤,则可以跳过此会话。只需确保您将其设置为预期目的:现货和保证金交易或期货交易或两者兼而有之。

  1. 登录您的币安账户。
  2. 转到您的个人资料,然后在 API 管理页面下,输入新的 API 密钥名称以“创建”。
  3. Binance 会从您的电子邮件中索取代码,并从您的身份验证应用程序中索取代码。输入代码并单击“提交”。
  4. 现在已创建新的 API 密钥。请注意,密钥仅在这一步对您可见,之后将被隐藏。因此,请记住妥善保存它以备将来参考。
  5. 编辑 API 密钥权限。
  6. 通过从您的身份验证应用程序输入代码来保存更改。

2. 流式订单更新

与用于市场数据流的端点和通道不同,要流式传输订单和帐户更新,您需要创建一个具有唯一监听密钥的用户数据流,每次启动新连接时都需要生成它。

2.1. 生成监听键

Spot 和 Futures 的基本 API 端点不同:

  • 币安现货和保证金:https 😕/api.binance.com
  • 币安合约: https 😕/fapi.binance.com

在这里,我们使用币安的golang版本的的SDk

  • 安装
go get github.com/adshao/go-binance/v2
  • 设置

API 服务的初始化客户端。从您的币安账户获取 APIKey/SecretKey。

var (
    apiKey = "your api key"
    secretKey = "your secret key"
)
client := binance.NewClient(apiKey, secretKey)
futuresClient := binance.NewFuturesClient(apiKey, secretKey)    // USDT-M Futures
deliveryClient := binance.NewDeliveryClient(apiKey, secretKey)  // Coin-M Futures

一个服务实例代表一个 REST API 端点,由 client.NewClient 函数初始化。

只需以链式方式调用 API。最后调用 Do() 发送 HTTP 请求。

  • 获取用户流监听key
func GetListenKey(t *testing.T) {
	client := binance.NewClient(apiKey, secretKey)

	listenKey, err := client.NewStartUserStreamService().Do(context.Background())
	if err != nil {
		fmt.Println(err)
		return
	}
	fmt.Println(listenKey)
}
  • curl获取listenKey
# curl -H "X-MBX-APIKEY: MY-APIKEY" -X 'POST' https://api.binance.com/api/v3/userDataStream
{"listenKey":"listenKey"}

2.2. Websocket 端点

Spot 和 Futures 的基本 websocket 端点:

  • 币安现货和保证金:wss://stream.binance.com:9443
  • 币安期货:wss://fstream.binance.com或wss://fstream-auth.binance.com

2.3. 流媒体连接

使用listen_key生成的和符合流媒体需求的 websocket 端点,详细代码如下:

func TestWsUserDataServe(t *testing.T) {
	wsHandler := func(event *binance.WsUserDataEvent) {
		fmt.Println(event)
	}
	errHandler := func(err error) {
		fmt.Println(err)
	}
	doneC, _, err := binance.WsUserDataServe(listenKey, wsHandler, errHandler)
	if err != nil {
		fmt.Println(err)
		return
	}
	<-doneC
}

将第 8 行替换listenKey为第 1 步中生成的 API 密钥。

2.4. 消息处理

2.4.1 订单更新

收到的消息将采用以下格式。对于事件类型"executionReport"(订单更新):

{
  "e": "executionReport",        // 事件类型
  "E": 1499405658658,            // 事件时间
  "s": "ETHBTC",                 // 交易对
  "c": "mUvoqJxFIILMdfAW5iGSOW", // clientOrderId
  "S": "BUY",                    // 订单方向
  "o": "LIMIT",                  // 订单类型
  "f": "GTC",                    // 有效方式
  "q": "1.00000000",             // 订单原始数量
  "p": "0.10264410",             // 订单原始价格
  "P": "0.00000000",             // 止盈止损单触发价格
  "d": 4,                        // 追踪止损(Trailing Delta) 只有在追踪止损订单中才会推送.
  "F": "0.00000000",             // 冰山订单数量
  "g": -1,                       // OCO订单 OrderListId
  "C": "",                       // 原始订单自定义ID(原始订单,指撤单操作的对象。撤单本身被视为另一个订单)
  "x": "NEW",                    // 本次事件的具体执行类型
  "X": "NEW",                    // 订单的当前状态
  "r": "NONE",                   // 订单被拒绝的原因
  "i": 4293153,                  // orderId
  "l": "0.00000000",             // 订单末次成交量
  "z": "0.00000000",             // 订单累计已成交量
  "L": "0.00000000",             // 订单末次成交价格
  "n": "0",                      // 手续费数量
  "N": null,                     // 手续费资产类别
  "T": 1499405658657,            // 成交时间
  "t": -1,                       // 成交ID
  "I": 8641984,                  // 请忽略
  "w": true,                     // 订单是否在订单簿上?
  "m": false,                    // 该成交是作为挂单成交吗?
  "M": false,                    // 请忽略
  "O": 1499405658657,            // 订单创建时间
  "Z": "0.00000000",             // 订单累计已成交金额
  "Y": "0.00000000",              // 订单末次成交金额
  "Q": "0.00000000"              // Quote Order Qty
  "j": 1,                        // Strategy ID; 下单时填上字段才会返回
  "J": 1000000                   // Strategy Type; 下单时填上字段才会返回
}

可能的执行类型:

  • NEW 新订单
  • CANCELED 订单被取消
  • REPLACED (保留字段,当前未使用)
  • REJECTED 新订单被拒绝 (这信息只会在撤消挂单再下单中发生,下新订单被拒绝但撤消挂单请求成功。)
  • TRADE 订单有新成交
  • EXPIRED 订单失效(根据订单的Time In Force参数)

如果订单是OCO(二选一订单),则除了显示"executionReport"事件外,还将显示一个名为"ListStatus"的事件。

{
  "e": "listStatus",                // 事件类型
  "E": 1564035303637,               // 事件时间
  "s": "ETHBTC",                    // 交易对
  "g": 2,                           // OrderListId
  "c": "OCO",                       // Contingency Type
  "l": "EXEC_STARTED",              // List Status Type
  "L": "EXECUTING",                 // List Order Status
  "r": "NONE",                      // List 被拒绝的原因
  "C": "F4QN4G8DlFATFlIUQ0cjdD",    // List Client Order ID
  "T": 1564035303625,               // 成交时间
  "O": [                           
    {
      "s": "ETHBTC",                // 交易对
      "i": 17,                      // orderId
      "c": "AJYsMjErWJesZvqlJCTUgL" // clientOrderId
    },
    {
      "s": "ETHBTC",
      "i": 18,
      "c": "bfYPSQdLoqAJeNrOr9adzq"
    }
  ]
}

2.4.2 余额更新

"balanceUpdate"从账户存款或取款的事件类型:

当下列情形发生时更新:

  • 账户发生充值或提取
  • 交易账户之间发生划转(例如 现货向杠杆账户划转)
{
  "e": "balanceUpdate",         // 事件类型
  "E": 1573200697110,           // 事件时间
  "a": "ABC",                   // 资产
  "d": "100.00000000",          // 余额变更
  "T": 1573200697068            // 具体时间
}

2.4.3 账户更新

每当帐户余额发生更改时,都会发送一个事件outboundAccountPosition,其中包含可能由生成余额变动的事件而变动的资产。

{
  "e": "outboundAccountPosition", // 事件类型
  "E": 1564034571105,             // 事件时间
  "u": 1564034571073,             // 账户末次更新时间戳
  "B": [                          // 余额
    {
      "a": "ETH",                 // 资产名称
      "f": "10000.000000",        // 可用余额
      "l": "0.000000"             // 冻结余额
    }
  ]
}

2.5 事件处理

按照不同的事件类型,处理消息,代码如下


func TestWsUserDataServe(t *testing.T) {
	wsHandler := func(event *binance.WsUserDataEvent) {
		fmt.Println(event)
		//账户更新事件
		if event.Event == "outboundAccountPosition" {
			AccountUpdate := event.AccountUpdate
			fmt.Println(AccountUpdate)
		}
		//余额更新事件
		if event.Event == "balanceUpdate" {
			balanceUpdate := event.BalanceUpdate
			fmt.Println(balanceUpdate)
			//现货交易订单更新事件
			if event.Event == "executionReport" {
				orderUpdate := event.OrderUpdate
				fmt.Println(orderUpdate)
			}
			//OCO交易订单更新事件
			if event.Event == "outboundAccountPosition" {
				OCOUpdate := event.OCOUpdate
				fmt.Println(OCOUpdate)
			}
		}
	}
	errHandler := func(err error) {
		fmt.Println(err)
	}
	doneC, _, err := binance.WsUserDataServe(listenKey, wsHandler, errHandler)
	if err != nil {
		fmt.Println(err)
		return
	}
	<-doneC
}

2.6 补充说明

  • 用户数据流在创建后60 分钟内有效listenKey。为防止超时并使其保持活动状态,建议大约每 30 分钟发送一次 ping。

  • 在 a PUT上执行 a listenKey将其有效期延长 60 分钟。

  • 在 a DELETE上执行 a listenKey将关闭流并使listenKey.
    stream.binance.com的单次连接 仅在24 小时内有效;确实希望在 24 小时标记断开连接。

具体代码如下

  • 延长60分钟有效期
//定时30分钟给listenKey续期
time.Sleep(1800 * time.Second)
func TestPutListenKey(t *testing.T) {
	client := binance.NewClient(apiKey, secretKey)


	err := client.NewKeepaliveUserStreamService().ListenKey(listenKey).Do(context.Background())
	if err != nil {
		fmt.Println(err)
	}
}
  • 立即关闭当前数据流
func TestCloseListenKey(t *testing.T) {
	client := binance.NewClient(apiKey, secretKey)

	err := client.NewCloseUserStreamService().ListenKey(listenKey).Do(context.Background())
	if err != nil {
		fmt.Println(err)
	}
}

参考链接:文章来源地址https://www.toymoban.com/news/detail-417534.html

  • Binance Websocket账户信息推送
    官方文档:https://binance-docs.github.io/apidocs/spot/cn/#websocket-2
  • Binance golang sdk:https://github.com/adshao/go-binance
  • Binance websocket账户接口:https://github.com/binance/binance-spot-api-docs/blob/master/user-data-stream_CN.md
  • 使用 Python 流式传输 Binance 订单更新:https://medium.com/coinmonks/streaming-binance-order-updates-using-python-90520e0d307f#ef2e

到了这里,关于websocket 流式传输 交易订单更新的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 首个支持RWA交易的订单簿DEX-PoseiSwap,即将开启IEO

    随着 DeFi 世界的发展,越来越多的链上协议支持以合成资产的方式,将传统金融资产以加密资产的形式映射至链上,包括美股、黄金期货等等,虽然这种方式进一步帮助投资者,以非许可的形式丰富了投资标的,但这种方式缺乏合规性保障。与此同时,链上 DEX 基本都是以

    2024年02月08日
    浏览(55)
  • Debezium日常分享系列之:流式传输 Cassandra

    选择Cassandra 这个 NoSQL 数据库,主要是因为它的高可用性、水平可扩展性以及处理高写入吞吐量的能力。 将 Cassandra 引入我们的基础设施后,我们的下一个挑战是找到一种方法将 Cassandra 中的数据公开给我们的数据仓库 BigQuery,以进行分析和报告。我们快速构建了一个 Airflow

    2024年02月13日
    浏览(48)
  • 用于流式传输自由视点视频的神经残余辐射场

    提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档 本周主要阅读了2023CVPR的文章,用于流式传输自由视点视频的神经残余辐射场,在文章中讲解了一种基于神经残余辐射场实现流式传输自由视点视频的方法,其主要思路就是建模时空特征空间中相邻时间

    2024年01月22日
    浏览(51)
  • vue使用websocket语音识别连续流式输出

    首先安装recorder-core依赖 npm i recorder-core 第一部分html,按钮,显示文本 第二部分:record.js文件,录音文件放入utils文件中,在vue页面中引入使用 将record.js引入 css

    2024年02月13日
    浏览(35)
  • 实时云渲染服务:流式传输 VR 和 AR 内容

    想象一下无需专用的物理计算机,甚至无需实物连接,就能获得高质量的 AR/VR 体验是种什么样的体验? 过去,与 VR 交互需要专用的高端工作站,并且根据头显、壁挂式传感器和专用的物理空间。VR 中的复杂任务会突破传感器范围、电缆长度和空间边界的限制,使艺术家陷入

    2024年01月18日
    浏览(41)
  • Debezium日常分享系列之:流式传输Cassandra第二部分

    在本博客文章系列的前半部分中,解释了Cassandra 设计流数据管道的决策过程。在这篇文章中,我们将把管道分为三个部分,并更详细地讨论每个部分: Cassandra 到 Kafka 与 CDC 代理 Kafka 与 BigQuery 和 KCBQ 使用 BigQuery 视图进行转换 相关技术博客: Debezium日常分享系列之:流式传输

    2024年02月16日
    浏览(45)
  • chatGPT流式输出前端实现fetch、SSE、websocket

    fetch 本身不直接支持流式输出,但你可以使用 ReadableStream 和 TextDecoder 等 Web Streams API 来实现类似的效果。 在 SSE 中,浏览器通过发送 HTTP GET 请求到服务器上特定的 SSE 端点(endpoint),然后服务器通过该连接发送事件(event)和相关数据到客户端,故SSE 主要使用 GET 请求。E

    2024年02月04日
    浏览(41)
  • Spring Task 实现定时任务 以及 WebSocket 实现 订单提醒 (学习笔记)

    1.maven坐标 spring-context 2.启动类添加注解 @EnableScheduling 开启任务调度 3.自定义定时任务类 去设置网站设置要 进行得定时任务 cron表达式在线生成器:https://cron.qqe2.com/ 1.导入maven坐标 2.导入websocket组件 3.设置配置类 4.导入代码 前端测试代码

    2024年02月20日
    浏览(42)
  • 使用 Python 流式传输来自 OpenAI API 的响应:分步指南

    OpenAI API 提供了大量可用于执行各种 NLP 任务的尖端 AI 模型。但是,在某些情况下,仅向 OpenAI 发出 API 请求可能还不够,例如需要实时更新时。这就是服务器发送事件 (SSE) 发挥作用的地方。 SSE 是一种简单有效的技术,用于将数据从服务器实时流式传输到客户端。 如何在 W

    2023年04月19日
    浏览(68)
  • 微信小程序WebSocket实现stream流式聊天对话功能

    要在微信小程序实现聊天对话功能,回话是流式应答,这里使用了WebSocket技术。WebSocket大家应该都很熟悉,使用wx.connectSocket就可以了。这里可能需要注意下的是流式应答,后端如何发送,前端如何接收。直接上代码: 可以扫码体验: 后端关键代码: 小程序ts代码: 可以扫码

    2024年04月10日
    浏览(86)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包