Bybit API自动化交易教程：新手也能轻松上手！

2025-03-07 13 次浏览条评论

Bybit API 自动化交易设置教程

简介

本教程旨在指导您逐步掌握如何利用 Bybit API 设置自动化交易系统。Bybit API 是一套强大的工具，允许开发者和交易者将自定义的交易策略无缝集成到 Bybit 交易平台。通过 API 接口，您可以构建程序化交易机器人，执行量化交易策略，进行算法交易，并实现更高级的交易功能，例如自动止损、追踪止损、网格交易等。本教程将涵盖API密钥的生成、API调用的基本结构、常见交易指令的实现以及风险管理策略的应用，旨在帮助您搭建一个稳定且高效的自动化交易系统。

准备工作

在开始之前，请确保您已具备以下条件，以便顺利进行 Bybit API 的开发和集成：

Bybit 账户: 您需要一个已注册且经过身份验证的 Bybit 账户。账户需要完成 KYC 认证，才能启用 API 功能并获得更高的 API 调用频率限制。请务必保管好您的账户信息，避免泄露。
编程知识: 熟悉至少一种编程语言，例如 Python, JavaScript, Go, Java 等。选择您最熟悉的语言，以便更高效地编写和调试代码。对于不同语言，Bybit 提供了相应的 SDK 或示例代码。
API 理解: 了解 API 的基本概念，例如 HTTP 请求方法（GET, POST, PUT, DELETE 等）、请求头、请求体、响应状态码、响应体（JSON 格式）以及 API 身份验证机制（API Key 和 Secret Key）。理解 RESTful API 的设计原则将有助于您更好地使用 Bybit API。
开发环境: 搭建好您的开发环境。对于 Python，您需要安装 `requests` 库，以及可选的 `websockets` 库（用于 WebSocket API）。对于 JavaScript，您可以使用 Node.js 和 npm 包管理器来安装必要的库。确保您的开发环境能够访问互联网，并且防火墙没有阻止 API 请求。推荐使用虚拟环境来隔离项目依赖，避免版本冲突。

获取 Bybit API 密钥

登录 Bybit 账户: 访问 Bybit 官方网站，使用您已注册的用户名和密码安全地登录您的个人账户。请确保您访问的是官方网站，避免钓鱼网站窃取您的登录凭证。启用双因素认证（2FA）可以显著提高账户安全性。
导航至 API 管理页面: 成功登录后，在账户中心或个人资料设置区域查找 "API 管理" 或类似的选项。不同的Bybit页面版本，该选项的位置可能略有差异，一般位于账户安全相关的设置子菜单中。如果找不到，请查阅Bybit的官方帮助文档或联系客服。
创建新的 API 密钥: 在 API 管理页面，点击 "创建 API 密钥" 或类似的按钮。Bybit 可能要求您进行额外的身份验证，例如输入验证码，以确认您的身份。
设置 API 权限: 创建 API 密钥时，仔细配置权限至关重要。通常，您需要勾选 "交易" 权限，以便您的应用程序可以执行交易操作。根据您的具体交易策略，可能还需要授予其他权限，例如 "提现"（如果您的策略涉及自动提现功能）、 "读取账户信息"（用于获取账户余额、持仓信息等）和 "合约数据"（用于获取实时市场数据和历史数据）。 务必遵循最小权限原则，只授予 API 密钥执行其所需功能的最低权限。过多的权限可能会增加账户安全风险。 Bybit 通常会提供详细的权限描述，请仔细阅读每个权限的含义。
生成 API 密钥: 确认所有权限设置后，生成您的 API 密钥，包括 API Key 和 API Secret。API Key 用于标识您的应用程序，而 API Secret 则用于对 API 请求进行签名验证。 务必将 API Secret 视为高度敏感信息，如同您的账户密码一样妥善保管，切勿以任何形式泄露给他人，包括通过电子邮件、聊天工具或代码仓库。 任何能够访问您的 API Secret 的人都可以控制您的 Bybit 账户并造成资金损失。建议将 API Secret 存储在安全的地方，例如加密的配置文件或硬件安全模块（HSM）。
IP 访问限制 (可选但强烈建议): 为了进一步加强安全防护，强烈建议您启用 IP 访问限制。将您的服务器或本地机器的公网 IP 地址添加到允许访问的 IP 列表中。Bybit 将只接受来自这些指定 IP 地址的 API 请求，从而有效阻止未经授权的访问。如果您的服务器 IP 地址会动态变化，您需要定期更新 IP 访问列表。请注意，如果您使用的 VPN 或代理服务器，请使用 VPN 或代理服务器的 IP 地址。正确配置 IP 访问限制可以显著降低 API 密钥被盗用后造成的潜在损失。一些云服务提供商提供专用的安全组或防火墙功能，可以进一步限制对 API 端口的访问。

