如何通过KuCoin API 获取市场行情数据

KuCoin 交易所提供了一套强大的 API，允许开发者访问其各种功能，包括获取实时的市场行情数据。本文将详细介绍如何通过 KuCoin API 获取市场行情数据，包括 API 的认证方式、请求方法、以及常用的数据接口。

API 认证

在使用 KuCoin API 之前，务必拥有一个 KuCoin 账户并生成必要的 API 密钥。请访问 KuCoin 官方网站，按照指引完成账户注册。成功注册账户后，导航至账户设置中的 API 管理页面，在此页面生成 API Key、Secret Key 和 Passphrase。务必妥善保管这些信息，因为它们是访问 KuCoin API 的关键凭证，泄露可能导致资产风险。

API 认证主要依赖于在 HTTP 请求头部中包含特定的身份验证信息来实现：

• KC-API-KEY: 您的 API Key，用于标识您的账户。
• KC-API-SECRET: 您的 Secret Key，与 API Key 配合使用，用于生成请求签名，验证请求的合法性。
• KC-API-PASSPHRASE: 您在创建 API 密钥时设置的 Passphrase，作为额外的安全层，确保只有您授权的应用才能访问您的账户。
• KC-API-TIMESTAMP: 当前的 Unix 时间戳，精确到秒，用于防止重放攻击。服务器会验证时间戳的有效性，确保请求的时效性。
• KC-API-SIGN: 使用 Secret Key 和请求参数生成的数字签名，用于验证请求的完整性和真实性。

签名生成过程如下，请严格按照步骤操作，确保签名正确：

1. 将 KC-API-TIMESTAMP , HTTP 请求方法 (例如 "GET" 或 "POST", 必须大写), 请求路径 (例如 "/api/v1/market/allTickers", 包含前导斜杠) 和请求体 (如果存在，必须是JSON字符串，否则为空字符串) 按照顺序拼接成一个字符串。注意，如果请求体为空，则使用空字符串 ""。
2. 使用您的 Secret Key 作为密钥，利用 HMAC-SHA256 算法对上述拼接的字符串进行哈希运算。HMAC-SHA256 是一种消息认证码算法，可以有效防止篡改。
3. 将哈希运算的结果进行 Base64 编码，得到最终的签名。Base64 是一种常用的编码方式，可以将二进制数据转换为文本字符串。

以下是在 Python 中生成签名的代码示例，请确保安装了必要的 Python 库：

import hmac import hashlib import base64 import time

def generate_signature(secret_key, timestamp, method, endpoint, request_body=""): """ 生成 KuCoin API 请求的数字签名。 Args: secret_key (str): 您的 Secret Key. timestamp (str): 当前 Unix 时间戳 (秒). method (str): HTTP 请求方法 (GET, POST, PUT, DELETE 等, 必须大写). endpoint (str): API 端点 (例如 /api/v1/market/allTickers, 包含前导斜杠). request_body (str): 请求体 (JSON 字符串, 如果存在，否则为空字符串). Returns: str: 生成的数字签名. """ message = timestamp + method + endpoint + request_body hmac_key = secret_key.encode('utf-8') message = message.encode('utf-8') hmac_obj = hmac.new(hmac_key, message, hashlib.sha256) hmac_base64 = base64.b64encode(hmac_obj.digest()).decode('utf-8') return hmac_base64

示例

api_secret = "YOUR_API_SECRET" # 替换为你的 Secret Key。 Secret Key 是用于签名请求的关键凭证，务必妥善保管，切勿泄露。API Secret Key 通常由交易所或服务提供商提供，用于验证您的身份和授权您访问特定 API 接口。 在实际应用中，请务必使用实际的 API Secret Key 替换此占位符。

timestamp = str(int(time.time())) # 获取当前时间戳。时间戳用于防止重放攻击，确保请求的新鲜度。这里使用 time.time() 获取当前时间的 Unix 时间戳（自 1970 年 1 月 1 日午夜以来的秒数），并将其转换为整数，然后转换为字符串。将时间戳包含在请求中，服务器可以验证请求是否在合理的时间范围内发出。

method = "GET" # 定义 HTTP 请求方法。这里使用 GET 方法，表示从服务器获取数据。常见的 HTTP 请求方法还包括 POST (用于提交数据)、PUT (用于更新数据) 和 DELETE (用于删除数据)。根据 API 的要求选择正确的 HTTP 方法。

