Coinbase API自动交易教程：新手入门与实战指南

2025-03-04 67 次浏览条评论

Coinbase API 自动交易指南：从入门到实践

前言

Coinbase 提供了强大且全面的 API（应用程序编程接口），开发者可以借助它构建复杂的自动交易机器人，进而显著简化加密货币交易流程，并完全依据预先设定的交易策略自动执行买卖操作。Coinbase API 不仅仅是一个简单的接口，它更像是一个连接开发者与数字资产市场的桥梁，让开发者能够深入掌控交易逻辑，实现个性化交易策略。本文将深入探讨如何高效利用 Coinbase API 构建和部署自动交易系统，内容涵盖从环境设置到策略执行的各个关键环节，并提供详细的步骤分解和可直接运行的示例代码，旨在帮助读者快速上手，并具备独立开发自动交易应用的能力。

准备工作：API 密钥和权限

为了能够安全且有效地进行自动交易，你需要在 Coinbase 平台上创建并配置 API 密钥。请确保你拥有一个 Coinbase Pro 账户，因为 Coinbase API 主要与 Pro 平台对接。登录你的 Coinbase Pro 账户，找到 API 密钥管理页面，通常位于账户设置或安全设置中。

在创建新的 API 密钥时，务必仔细评估并授予必要的权限。权限控制着你的 API 密钥可以访问哪些资源和执行哪些操作。对于典型的自动交易策略，你需要以下核心权限：

trade ：这是至关重要的权限，它允许你的应用程序执行买入和卖出交易。没有此权限，你将无法进行任何实际的交易操作。
wallet:accounts:read ：此权限允许你的应用程序读取你的 Coinbase Pro 账户信息，例如各个币种的余额。这是跟踪你的投资组合和确保交易不会超出可用资金的重要权限。
wallet:addresses:read ：此权限允许你的应用程序读取你的钱包地址。虽然在自动交易的核心流程中可能不直接使用，但在某些需要验证或转账的场景下，此权限可能很有用。
wallet:buys:create (可选，取决于你的策略)：如果你的自动交易策略包括自动买入加密货币，你需要授予此权限。它允许你的应用程序创建新的买入订单。
wallet:sells:create (可选，取决于你的策略)：如果你的自动交易策略包括自动卖出加密货币，你需要授予此权限。它允许你的应用程序创建新的卖出订单。

重要提示： 在授予 API 密钥权限时，请始终遵循最小权限原则。只授予你的应用程序实际需要的权限，不要授予不必要的权限，以降低安全风险。妥善保管你的 API 密钥，避免泄露，并定期审查和更新你的密钥。

注意：请妥善保管你的 API 密钥，不要泄露给他人。建议将 API 密钥存储在安全的地方，例如环境变量或加密配置文件中。

开发环境搭建

选择你熟悉的编程语言。Python 因其拥有强大的第三方库生态系统和简洁的语法，成为开发加密货币相关应用程序和与交易所 API 交互的热门选择。为了确保开发过程的顺利进行，需要安装一些必要的 Python 库，这些库将极大地简化 API 请求的发送和敏感信息的管理。

使用以下命令通过 pip 包管理器安装所需的库：

pip install requests python-dotenv

requests ：这是一个流行的 Python 库，专门用于发送 HTTP 请求。它允许你的程序与 Coinbase API 建立连接，并执行各种操作，如获取市场数据、创建订单和管理账户信息。 requests 库简化了发送各种类型的 HTTP 请求（例如 GET、POST、PUT、DELETE）的过程，并提供了处理响应的便捷方法。
python-dotenv ：该库的作用是从 .env 文件中加载环境变量。在开发过程中，尤其是涉及到 API 密钥等敏感信息时，直接将这些信息硬编码在代码中是非常不安全的。 python-dotenv 允许你将这些敏感信息存储在 .env 文件中，并在运行时通过读取该文件来获取这些信息，从而避免了敏感信息泄露的风险。