选择编程语言和库

在加密货币交易和数据分析中，编程语言和相关库的选择至关重要。以下示例使用 Python 编程语言和 pybit 库，这是一个与 Bybit 交易所进行交互的强大工具。 Python 语言以其简洁的语法、丰富的库支持和广泛的应用场景，成为加密货币领域开发者的首选。您可以根据自身的技术背景和项目需求，选择其他合适的编程语言和库，例如 JavaScript、Go 或 Java。

安装 pybit 库:
要开始使用 pybit 库，您需要先进行安装。推荐使用 pip 包管理器，它简化了 Python 包的安装过程。在命令行或终端中执行以下命令即可完成安装：

pip install pybit

如果您使用 Anaconda 环境，则可以使用 conda 包管理器进行安装。conda 提供了更全面的环境管理功能，可以有效解决包之间的依赖关系问题。使用以下命令安装 pybit ：

conda install -c conda-forge pybit
其他常用 Python 库:
除了 pybit 之外，还有许多其他 Python 库在加密货币开发中非常有用。这些库提供了各种功能，例如发送 HTTP 请求、处理数据和执行数值计算。
- requests : 该库用于向交易所或其他 API 端点发送 HTTP 请求。它可以轻松地获取市场数据、提交订单和其他交易相关操作。 requests 库支持各种 HTTP 方法（例如 GET、POST、PUT、DELETE），并提供了灵活的参数设置和身份验证机制。
- pandas : pandas 库是数据分析和处理的强大工具。它提供了 DataFrame 对象，可以方便地存储和操作表格数据。您可以使用 pandas 库来清洗数据、进行统计分析、创建可视化图表等。在加密货币领域， pandas 经常用于分析历史交易数据、计算指标和构建交易策略。
- numpy : numpy 库是 Python 中用于数值计算的基础库。它提供了高性能的多维数组对象（ndarray）和各种数学函数。 numpy 库可以用于执行复杂的数值计算，例如线性代数、傅里叶变换和随机数生成。在加密货币领域， numpy 经常用于计算价格波动率、相关性和其他统计指标。

连接到 Bybit API

与Bybit API建立连接是开始进行自动化交易或数据分析的关键步骤。以下代码片段展示了如何使用 pybit 库通过 HTTP 协议连接到 Bybit API：

from pybit import HTTP
import time

以上代码首先导入了 pybit 库中的 HTTP 模块。 HTTP 模块提供了与 Bybit API 进行交互所需的功能。还导入了 time 模块，它在实际应用中可用于处理时间相关操作，例如控制请求频率或进行时间戳转换。连接 Bybit API 需要API Key和Secret。Bybit提供现货、合约等不同的API，需要根据自己的需求选择。 API Key和Secret可以在Bybit官网的用户中心创建和管理。 API Key和Secret需要妥善保管，避免泄露。

替换为您的 API Key 和 API Secret

在进行加密货币交易或数据分析时，通常需要访问交易所或平台的 API。为了安全地验证您的身份和授权访问权限，您需要提供 API Key 和 API Secret。 API Key 类似于您的用户名，而 API Secret 类似于您的密码，用于加密验证您的身份。

API Key 和 API Secret 通常可以在交易所或平台的开发者控制台中生成。请务必妥善保管您的 API Secret，不要将其泄露给他人，因为这可能会导致您的账户被盗用。

以下代码示例展示了如何在 Python 中设置 API Key 和 API Secret：

api_key = "YOUR_API_KEY"
api_secret = "YOUR_API_SECRET"

请将 "YOUR_API_KEY" 替换为您实际的 API Key，并将 "YOUR_API_SECRET" 替换为您实际的 API Secret。替换完成后，您就可以使用这些密钥来访问交易所或平台的 API，并进行相应的操作，例如获取市场数据、下单交易等。

选择API终端，现货或合约

如果使用USDT永续合约

在使用Bybit交易所的USDT永续合约进行交易时，需要初始化一个HTTP会话对象，用于与Bybit的API进行通信。以下代码展示了如何创建该会话对象：