endpoint = "/api/v1/market/allTickers" # 定义 API 接口的端点。端点指定了要访问的特定资源或功能。在这个例子中， /api/v1/market/allTickers 可能表示获取所有交易对的市场行情数据的接口。API 文档通常会详细说明每个端点的作用和参数。

request_body = "" # 定义请求体。对于 GET 请求，通常不需要请求体，因此这里设置为空字符串。对于 POST、PUT 等请求，请求体可以包含要发送到服务器的数据，例如 JSON 或 XML 格式的数据。

signature = generate_signature(api_secret, timestamp, method, endpoint, request_body) # 使用 Secret Key、时间戳、HTTP 方法、端点和请求体生成签名。签名用于验证请求的完整性和真实性，防止篡改。 generate_signature 函数的具体实现取决于所使用的签名算法，例如 HMAC-SHA256。该函数接受 API Secret Key 和请求的各个部分作为输入，并生成唯一的签名字符串。

print(f"Generated Signature: {signature}") # 打印生成的签名。用于调试和验证签名是否正确生成。在实际应用中，需要将生成的签名添加到 HTTP 请求头或请求参数中，以便服务器验证请求的有效性。正确的签名是成功调用 API 的关键。

获取所有交易对的行情数据

要获取所有交易对的实时行情数据，您可以使用 /api/v1/market/allTickers 接口。此接口提供了全局市场概览，返回一个JSON格式的列表，其中包含所有交易对的最新成交价（Last Traded Price）、成交量（Volume）、最高价（Highest Price）、最低价（Lowest Price）、以及时间戳（Timestamp）等关键指标。 通过这些数据，您可以快速了解整个市场的动态，进行趋势分析，或者构建实时的监控系统。

为了充分利用此接口，您需要了解返回数据的结构。每个交易对的行情信息通常包含以下字段：

• symbol : 交易对的唯一标识符，例如 "BTCUSDT"。
• price : 最新成交价，以报价货币计价。
• volume : 24小时成交量，以基础货币计价。
• high : 24小时最高价。
• low : 24小时最低价。
• timestamp : 最新成交的时间戳，通常为Unix时间戳，精确到毫秒或秒。

以下是一个使用 Python 和 requests 库获取所有交易对行情数据的示例，并包含了错误处理和数据解析的建议：

import requests
import time
import os
import 

def get_all_tickers():
    """
    获取所有交易对的行情数据。
    """
    url = "your_exchange_api_endpoint/api/v1/market/allTickers" # 替换为实际的API端点
    try:
        response = requests.get(url)
        response.raise_for_status()  # 检查HTTP状态码，如果不是200，则抛出异常

        data = response.()

        if isinstance(data, list):
            # 遍历并打印每个交易对的行情数据
            for ticker in data:
                print(f"Symbol: {ticker['symbol']}, Price: {ticker['price']}, Volume: {ticker['volume']}")
        else:
            print("Error: Invalid response format. Expected a list.")

    except requests.exceptions.RequestException as e:
        print(f"Request failed: {e}")
    except .JSONDecodeError as e:
        print(f"Failed to decode JSON: {e}")
    except KeyError as e:
        print(f"Missing key in response data: {e}")

if __name__ == "__main__":
    get_all_tickers()

代码解释：

• import requests : 导入 requests 库，用于发送 HTTP 请求。
• import time : 导入 time 库，虽然本例未使用，但通常用于处理时间相关的操作，如添加延迟避免频率限制。
• import os : 导入 os 库，虽然本例未使用，但可以用于处理环境变量或文件操作。
• url = "your_exchange_api_endpoint/api/v1/market/allTickers" : 定义 API 端点 URL，请替换为交易所提供的实际地址。
• response = requests.get(url) : 发送 GET 请求到 API 端点。
• response.raise_for_status() : 检查 HTTP 响应状态码，如果不是 200 OK，则抛出异常。这有助于快速检测请求是否成功。
• data = response.() : 将响应内容解析为 JSON 格式。
• for ticker in data: : 遍历 JSON 列表，提取每个交易对的行情数据。
• print(f"Symbol: {ticker['symbol']}, Price: {ticker['price']}, Volume: {ticker['volume']}") : 打印交易对的符号、价格和交易量。
• try...except 块：用于捕获和处理可能发生的异常，例如网络连接错误、JSON 解析错误、以及数据缺失等。