为了安全地存储你的 API 密钥和其他敏感配置信息，创建一个名为 .env 的文件。这个文件应该位于你的项目根目录下，并且不应该被提交到版本控制系统（例如 Git）。将你的 API 密钥按照以下格式存储在 .env 文件中：

COINBASE_API_KEY="YOUR_API_KEY"
COINBASE_API_SECRET="YOUR_API_SECRET"
COINBASE_API_PASSPHRASE="YOUR_API_PASSPHRASE"

请务必将 YOUR_API_KEY 、 YOUR_API_SECRET 和 YOUR_API_PASSPHRASE 替换为你从 Coinbase 获得的实际 API 密钥、API 密钥秘钥和 API 密钥密码。这些凭证对于访问你的 Coinbase 账户和执行交易至关重要，因此需要妥善保管。将 .env 文件添加到你的 .gitignore 文件中，以防止意外地将这些敏感信息提交到代码仓库。

身份验证

Coinbase API 使用 HMAC (Hash-based Message Authentication Code) 机制来确保请求的真实性和完整性。这种身份验证方法依赖于共享密钥，即你的 API 密钥和 API 密钥密码，结合当前时间戳来生成独特的签名。该签名附加到每个 API 请求的头部，服务器通过验证该签名来确认请求的来源和内容未被篡改。

HMAC 的核心在于利用加密哈希函数（如 SHA256）和密钥，对请求内容进行哈希运算。由于只有客户端和服务器拥有相同的密钥，因此只有授权的客户端才能生成有效的签名。时间戳的使用进一步防止了重放攻击，即攻击者截获并重用之前的请求。下面提供一个 Python 函数示例，用于生成适用于 Coinbase API 的请求头部：

import os import requests import time import hmac import hashlib from dotenv import load_dotenv

这段代码片段导入了必要的 Python 库。 os 模块用于访问环境变量， requests 库用于发送 HTTP 请求， time 库用于获取当前时间戳， hmac 和 hashlib 库用于生成 HMAC 签名， dotenv 库用于从 .env 文件加载环境变量。使用 .env 文件有助于安全地管理 API 密钥和密码，避免将其硬编码到代码中。

load_dotenv()

调用 load_dotenv() 函数会从项目根目录下的 .env 文件中加载环境变量。确保创建一个 .env 文件，并将你的 API 密钥、密码和 API 地址添加到该文件中。例如：

COINBASE_API_KEY=your_api_key
COINBASE_API_SECRET=your_api_secret
COINBASE_API_PASSPHRASE=your_api_passphrase

API_KEY = os.getenv("COINBASE_API_KEY") API_SECRET = os.getenv("COINBASE_API_SECRET") API_PASSPHRASE = os.getenv("COINBASE_API_PASSPHRASE") API_URL = "https://api.coinbase.com/v2" # Coinbase API v2

这些行代码从环境变量中检索 API 密钥、密码和 API URL，并将它们存储在相应的变量中。请务必使用实际的 API 密钥、密码和 URL 替换占位符。 API_URL 设置为 Coinbase API 的版本 2，这是当前推荐的版本。

def get_auth_headers(method, path, body=''): timestamp = str(int(time.time())) message = timestamp + method + path + body hmac_key = API_SECRET.encode('utf-8') message = message.encode('utf-8') signature = hmac.new(hmac_key, message, hashlib.sha256).hexdigest()

get_auth_headers 函数接收 HTTP 方法（例如 GET 、 POST 、 PUT 、 DELETE ）、API 路径和请求正文（如果存在）作为参数。该函数首先获取当前时间戳，并将其转换为字符串。然后，将时间戳、HTTP 方法、API 路径和请求正文连接成一个字符串，作为 HMAC 算法的输入消息。API 密钥密码用作 HMAC 密钥。 hmac.new 函数创建一个新的 HMAC 对象，使用 SHA256 哈希函数对消息进行哈希运算。 hexdigest() 方法将哈希值转换为十六进制字符串，作为签名。