session = HTTP( endpoint="https://api.bybit.com", # Bybit API endpoint api_key=api_key, api_secret=api_secret )

代码解释：

HTTP(...) ：这是用于创建HTTP会话对象的函数或类。具体的实现细节取决于你使用的Bybit API库。
endpoint="https://api.bybit.com" ：指定Bybit API的访问入口点。所有API请求都将发送到此URL。确保使用官方提供的endpoint，以避免安全风险。对于测试环境，Bybit也可能提供不同的endpoint。
api_key=api_key ：你的Bybit API密钥。API密钥用于身份验证，允许你访问你的Bybit账户并执行交易。API密钥需要妥善保管，避免泄露。
api_secret=api_secret ：你的Bybit API密钥的密钥。API密钥的密钥与API密钥一起使用，用于对API请求进行签名，以确保请求的完整性和真实性。同样，密钥也需要妥善保管。

注意事项：

确保你已经从Bybit获取了有效的API密钥和密钥。
将 api_key 和 api_secret 替换为你自己的实际值。
安全地存储你的API密钥和密钥，避免泄露给他人。
在使用API密钥进行任何交易之前，请仔细阅读Bybit的API文档。
请注意，过度频繁的API请求可能会受到Bybit的速率限制。
使用不同于 https://api.bybit.com 的测试endpoint（例如，用于sandbox环境的endpoint）以进行测试。

如果使用现货交易

session = HTTP(

endpoint="https://api.bybit.com",

apikey=apikey,

apisecret=apisecret

)

如果使用测试网

session = HTTP(

endpoint="https://api-testnet.bybit.com",

apikey=apikey,

apisecret=apisecret

)

检查连接是否成功

为了验证API连接是否成功，可以使用以下代码片段测试与服务器的连接。此过程通过获取服务器时间来实现，这是验证通信渠道畅通性的常见方法。

try:

server_time = session.get_server_time()

print(f"连接成功，服务器时间: {server_time}")

except Exception as e:

print(f"连接失败: {e}")

代码解释：

session.get_server_time() : 此函数调用旨在从交易所服务器检索当前时间戳。成功获取服务器时间表明API密钥有效，网络连接稳定，并且服务器正常运行。

try...except 块 : 这是一个Python异常处理机制。如果 session.get_server_time() 调用因任何原因失败（例如，无效的API密钥、网络问题、服务器维护），则会引发异常。 except 块捕获此异常，并打印一条包含错误信息的连接失败消息。这对于调试连接问题至关重要。

连接失败的潜在原因包括：API密钥错误或未激活、网络连接问题（防火墙阻止、DNS解析失败等）、服务器维护或过载，以及请求频率限制。检查API密钥的有效性，确保网络连接稳定，并查阅交易所的官方文档以了解任何已知的维护或服务中断信息。

常用 API 调用示例

获取账户信息

为了获取用户的账户信息，特别是指定币种（例如USDT）的余额，我们可以使用交易所提供的API接口。以下代码展示了如何通过Python的 session 对象（假设已初始化并与交易所建立连接）调用 get_wallet_balance 方法来获取账户余额。

这段代码的核心在于调用 session.get_wallet_balance(coin="USDT") 方法。 coin="USDT" 参数指定了我们想要查询的币种为USDT（泰达币）。这个方法会向交易所的服务器发送请求，获取与账户相关的USDT余额信息。

为了确保程序的健壮性，我们使用了 try...except 块来捕获可能发生的异常。如果在获取账户信息的过程中发生任何错误（例如，网络连接问题、API调用失败、权限不足等）， except 块中的代码会被执行，打印出错误信息，帮助开发者诊断问题。

示例代码如下：


try:
    account_info = session.get_wallet_balance(coin="USDT")
    print(f"账户信息: {account_info}")
except Exception as e:
    print(f"获取账户信息失败: {e}")

如果成功获取到账户信息， account_info 变量将包含账户的余额和其他相关信息，这些信息将以字典或其他数据结构的形式返回，具体取决于交易所API的实现。然后，我们使用 print(f"账户信息: {account_info}") 语句将账户信息打印到控制台。 f-string 是一种方便的格式化字符串的方式，它可以将变量的值嵌入到字符串中。

在实际应用中，你需要替换 session 对象为你自己的会话对象，并确保你已经正确配置了API密钥和权限。不同的交易所API的调用方式和返回结果可能会有所不同，因此你需要仔细阅读交易所的API文档。

下单

symbol = "BTCUSDT" # 交易对。指定进行交易的货币对，例如这里是比特币兑美元。

side = "Buy" # 买入或卖出。指明交易方向，可以是 "Buy" (买入) 或 "Sell" (卖出)。

order_type = "Market" # 市价单。指定订单类型。 "Market" 表示市价单，会以当前市场最优价格立即成交。也可以使用"Limit"（限价单）等其他订单类型，但需要额外指定价格参数。

qty = 0.001 # 数量。指定交易的数量，例如这里是0.001个比特币。

time_in_force = "GoodTillCancel" # 订单有效期。设定订单的有效时间。"GoodTillCancel" (GTC) 表示订单会一直有效，直到被完全成交或手动取消。其他选项包括 "ImmediateOrCancel" (IOC) 和 "FillOrKill" (FOK)。

try:

order = session.place_order(

symbol=symbol,

side=side,

order_type=order_type,

qty=qty,

time_in_force=time_in_force,

reduce_only=False, # 是否只减仓。设置为 False 表示允许开仓和平仓。设置为 True 则仅允许减少当前仓位，常用于止损或平仓操作。

close_on_trigger=False # 是否触发时平仓。在触发条件单时，如果设置为 True ，表示当条件满足时立即平仓。

)

print(f"下单成功: {order}")

except Exception as e:

print(f"下单失败: {e}")

获取订单信息

为了查询特定订单的详细信息，您需要提供订单ID。请将以下代码中的 YOUR_ORDER_ID 替换为您希望查询的实际订单ID。

order_id = "YOUR_ORDER_ID" # 替换为您的订单 ID

以下代码段演示了如何使用会话对象( session )获取订单信息。该代码块尝试通过提供的 order_id 从交易平台检索订单信息。如果成功，它将格式化并打印订单的详细信息。如果发生任何错误（例如，订单ID无效或网络问题），将捕获异常并打印错误消息，以便于调试。

try:
order_info = session.get_order(order_id=order_id)
print(f"订单信息: {order_info}")
except Exception as e:
print(f"获取订单信息失败: {e}")

代码解释：

session.get_order(order_id=order_id) ：这是调用交易所API来获取订单信息的关键步骤。 session 对象代表与交易所的连接， get_order 方法用于根据提供的 order_id 检索订单数据。
try...except ：这是一个标准的Python异常处理结构。 try 块中的代码会被执行，如果出现任何异常，则会跳转到 except 块。
print(f"订单信息: {order_info}") ：使用f-string格式化输出订单信息。 order_info 变量包含从交易所API返回的订单详细数据。
print(f"获取订单信息失败: {e}") ：如果获取订单信息的过程中发生任何异常，则会打印包含错误信息的提示，帮助用户诊断问题。 e 变量包含异常对象的详细信息。

注意事项：

确保您已正确初始化 session 对象并已连接到交易所API。
订单ID必须是有效的，并且存在于交易所系统中。
get_order 方法的具体实现取决于您使用的交易所API库。请参考相关文档。

撤销订单

在加密货币交易中，撤销订单是交易者管理其仓位和控制风险的关键操作。通过 API 接口，您可以便捷地取消尚未成交的订单。

order_id = "YOUR_ORDER_ID" # 替换为您的订单 ID

务必将 YOUR_ORDER_ID 替换为您要撤销的订单的实际 ID。订单 ID 是交易所分配给每个订单的唯一标识符，您可以在您的交易历史或订单簿中找到它。确保提供的订单 ID 与您希望取消的订单完全匹配，否则可能导致取消错误的订单。

try: cancel_order = session.cancel_order(symbol=symbol, order_id=order_id) print(f"撤销订单成功: {cancel_order}") except Exception as e: print(f"撤销订单失败: {e}")

这段代码块展示了如何使用 API 客户端库（例如 Python 的某个交易所 SDK）来撤销订单。 session.cancel_order() 函数接受至少两个参数：交易对代码（ symbol ）和订单 ID（ order_id ）。 symbol 参数指定了您要撤销订单的交易市场，例如 "BTCUSDT" 或 "ETHBTC"。 order_id 参数指定了要取消的订单的唯一标识符。

try...except 块用于处理可能出现的异常情况。如果撤销订单成功，将打印一条成功消息，其中包含交易所返回的响应信息。如果撤销订单失败（例如，由于订单已成交、订单 ID 不存在或网络连接问题），将捕获 Exception 异常，并打印一条包含错误信息的失败消息。仔细检查错误信息有助于诊断问题并采取适当的措施，例如检查订单 ID 是否正确或重试撤销操作。

获取K线数据

symbol = "BTCUSDT" 交易对，指定要查询的加密货币交易对。例如， "BTCUSDT" 表示比特币兑美元泰达币。请确保交易对在交易所中存在且活跃。

interval = "15" K线周期，指定K线的时间间隔。常用的时间间隔包括：1分钟（ "1" ）、3分钟（ "3" ）、5分钟（ "5" ）、15分钟（ "15" ）、30分钟（ "30" ）、1小时（ "60" ）、2小时（ "120" ）、4小时（ "240" ）、6小时（ "360" ）、12小时（ "720" ）、日线（ "D" ）、月线（ "M" ）、周线（ "W" ）。选择合适的K线周期取决于交易策略和时间范围。

from_time = int(time.time()) - 3600 * 24 * 7 起始时间戳，用于指定K线数据的起始时间。此示例获取的是一周前的数据。 time.time() 返回当前时间的Unix时间戳（秒）， 3600 * 24 * 7 计算的是一周的秒数。

使用 try...except 块捕获潜在的异常，确保程序的健壮性。 session.get_kline(symbol=symbol, interval=interval, from_time=from_time) 调用交易所API获取K线数据。 symbol ， interval 和 from_time 是之前定义的参数。

print(f"K线数据: {klines}") 打印获取到的K线数据，以便调试和分析。 klines 变量包含K线数据，通常是一个包含多个K线信息的列表。

print(f"获取K线数据失败: {e}") 如果获取K线数据失败，则打印错误信息，方便排查问题。 e 变量包含异常信息。

错误处理

在使用 API 的过程中，可能会遇到各种错误。健壮的错误处理机制对于稳定可靠的应用程序至关重要。以下是一些常见的错误处理方法，结合实际场景和最佳实践：

检查 API 返回码: Bybit API 会返回状态码，用于指示请求是否成功。这些状态码是HTTP状态码的扩展应用。常见的状态码包括：
- 200 (成功): 请求成功处理并返回预期结果。
- 400 (错误请求): 服务器无法理解请求，通常是由于请求参数错误或格式不正确。详细查看请求体和URL参数。
- 401 (未授权): 请求需要身份验证，但用户未提供有效的身份验证凭据。检查API密钥和权限设置。
- 403 (禁止访问): 服务器理解请求，但拒绝执行。这可能由于IP限制或账户权限问题。
- 429 (请求过多): 超过了API的请求频率限制。稍后重试，或者优化请求策略以减少请求次数。
- 500 (服务器内部错误): 服务器遇到意外情况，无法完成请求。这通常是服务器端的问题，可以稍后重试或联系技术支持。
- 502 (错误网关): 作为网关或代理的服务器从上游服务器收到无效响应。
- 503 (服务不可用): 服务器暂时无法处理请求，通常是由于服务器过载或维护。
- 504 (网关超时): 服务器作为网关或代理，等待上游服务器响应超时。
阅读错误信息: API 返回的错误信息通常会包含错误原因以及可能的解决方案。仔细阅读错误信息，有助于您快速定位问题，例如缺少必要的参数、参数格式不正确、签名验证失败等。通常，错误信息会提供更具体的错误代码和描述，例如 "code": -1000, "msg": "Invalid API-key, IP whitelist for security." 。

使用 try-except 块: 在Python等编程语言中，使用


   try-except

块捕获异常，避免程序崩溃。例如，可以捕获


   requests.exceptions.RequestException

来处理网络连接错误，捕获


   .JSONDecodeError

来处理JSON解析错误。更精细的错误处理可以针对不同类型的Bybit API错误进行捕获。


try:
    response = requests.get(url, headers=headers)
    response.raise_for_status()  # 抛出HTTPError异常，如果状态码不是200
    data = response.()
except requests.exceptions.RequestException as e:
    print(f"网络错误: {e}")
except .JSONDecodeError as e:
    print(f"JSON解码错误: {e}")
except Exception as e:
    print(f"其他错误: {e}")
else:
    # 请求成功，处理数据
    print(data)

记录日志: 记录 API 请求和响应，包括请求的URL、Headers、请求体、响应状态码、响应内容等，方便您排查问题。使用日志级别（如DEBUG, INFO, WARNING, ERROR）来区分不同严重程度的事件。可以考虑使用Python的


   logging

模块或其他专业的日志库。


import logging

logging.basicConfig(level=logging.INFO, filename='api.log', format='%(asctime)s - %(levelname)s - %(message)s')

try:
    response = requests.get(url, headers=headers)
    response.raise_for_status()
    data = response.()
    logging.info(f"请求成功: URL={url}, 状态码={response.status_code}, 响应={data}")
except requests.exceptions.RequestException as e:
    logging.error(f"网络错误: URL={url}, 错误={e}")
except .JSONDecodeError as e:
    logging.error(f"JSON解码错误: URL={url}, 响应内容={response.text}, 错误={e}")
except Exception as e:
    logging.error(f"其他错误: URL={url}, 错误={e}")

处理请求频率限制: Bybit API 对请求频率有限制。如果您的请求频率过高，可能会收到 429 错误。您可以使用


   time.sleep()

函数来控制请求频率，或者使用更高级的速率限制库，例如


   ratelimit

。更高级的方法包括使用令牌桶算法或漏桶算法来实现更精细的速率控制。需要注意的是，不同的Bybit API接口可能有不同的频率限制，需要仔细阅读API文档。


import time
import requests

# 假设每个接口的请求频率限制为每秒10次
REQUESTS_PER_SECOND = 10
LAST_REQUEST_TIME = 0

def make_api_request(url, headers):
    global LAST_REQUEST_TIME
    now = time.time()
    elapsed_time = now - LAST_REQUEST_TIME

    if elapsed_time < (1 / REQUESTS_PER_SECOND):
        time.sleep((1 / REQUESTS_PER_SECOND) - elapsed_time)

    response = requests.get(url, headers=headers)
    LAST_REQUEST_TIME = time.time()
    return response

# 示例使用
for i in range(20):
    response = make_api_request(url, headers)
    print(f"请求 {i+1}: 状态码={response.status_code}")

策略示例 (简单移动平均线交叉)

以下是一个简单的移动平均线交叉策略示例，仅供参考。它演示了如何使用短期和长期移动平均线来识别潜在的买入和卖出信号。请注意，这只是一个基础示例，实际交易中需要进行更全面的风险管理和参数优化。

import pandas as pd

def simple_moving_average_crossover(symbol, interval, fast_period, slow_period, amount):

"""

简单的移动平均线交叉策略。

Args:
    symbol: 交易对，例如 "BTCUSDT"。指定要交易的加密货币对。
    interval: K线周期，例如 "15" (15分钟)。定义蜡烛图的时间间隔，例如 15 分钟、1 小时或 1 天。较短的周期会产生更多的交易信号，但也可能增加噪音。
    fast_period: 短期移动平均线周期。用于计算短期移动平均线的周期数。例如，如果 interval 是 "15"，fast_period 是 20，则短期移动平均线将基于过去 20 个 15 分钟的蜡烛图计算。
    slow_period: 长期移动平均线周期。用于计算长期移动平均线的周期数。例如，如果 interval 是 "15"，slow_period 是 50，则长期移动平均线将基于过去 50 个 15 分钟的蜡烛图计算。
    amount: 每次交易的金额。指定每次交易中要使用的金额（例如，美元）。
"""

while True:
    # 获取 K 线数据
    from_time = int(time.time()) - 3600 * 24 * 7  # 获取一周前的数据，确保有足够的数据计算移动平均线。可以根据需要调整时间范围。
    try:
        klines = session.get_kline(symbol=symbol, interval=interval, from_time=from_time)
    except Exception as e:
        print(f"获取 K 线数据失败: {e}")
        time.sleep(60)  # 等待 60 秒后重试，应对API调用失败的情况。
        continue

    if klines and klines['ret_msg'] == 'OK':
        df = pd.DataFrame(klines['result'])
        df['close'] = pd.to_numeric(df['close'])

        # 计算移动平均线
        df['fast_ma'] = df['close'].rolling(window=fast_period).mean()
        df['slow_ma'] = df['close'].rolling(window=slow_period).mean()

        # 判断是否产生交叉
        if df['fast_ma'].iloc[-1] > df['slow_ma'].iloc[-1] and df['fast_ma'].iloc[-2] <= df['slow_ma'].iloc[-2]:
            # 金叉，买入。短期移动平均线向上穿过长期移动平均线，表明潜在的上升趋势。
            side = "Buy"
            order_type = "Market"
            qty = amount / df['close'].iloc[-1] #根据金额计算数量。根据交易金额和当前价格计算购买数量。
            try:
                order = session.place_order(
                    symbol=symbol,
                    side=side,
                    order_type=order_type,
                    qty=qty,
                    time_in_force="GoodTillCancel",
                    reduce_only=False,
                    close_on_trigger=False
                )
                print(f"金叉，买入: {order}")
            except Exception as e:
                print(f"下单失败: {e}")

        elif df['fast_ma'].iloc[-1] < df['slow_ma'].iloc[-1] and df['fast_ma'].iloc[-2] >= df['slow_ma'].iloc[-2]:
            # 死叉，卖出。短期移动平均线向下穿过长期移动平均线，表明潜在的下降趋势。
            side = "Sell"
            order_type = "Market"
            qty = amount / df['close'].iloc[-1] #根据金额计算数量。根据交易金额和当前价格计算出售数量。
            try:
                order = session.place_order(
                    symbol=symbol,
                    side=side,
                    order_type=order_type,
                    qty=qty,
                    time_in_force="GoodTillCancel",
                    reduce_only=False,
                    close_on_trigger=False
                )
                print(f"死叉，卖出: {order}")
            except Exception as e:
                print(f"下单失败: {e}")
    else:
        print("K线数据为空或获取失败")

    time.sleep(60)  # 每隔 60 秒检查一次，避免过于频繁的API调用。可以根据需要调整休眠时间。

设置策略参数

在加密货币交易策略中，参数配置是至关重要的一步，它直接影响策略的有效性和盈利能力。以下参数是策略中常用的核心配置：

symbol = "BTCUSDT" ：交易对的选择。 symbol 参数定义了策略将要交易的加密货币对。在这个例子中，我们选择了 "BTCUSDT"，表示比特币（BTC）与泰达币（USDT）的交易对。交易对的选择应该基于市场流动性、波动性以及个人风险偏好等因素。

interval = "15" ：K线图的时间周期。 interval 参数设定了策略分析和执行交易所依赖的K线图的时间周期。这里选择了 "15"，表示 15 分钟的K线图。不同的时间周期会影响策略的灵敏度和交易频率。较短的时间周期会产生更多的交易信号，但也可能增加噪音和错误信号的风险。

fast period = 5 ：快速移动平均线的周期。 fast period 参数定义了快速移动平均线计算所使用的时间周期。在这个例子中，设置为 5，意味着计算过去 5 个周期的价格平均值。快速移动平均线通常用于捕捉短期价格趋势。

slow period = 20 ：慢速移动平均线的周期。 slow period 参数定义了慢速移动平均线计算所使用的时间周期。这里设置为 20，意味着计算过去 20 个周期的价格平均值。慢速移动平均线通常用于识别长期价格趋势。快速线和慢速线的交叉通常作为买入或卖出信号。

amount = 10 ：每次交易的金额。 amount 参数指定了每次交易投入的资金量。这里设置为 10 USDT，意味着每次交易将使用 10 个泰达币。资金量的选择应该基于风险承受能力、账户余额和策略风险管理规则。适当的资金管理能够降低爆仓风险，并使策略更具可持续性。

运行策略

simplemovingaveragecrossover(symbol, interval, fastperiod, slow_period, amount) #取消注释以运行策略

注意：此策略仅为示例，并未经过充分测试。在实际使用前，请务必进行回测和风险评估。并且需要根据实际情况进行调整。此外，还应该加入止损，止盈等风控措施。

安全注意事项

保护 API 密钥: API 密钥（API Key）和 API 密钥Secret（API Secret）是访问 Bybit API 的凭证，务必将其视为最高机密。不要将它们存储在不安全的地方，如代码库、公共论坛或共享文档中。使用环境变量或密钥管理系统来安全地存储这些凭证。 API Secret 应当像密码一样保护，任何泄露都可能导致资金损失或数据泄露。
设置 IP 访问限制: 为了增加安全性，强烈建议设置 IP 访问限制。这允许您指定可以从哪些特定的 IP 地址向 Bybit API 发送请求。您可以在 Bybit 账户的 API 管理页面配置 IP 白名单，仅允许来自受信任 IP 地址的 API 请求，从而阻止未经授权的访问。确保您的服务器 IP 地址是静态的，否则，每次 IP 地址更改时都需要更新白名单。
最小权限原则: 在创建 API 密钥时，只赋予其执行所需操作的最低权限。例如，如果您的应用程序只需要读取市场数据，则不要授予交易权限。Bybit API 允许您细粒度地控制 API 密钥的权限，例如只允许访问特定的交易对或限制提现功能。这有助于最大限度地减少潜在的损害，如果 API 密钥被盗用。
定期更换 API 密钥: 定期更换 API 密钥是维护安全性的重要措施。即使您的 API 密钥没有泄露，也建议定期轮换，以减少潜在的风险。Bybit 允许您生成新的 API 密钥并禁用旧密钥。建议您制定一个密钥轮换计划，并确保您的应用程序能够自动适应新的 API 密钥。
监控 API 使用情况: 密切监控 API 的使用情况，包括请求频率、错误率和交易活动。 Bybit 提供 API 使用统计信息，您可以利用这些信息来检测异常行为，例如突然的请求量激增或来自未知 IP 地址的请求。及时发现和响应这些异常情况可以帮助您防止潜在的安全事件。考虑设置警报，以便在检测到可疑活动时收到通知。
仔细阅读 Bybit API 文档: Bybit API 文档包含了关于每个 API 接口的详细信息，包括参数、返回值、错误代码和速率限制。仔细阅读文档可以帮助您避免常见的错误，并确保您的应用程序能够正确地与 API 交互。了解 API 的限制可以帮助您优化您的应用程序，避免超出速率限制，并提高性能。
使用测试网进行测试: 在将您的应用程序部署到生产环境之前，务必在 Bybit 测试网进行充分的测试。测试网是一个模拟真实交易环境的沙箱，允许您在不冒真金白银风险的情况下测试您的代码。使用测试网可以帮助您发现潜在的错误和安全漏洞，并确保您的应用程序能够按预期工作。在测试网中，您可以模拟各种交易场景，并测试您的错误处理逻辑。

常见问题

API 密钥无效:
请仔细检查您的 API Key 和 API Secret 是否正确。确保复制粘贴时没有遗漏或错误。另外，核实您的 API 密钥是否已经过期或被禁用。部分交易所会定期轮换密钥，或在安全事件后禁用密钥。登录 Bybit 账户，在 API 管理页面重新生成或激活密钥。
请求频率过高:
Bybit API 对请求频率有限制，是为了防止滥用和维护服务器稳定。您需要控制请求频率，避免超过 Bybit API 的限制。具体的频率限制可以在 Bybit API 文档中找到。可以考虑使用队列或延迟机制来控制请求速率，避免触发限流。
权限不足:
API 密钥需要具有执行所需操作的权限。在创建 API 密钥时，务必检查并确认您已授予密钥足够的权限，例如交易、提现或查询账户信息等。不同的交易策略可能需要不同的权限，请根据您的实际需求进行配置。例如，进行现货交易需要现货交易权限，进行合约交易则需要合约交易权限。务必仔细阅读Bybit的API文档，了解不同权限的具体作用。
签名错误:
签名是验证 API 请求完整性和身份的关键。请检查签名算法是否正确，并确保时间戳有效。签名算法通常包括对请求参数进行排序、拼接，然后使用 API Secret 进行哈希运算。时间戳必须是当前时间，并且在 Bybit 允许的误差范围内。时间戳的准确性对于签名验证至关重要，请确保您的系统时间与网络时间同步。另外，仔细检查请求参数的排序和编码方式，确保与 Bybit API 的要求一致。
网络连接问题:
确保您的网络连接正常。检查您的服务器是否可以访问 Bybit API 的 endpoint。可以尝试使用 `ping` 或 `traceroute` 命令来诊断网络连接问题。防火墙设置、代理服务器或 DNS 解析问题都可能导致网络连接失败。请确保您的网络环境稳定，避免因网络波动导致 API 请求失败。

本教程提供了 Bybit API 自动化交易设置的基本步骤和示例代码。您可以通过学习 Bybit API 文档 (务必仔细阅读官方文档，了解最新的 API 规则和参数)，并参考其他开源项目和社区资料，构建更复杂的交易策略，例如网格交易、套利交易或趋势跟踪策略。同时，请重视风险管理，设置止损和止盈，并定期监控您的交易策略的表现。

HTX vs OKX：BCH交易，谁才是你的最佳选择？ Upbit 期货套期保值：稳赚不赔？三种策略详解与实战案例！