注意事项：

• API 密钥： 某些交易所可能需要 API 密钥才能访问此接口。请确保您已正确配置 API 密钥，并将其添加到请求头中。
• 频率限制： 交易所通常会对 API 请求频率进行限制，以防止滥用。请务必遵守交易所的频率限制，并根据需要添加适当的延迟。
• 错误处理： 在实际应用中，需要进行更完善的错误处理，例如记录错误日志、重试请求等。
• 数据存储： 如果需要长期存储行情数据，可以将数据保存到数据库或文件中。
• 数据类型： 请注意 API 返回的数据类型，例如价格和交易量可能为字符串或数字。在进行计算时，需要将字符串转换为数字。
• API 端点： 不同的交易所API端点可能不同，请根据您所使用的交易所进行调整。

从环境变量中获取 API 密钥信息

API 密钥、API 密钥 Secret 和 API 密钥 Passphrase 是访问 KuCoin API 的凭证。为了安全起见，建议从环境变量中读取这些值，避免硬编码在代码中。 以下代码片段展示了如何使用 Python 的 os 模块获取环境变量。

api_key = os.environ.get("KUCOIN_API_KEY")
api_secret = os.environ.get("KUCOIN_API_SECRET")
api_passphrase = os.environ.get("KUCOIN_API_PASSPHRASE")

以上代码分别从环境变量 KUCOIN_API_KEY , KUCOIN_API_SECRET 和 KUCOIN_API_PASSPHRASE 中获取 API 密钥相关的信息。 请确保在使用前已正确设置这些环境变量。

get_all_tickers() 函数用于获取 KuCoin 交易所所有交易对的行情数据。

该函数首先定义了 API endpoint 和 HTTP 方法。

def get_all_tickers():
    """
    获取 KuCoin 所有交易对的行情数据。
    """
    endpoint = "/api/v1/market/allTickers"
    method = "GET"
    timestamp = str(int(time.time()))

为了保证API请求的安全性，需要对请求进行签名。 以下展示了如何生成请求签名。

    signature = generate_signature(api_secret, timestamp, method, endpoint)

generate_signature() 函数 (未在此处定义) 接受 API Secret、时间戳、HTTP 方法和 API endpoint 作为参数， 并返回一个基于 HMAC-SHA256 算法生成的签名。 该签名用于验证请求的合法性。

接下来，构建包含 API 密钥、签名、时间戳和其他必要信息的 HTTP 请求头。 Content-Type 设置为 application/ 。

    headers = {
        "KC-API-KEY": api_key,
        "KC-API-SECRET": api_secret,
        "KC-API-PASSPHRASE": api_passphrase,
        "KC-API-TIMESTAMP": timestamp,
        "KC-API-SIGN": signature,
        "Content-Type": "application/"
    }

使用 requests 库发送 GET 请求到 KuCoin API。 为了处理可能出现的网络或API错误，使用了 try...except 块。

    try:
        response = requests.get("https://api.kucoin.com" + endpoint, headers=headers)
        response.raise_for_status()   # 检查请求是否成功 (状态码 200)
        data = response.()
        return data
    except requests.exceptions.RequestException as e:
        print(f"请求出错: {e}")
        return None
    except ValueError as e:
        print(f"JSON 解析出错: {e}")
        return None

response.raise_for_status() 会在响应状态码不是 200 OK 的情况下抛出异常。 如果响应成功，则使用 response.() 将 JSON 格式的响应内容解析为 Python 字典。

在 if __name__ == "__main__": 块中，调用 get_all_tickers() 函数获取所有交易对的行情数据。

if __name__ == "__main__":
    all_tickers = get_all_tickers()

对返回的数据进行检查，如果成功获取数据且返回码为 "200000"，则遍历 data['ticker'] 列表， 并打印每个交易对的 symbol 和最新成交价 (last)。 如果获取数据失败，则打印错误信息。

    if all_tickers and all_tickers['code'] == "200000":
        print("成功获取所有交易对行情数据:")
        for ticker in all_tickers['data']['ticker']:
            print(f"   交易对: {ticker['symbol']}, 最新成交价: {ticker['last']}")
    else:
        print("获取所有交易对行情数据失败.")
        if all_tickers:
            print(f"错误信息: {all_tickers}")