return {
    'CB-ACCESS-SIGN': signature,
    'CB-ACCESS-TIMESTAMP': timestamp,
    'CB-ACCESS-KEY': API_KEY,
    'CB-ACCESS-PASSPHRASE': API_PASSPHRASE,
     'Content-Type': 'application/'
}

该函数返回一个包含以下键值对的字典： CB-ACCESS-SIGN （HMAC 签名）、 CB-ACCESS-TIMESTAMP （时间戳）、 CB-ACCESS-KEY （API 密钥）和 CB-ACCESS-PASSPHRASE （API 密钥密码）。这些头部必须包含在每个发送到 Coinbase API 的请求中。 'Content-Type' 被设置为 'application/'，表明请求正文应采用 JSON 格式。

获取账户信息

可以使用以下代码获取你的账户信息，包括可用余额、持有余额等更详细的账户状态信息。该代码示例展示了如何通过 API 请求获取账户数据，并解析返回的 JSON 数据以显示账户的各项属性。

def get_accounts(): endpoint = "/accounts" method = "GET" url = API_URL + endpoint headers = get_auth_headers(method, endpoint) response = requests.get(url, headers=headers) response.raise_for_status() # 抛出 HTTPError，以处理错误，确保请求成功 return response.()

accounts = get_accounts() for account in accounts['data']: print(f"Account ID: {account['id']}") print(f"Currency: {account['currency']}") print(f"Balance: {account['balance']['amount']} {account['balance']['currency']}") print("-" * 20)

这段代码首先定义了一个 get_accounts 函数，该函数向 API 发送 GET 请求以获取账户信息。 API_URL 变量应替换为实际的 API 端点地址。 get_auth_headers 函数负责生成包含身份验证信息的 HTTP 头部，确保请求具有访问账户信息的权限。 response.raise_for_status() 方法用于检查 API 响应的状态码，如果状态码表示错误（例如 404 或 500），则会引发 HTTPError 异常，从而可以及时发现并处理错误。函数返回的是包含账户信息的 JSON 数据。后续代码遍历账户数据，并打印每个账户的 ID、币种和余额。余额信息包括余额的数量和币种。

创建买卖订单

以下代码演示如何使用 Coinbase API 创建一个市价买单。市价买单会以当前市场上最优的价格立即执行，确保交易的快速完成。

要实现买单功能，我们需要调用Coinbase API的 /accounts/{account_id}/buys 端点，而非 /accounts/{account_id}/sells 。

以下Python代码展示了如何构建并发送一个创建市价买单的API请求：


def create_market_buy_order(currency_pair, amount, account_id):
    """
    使用Coinbase API创建一个市价买单。

    参数:
        currency_pair (str): 交易对，例如 "BTC-USD"。
        amount (str): 要购买的加密货币数量。
        account_id (str): Coinbase账户ID。

    返回值:
        dict: API响应的JSON数据。
    """
    endpoint = f"/accounts/{account_id}/buys"  # 使用正确的 buys 端点
    method = "POST"
    url = API_URL + endpoint
    body = {
        "type": "market",
        "size": amount,
        "currency": currency_pair
    }
    body_ = str(body).replace("'", '"')  # 将单引号转换为双引号，符合JSON格式
    headers = get_auth_headers(method, endpoint, body_)
    response = requests.post(url, headers=headers, data=body_)
    response.raise_for_status()  # 如果响应状态码不是 200，则引发 HTTPError 异常
    return response.()

代码解释：

