Python 实现 120 个币种实时数据采集：限速接口的均匀查询策略

可以使用Python中的time.sleep()函数来控制定时任务的执行间隔，以保证查询接口不会超速。根据接口限速为20次/s，即每次查询接口的最小时间间隔为1/20=0.05秒。

以下是一个示例代码：

import time
import redis

# 创建redis连接
r = redis.Redis(host='localhost', port=6379)

# 定义币种列表
coins = ['BTC', 'ETH', 'XRP', 'LTC']

# 定义定时任务的执行间隔
intervals = [1, 5, 15, 30, 60, 240]

# 定义查询接口的限速
rate_limit = 20

# 查询币种实时数据的函数
def query_coin_data(coin):
    # 模拟查询接口
    print(f'查询币种{coin}的实时数据')
    # 将查询结果写入redis队列
    r.lpush('coin_data', f'币种{coin}的实时数据')

# 定时任务
def timed_task():
    count = 0
    while count < 120:
        for coin in coins:
            for interval in intervals:
                # 查询币种实时数据
                query_coin_data(coin)
                count += 1
                # 控制查询接口的频率
                time.sleep(1 / rate_limit)

# 执行定时任务
timed_task()

在上述示例代码中，通过time.sleep(1 / rate_limit)来控制查询接口的频率，以保证不超过接口的限速要求。每次查询接口后，将查询结果写入Redis队列中。