请务必将示例代码中的占位符替换为您的实际 API 密钥信息。 将 API 密钥存储在环境变量中是一种更安全的做法，可以防止密钥泄露。

获取单个交易对的行情数据

为了获取特定交易对的实时行情数据，您可以使用 /api/v1/market/ticker API 接口。此接口允许您检索指定交易对的最新价格、交易量和其他关键市场信息。您需要提供交易对的唯一标识符 symbol 作为请求参数。

symbol 参数遵循特定的命名约定，通常由两个以连字符分隔的代币符号组成，例如 BTC-USDT ，表示比特币和泰达币之间的交易对。

以下 Python 代码示例演示了如何使用 requests 库向 API 发送请求，获取 BTC-USDT 交易对的行情数据。代码还包括导入其他必要模块，如 time 和 os ，并使用 urllib.parse.quote 进行 URL 编码，尽管在此特定示例中可能不是必需的，但它是一种良好的实践，特别是在处理包含特殊字符的交易对符号时。

import requests import time import os from urllib.parse import quote

从环境变量中获取 API 密钥信息

为了保证API密钥的安全，建议从环境变量中读取API密钥、密钥和密码。这样可以避免将敏感信息硬编码到代码中，从而降低泄露风险。

api_key = os.environ.get("KUCOIN_API_KEY")
api_secret = os.environ.get("KUCOIN_API_SECRET")
api_passphrase = os.environ.get("KUCOIN_API_PASSPHRASE")

以上代码使用 os.environ.get() 函数从环境变量中获取KuCoin API的相关密钥信息。如果环境变量未设置，该函数将返回 None 。在实际应用中，应添加对这些变量是否存在的检查，并在缺失时进行相应的错误处理。

def get_ticker(symbol):
"""
获取指定交易对的行情数据。

Args:
symbol (str): 交易对 (例如 BTC-USDT).
"""

此函数用于从KuCoin API获取指定交易对的最新行情数据。它接受一个参数 symbol ，表示要查询的交易对，例如"BTC-USDT"。

endpoint = f"/api/v1/market/ticker?symbol={quote(symbol)}"   #  使用 quote  进行  URL 编码

method =  "GET"

timestamp =  str(int(time.time()))

构造API请求的endpoint，这里使用了Python的f-string格式化字符串功能，并将交易对 symbol 拼接到URL中。特别需要注意的是，由于URL中不能直接包含某些特殊字符，如空格等，因此需要使用 urllib.parse.quote 函数对 symbol 进行URL编码，以确保请求的正确性。然后，定义HTTP请求方法为GET，并获取当前时间戳，用于生成API签名。

signature =  generate_signature(api_secret,  timestamp,  method, endpoint)

通过 generate_signature 函数(未在此代码段提供，需要单独实现)使用你的API密钥、时间戳、HTTP方法和endpoint计算出请求签名。这个签名对于验证请求的合法性至关重要。 KuCoin API使用HMAC-SHA256算法对请求进行签名，确保只有授权用户才能访问API。

headers = {

     "KC-API-KEY": api_key,

    "KC-API-SECRET": api_secret,

    "KC-API-PASSPHRASE": api_passphrase,

     "KC-API-TIMESTAMP": timestamp,

    "KC-API-SIGN": signature,

    "Content-Type": "application/"

}

构建HTTP请求头，其中包括API密钥、密钥、密码、时间戳和签名。 Content-Type 设置为 application/ ，表明我们期望接收JSON格式的响应。

try:

     response  = requests.get("https://api.kucoin.com"  +  endpoint, headers=headers)

    response.raise_for_status()

    data = response.()

    return  data

except requests.exceptions.RequestException  as e:

      print(f"请求出错:  {e}")

    return  None

except ValueError as e:

    print(f"JSON 解析出错: {e}")

     return None

使用 requests.get() 函数发送GET请求到KuCoin API。 response.raise_for_status() 用于检查HTTP响应状态码，如果状态码不是200，将抛出一个HTTPError异常。然后，使用 response.() 方法将响应内容解析为JSON格式。如果请求过程中发生任何异常（例如网络错误或JSON解析错误），将捕获异常并返回 None 。

if __name__ == "__main__":

       symbol =  "BTC-USDT"

      ticker_data = get_ticker(symbol)