create_market_buy_order(currency_pair, amount, account_id) : 该函数接收三个参数：交易对（例如"BTC-USD"），要购买的加密货币数量，以及你的Coinbase账户ID。
endpoint = f"/accounts/{account_id}/buys" : 定义API端点，指向特定账户的买单创建接口。 注意：这里更正为 buys ，以实现买单功能。
method = "POST" : 指定HTTP请求方法为POST，用于向服务器提交数据。
url = API_URL + endpoint : 构建完整的API请求URL。 API_URL 需要替换为 Coinbase API 的基础 URL。
body = { ... } : 构建请求体（payload），包含买单的详细信息，包括订单类型（"market"表示市价单）、购买数量（ size ）和交易对（ currency_pair ）。
body_ = str(body).replace("'", '"') : 将Python字典转换为JSON字符串，并确保使用双引号，因为Coinbase API要求JSON格式。
headers = get_auth_headers(method, endpoint, body_) : 调用 get_auth_headers 函数生成包含身份验证信息的HTTP头部。你需要实现这个函数，参考Coinbase API文档。
response = requests.post(url, headers=headers, data=body_) : 使用 requests 库发送POST请求到Coinbase API。
response.raise_for_status() : 检查响应状态码。如果状态码表示错误（例如400、401、500），则抛出一个异常， indicating the request failed.
return response.() : 将API响应的JSON数据解析为Python字典并返回。

重要提示：

请务必替换代码中的 API_URL 为你实际使用的Coinbase API的URL。
你需要实现 get_auth_headers 函数，该函数负责生成符合Coinbase API要求的身份验证头部。 Coinbase API使用HMAC签名进行身份验证。请参考Coinbase API文档了解如何生成正确的签名。
在实际交易前，请务必使用Coinbase API的沙盒环境进行测试，以避免意外损失。
请谨慎处理你的API密钥，不要将其泄露给他人。
在生产环境中使用该代码前，请充分测试和验证其功能。

示例：使用账户 ID `YOUR_ACCOUNT_ID` 以市价购买 0.01 BTC 的订单

要使用指定的账户 ID 下市价购买比特币的订单，您需要替换示例代码中的占位符。请确保您的账户拥有足够的资金来完成交易。

account_id = "YOUR_ACCOUNT_ID" # 替换为你的账户ID

将 YOUR_ACCOUNT_ID 替换为您在交易平台上的真实账户 ID。账户 ID 用于标识您的账户，并确保订单与正确的账户相关联。不同交易所获取account_id的方式不一样，请参考交易所的官方API文档。

currency_pair = "BTC-USD"

currency_pair 变量定义了交易的货币对。在这个例子中，它被设置为 "BTC-USD" ，表示购买比特币 (BTC) 并使用美元 (USD) 支付。您可以根据需要更改此变量以交易不同的货币对，例如，如果想要交易比特币和以太坊，可以设置为"BTC-ETH"。

amount = "0.01"

amount 变量指定了要购买的比特币数量。在本例中，设置为 "0.01" ，表示购买 0.01 BTC。请根据您的需求调整此值。

接下来，代码尝试创建市价购买订单，并处理可能发生的任何错误。

try: order = create_market_buy_order(currency_pair, amount, account_id) print(f"订单已创建: {order}") except requests.exceptions.HTTPError as e: print(f"创建订单时出错: {e}")

这段代码块使用 try-except 结构来捕获可能在订单创建过程中发生的 HTTP 错误。 create_market_buy_order 函数（未在此处定义，需要您自行实现或使用交易平台提供的 SDK）负责与交易所的 API 交互，并提交市价购买订单。如果订单创建成功，将打印订单信息；如果出现 HTTP 错误（例如，账户余额不足、API 密钥无效等），将捕获异常并打印错误消息。请务必仔细阅读交易所的API文档，特别是关于错误代码的说明，以便更准确地处理各种异常情况。某些交易所可能对API的调用频率有限制，超出限制也会导致HTTPError，需要您合理控制API调用频率。为了安全起见，建议将账户ID、API密钥等敏感信息存储在环境变量或配置文件中，而不是直接硬编码在代码中。