当脚本作为主程序运行时，设置要查询的交易对为"BTC-USDT"，并调用 get_ticker() 函数获取行情数据。

if ticker_data and  ticker_data['code'] == "200000":

     print(f"成功获取 {symbol} 的行情数据:")

      print(f"   最新成交价: {ticker_data['data']['price']}")

      print(f"   24 小时最高价:  {ticker_data['data']['high']}")

      print(f"  24  小时最低价: {ticker_data['data']['low']}")

    print(f"  24  小时交易量: {ticker_data['data']['vol']}")

else:

     print(f"获取 {symbol} 的行情数据失败.")

     if ticker_data:

         print(f"错误信息:  {ticker_data}")

检查 ticker_data 是否成功获取，并且响应代码是否为"200000"，这表示请求成功。如果成功，则从 ticker_data 中提取并打印最新成交价、24小时最高价、24小时最低价和24小时交易量。如果请求失败，则打印错误信息。

请注意，由于 symbol 包含了特殊字符，需要使用 urllib.parse.quote 进行URL编码，以确保请求的正确性。

获取 K 线数据

KuCoin API 提供了获取历史 K 线数据的接口 /api/v1/market/candles 。使用此接口，你可以检索指定交易对在特定时间范围内的开盘价、最高价、最低价和收盘价等关键信息，这对于技术分析和回测交易策略至关重要。 你需要提供以下核心参数：

• 交易对 ( symbol ): 指定需要获取 K 线数据的交易对，例如 BTC-USDT 。确保使用交易所支持的正确交易对代码。
• 时间粒度 ( type ): 定义 K 线的周期长度，例如 1min (1 分钟), 5min (5 分钟), 15min (15 分钟), 30min (30 分钟), 1hour (1 小时), 4hour (4 小时), 1day (1 天), 1week (1 周)。 选择适当的时间粒度取决于你的交易策略和分析周期。
• 起始时间 ( startAt ): 指定数据起始的时间戳，以 Unix 时间戳表示（单位为秒）。
• 结束时间 ( endAt ): 指定数据结束的时间戳，同样以 Unix 时间戳表示（单位为秒）。 确保 endAt 大于 startAt 。

需要注意的是， KuCoin API 对请求频率有限制。为了避免被限流，建议合理设置请求间隔，并且批量获取数据时，尽量选择较大的时间范围，减少请求次数。API 返回的数据格式为包含 K 线数据的数组，每条数据包含时间戳、开盘价、收盘价、最高价、最低价、成交量等信息。

以下是一个使用 Python requests 库获取 BTC-USDT 交易对 1 分钟 K 线数据的示例代码片段：

import requests
import time
import os
from urllib.parse import quote
import datetime

从环境变量中获取 API 密钥信息

为了安全起见，建议将 API 密钥、密钥和密码短语存储在环境变量中。以下代码演示了如何从环境变量中读取这些敏感信息，并将其用于后续的 API 请求。这样做可以防止将密钥硬编码在代码中，从而降低密钥泄露的风险。

api_key = os.environ.get("KUCOIN_API_KEY")
api_secret = os.environ.get("KUCOIN_API_SECRET")
api_passphrase = os.environ.get("KUCOIN_API_PASSPHRASE")

get_kline_data 函数用于从 KuCoin API 获取指定交易对的历史 K 线数据。此函数接收交易对、K 线类型、起始时间和结束时间作为参数，并返回包含 K 线数据的字典。

def get_kline_data(symbol, kline_type, start_at, end_at):
"""
获取指定交易对的 K 线数据。


    Args:

        symbol (str): 交易对 (例如 BTC-USDT).

        kline_type (str): K 线类型 (例如 1min, 5min, 1hour, 1day).

        start_at (int): 起始时间戳 (秒).

        end_at (int): 结束时间戳 (秒).

    """

    endpoint = f"/api/v1/market/candles?symbol={quote(symbol)}&type={quote(kline_type)}&startAt={start_at}&endAt={end_at}"

    method = "GET"

    timestamp = str(int(time.time()))


    signature = generate_signature(api_secret, timestamp, method, endpoint)


    headers = {

        "KC-API-KEY": api_key,

        "KC-API-SECRET": api_secret,

        "KC-API-PASSPHRASE": api_passphrase,

        "KC-API-TIMESTAMP": timestamp,

        "KC-API-SIGN": signature,

        "Content-Type": "application/"

    }


    try:

        response = requests.get("https://api.kucoin.com" + endpoint, headers=headers)

        response.raise_for_status() # 检查响应状态码，如果不是 200 则抛出异常

        data = response.()

        return data

    except requests.exceptions.RequestException as e:

        print(f"请求出错: {e}")

        return None

    except ValueError as e:

        print(f"JSON 解析出错: {e}")

        return None

上述代码片段的关键在于构造正确的 API 请求头。除了 API 密钥、密钥和密码短语之外，还需要一个时间戳和一个签名。签名是通过将密钥、时间戳、HTTP 方法和端点组合在一起，并使用 HMAC-SHA256 算法进行哈希处理生成的。这个签名用于验证请求的完整性和身份。

以下是主程序，展示如何使用 get_kline_data 函数获取 BTC-USDT 交易对的 1 分钟 K 线数据，并打印结果。默认情况下，它会获取过去 1 小时的数据。增加了对于API返回数据code的检查，确保数据获取成功。

if __name__ == "__main__":
symbol = "BTC-USDT"
kline_type = "1min"
# 获取过去 1 小时的数据
end_at = int(time.time())
start_at = end_at - 3600

    kline_data = get_kline_data(symbol, kline_type, start_at, end_at)


    if kline_data and kline_data['code'] == "200000":

        print(f"成功获取 {symbol} 的 K 线数据:")

        for kline in kline_data['data']:

            # kline 数据格式：[时间戳, 开盘价, 收盘价, 最高价, 最低价, 成交量, 成交额]

            timestamp, open_price, close_price, high_price, low_price, volume, turnover = kline

            dt_object = datetime.datetime.fromtimestamp(timestamp / 1000)  # KuCoin API 返回的时间戳单位为毫秒

            print(f" 时间: {dt_object}, 开盘价: {open_price}, 收盘价: {close_price}, 最高价: {high_price}, 最低价: {low_price}, 交易量: {volume}")

    else:

        print(f"获取 {symbol} 的 K 线数据失败.")

        if kline_data:

            print(f"错误信息: {kline_data}")

KuCoin API 支持多种 K 线类型，常用的包括： 1min , 5min , 15min , 30min , 1hour , 2hour , 4hour , 6hour , 8hour , 12hour , 1day , 1week 。选择合适的 K 线类型取决于你的交易策略和分析周期。

错误处理

在与KuCoin API交互时，可能会遭遇多种类型的错误。为了帮助开发者更好地理解和处理这些潜在问题，KuCoin API会在返回的JSON数据中包含一个重要的 code 字段。这个字段如同一个状态指示器，明确地告知客户端请求的处理结果。

以下列出了一些常见的错误代码，以及它们所代表的具体含义：

• 200000 : 这是一个积极的信号，表示API请求已成功处理并返回了预期结果。
• 400000 : 此错误代码表明客户端发送的请求中包含无效的参数。这可能包括参数缺失、格式错误或超出允许范围的值。开发者应仔细检查请求参数，确保其符合API文档的要求。
• 400003 : 这是安全性相关的错误，意味着API服务器未能验证请求的签名。签名验证是确保请求的完整性和身份验证的关键步骤。开发者应检查签名算法的实现，以及所使用的API密钥是否正确。可能的原因包括密钥泄露或签名计算错误。
• 401000 : 此错误代码表示客户端未经过身份验证，或者提供的身份验证信息（例如API密钥和密钥）无效。在访问需要身份验证的API端点之前，必须确保已正确配置和传递身份验证凭据。
• 429000 : 此错误指示客户端已超过API的速率限制。为防止滥用和保持服务质量，KuCoin API对请求频率设置了限制。当达到限制时，API将返回此错误代码。客户端应实现重试机制，并在收到此错误后暂停一段时间再尝试发送请求。可以结合使用指数退避算法来逐步增加重试间隔。

为了构建健壮且具有弹性的应用程序，开发者必须在代码中充分利用 code 字段。根据不同的错误代码，采取相应的处理策略至关重要。例如，当遇到 429000 （频率限制）错误时，一种有效的策略是暂停一段时间后重试请求。更高级的策略可能包括将请求放入队列，并根据速率限制动态调整发送速率。还可以考虑使用缓存来减少对API的请求次数。