注意：将 YOUR_ACCOUNT_ID 替换为你实际的 Coinbase 账户 ID。 currency_pair 是你要交易的货币对，例如 "BTC-USD"。 size 是你要购买的数量，type 设置为 "market" 表示市价单。请仔细检查你设定的 size 值，错误的 size 值可能导致意外的交易。此外，为了创建买单，需要修改 endpoint 为 /accounts/{account_id}/buys 并进行对应的测试。

订单状态查询

您可以使用唯一的订单 ID 查询订单的当前状态。通过订单 ID，您可以实时追踪订单的处理进度、确认订单是否已支付、以及预计的送达时间等详细信息。

以下代码片段展示了如何通过 Python 脚本和 API 调用来获取订单信息。该示例使用了 requests 库来发送 HTTP GET 请求，并假设您已经定义了 API_URL 和 get_auth_headers 函数。 API_URL 应该指向您的 API 接口地址， get_auth_headers 函数负责生成包含身份验证信息的请求头，以确保 API 请求的安全性。

response.raise_for_status() 方法会在响应状态码指示错误（如 4xx 或 5xx）时抛出一个 HTTPError 异常，从而方便错误处理。如果请求成功， response.() 方法会将响应体解析为 JSON 格式，便于进一步处理订单数据。


def get_order(order_id):
    """
    通过订单 ID 获取订单详情。

    Args:
        order_id (str): 要查询的订单的唯一标识符。

    Returns:
        dict: 包含订单信息的 JSON 字典。

    Raises:
        requests.exceptions.HTTPError: 如果 API 请求返回错误状态码。
    """
    endpoint = f"/orders/{order_id}"
    method = "GET"
    url = API_URL + endpoint
    headers = get_auth_headers(method, endpoint)
    response = requests.get(url, headers=headers)
    response.raise_for_status()  # 检查是否成功
    return response.()

请确保替换 API_URL 为实际的 API 地址，并根据您的 API 的具体要求修改 get_auth_headers 函数。同时，为了提高代码的可读性和可维护性，建议添加适当的注释和异常处理机制。

示例：使用订单 ID `YOUR_ORDER_ID` 查询订单状态

order_id = "YOUR_ORDER_ID" # 将此字符串 "YOUR_ORDER_ID" 替换为您的实际订单 ID。订单 ID 是用于唯一标识订单的字符串，通常由交易平台或交易所生成。请确保替换的订单 ID 是有效的，并且与您要查询的订单对应。

try: order_status = get_order(order_id) print(f"订单状态: {order_status}") except requests.exceptions.HTTPError as e: print(f"查询订单状态时出错: {e}")

务必将 YOUR_ORDER_ID 替换为你的实际的订单 ID。这是至关重要的步骤，否则查询将会失败。订单 ID 区分大小写，请确保输入正确。在实际应用中， get_order() 函数将会调用加密货币交易所或交易平台的 API 来获取订单状态。如果遇到 HTTPError ，表示网络请求或 API 调用失败，请检查您的网络连接、API 密钥以及 API 调用参数是否正确。常见的错误包括无效的 API 密钥、请求频率过高以及订单 ID 不存在。

错误处理

在使用 Coinbase API 进行开发时，稳健的错误处理机制至关重要。由于网络请求的性质，以及API本身可能存在的各种问题，务必对可能发生的错误情况进行周全的考虑和处理。Coinbase API通常会返回包含详细错误信息的 JSON 响应体，以便开发者诊断和解决问题。

建议采用 try...except 块结构来捕获潜在的异常。特别是需要捕获 requests.exceptions.HTTPError 异常，该异常通常在HTTP请求返回错误状态码时抛出。通过捕获此类异常，可以防止程序崩溃，并执行适当的错误处理逻辑。

在 except 块中，务必检查 HTTP 响应的状态码。状态码可以提供关于错误的初步信息。例如，400 状态码通常表示客户端请求存在问题，而 500 状态码则可能表明服务器端出现了错误。详细的错误代码列表和说明可以在Coinbase API的官方文档中找到，以便更准确地诊断问题。

解析 JSON 响应体，并检查其中的错误信息字段。Coinbase API 通常会在 JSON 响应中包含 error 或 errors 字段，其中包含更详细的错误描述、错误代码和相关的上下文信息。可以根据这些信息来确定错误的根本原因，并采取相应的纠正措施，例如重试请求、验证输入参数或向用户显示有用的错误消息。

最佳实践包括记录错误信息以便于调试和问题追踪，并为用户提供清晰的错误反馈，以便他们了解发生了什么以及如何解决问题。通过实现完善的错误处理策略，可以提高应用程序的稳定性和用户体验。

进阶：编写自动交易策略

上述代码示例展示了基础的 API 操作，为构建复杂的自动化交易策略奠定了基础。您可以利用这些操作，结合市场分析和风险管理原则，开发出定制化的交易系统。例如，您可以构建一个定期扫描市场行情的脚本，当价格触及预先设定的买入或卖出触发点时，自动执行交易指令。这种策略可以帮助您抓住市场机会，减少人工干预，并提高交易效率。

更进一步，可以融入技术指标分析，提升交易决策的智能化水平。例如，可以使用移动平均线（Moving Average）来识别趋势方向，或利用相对强弱指数（RSI）来判断市场超买超卖情况。当这些技术指标发出交易信号时，脚本将自动执行相应的买卖操作。结合多种技术指标，并设置合理的参数，可以构建出更稳健和有效的交易策略。

风险管理是自动交易策略中至关重要的一环。建议在脚本中加入止损和止盈机制，以控制单笔交易的潜在亏损和锁定利润。可以根据自身的风险承受能力和市场波动性，灵活调整止损止盈的幅度。同时，需要定期监控交易系统的运行状态，并根据市场变化及时调整策略参数，确保交易系统的稳定性和盈利能力。

安全提示

永远不要将你的 API 密钥硬编码到你的代码中。硬编码密钥会使你的应用程序极易受到攻击。使用环境变量、配置文件、密钥管理系统（如 HashiCorp Vault）或其他安全的方法来存储你的密钥。这些方法可以防止密钥泄露到版本控制系统或日志文件中。考虑使用加密技术来进一步保护存储的密钥。
限制 API 密钥的权限，只授予必要的权限。最小权限原则是安全最佳实践。为每个 API 密钥分配执行特定任务所需的最低权限集。例如，如果密钥仅用于获取市场数据，则不要授予其交易或提款的权限。 Coinbase Pro 允许你创建具有特定权限的 API 密钥。仔细审查并限制每个密钥的权限范围。
监控你的交易活动，定期检查你的账户余额和交易历史。定期监控有助于及早发现未经授权的活动或安全漏洞。设置警报，以便在发生异常交易或余额变化时收到通知。检查你的交易历史记录，以识别任何可疑活动。使用 Coinbase 提供的审计日志来跟踪 API 密钥的使用情况。
使用双因素身份验证（2FA）来保护你的 Coinbase 账户。 2FA 增加了一层额外的安全保护，即使攻击者获得了你的密码，也无法访问你的帐户。启用 Coinbase 提供的 2FA 选项，例如基于时间的一次性密码 (TOTP) 应用程序（如 Google Authenticator 或 Authy）或硬件安全密钥（如 YubiKey）。
注意交易所的API使用限制，例如请求频率限制，避免触发限流机制。交易所通常对 API 请求的频率和数量施加限制，以防止滥用和保持系统稳定性。超过这些限制可能会导致 API 密钥被暂时或永久禁用。仔细阅读 Coinbase Pro 的 API 文档，了解具体的速率限制。实施重试机制和指数退避算法，以便在达到速率限制时自动处理错误并重试请求。使用缓存来减少 API 请求的数量。

星河交易所：加密货币交易平台潜在风险深度解析欧易交易机器人设置：策略、参数与技巧深度解析