526互联

六、区块量化 okx RSI策略

发布时间 2023-06-16 17:39:29作者: 金记缘

1、新增cross_rsi_order.py

# -*- coding: utf-8 -*-
import talib
import cross_order as order
import time
RSI_PERIODS = 14 # RSI计算周期
RSI_OVER_SOLD_THRESH = 30 # 超卖阈值
RSI_OVER_BOUGHT_THRESH = 70 # 超买阈值


def main():
print("任务开始时间：", time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time())))
for symbol in order.symbol_pool:
# 设置杠杆倍数
order.set_leverage(symbol=symbol, leverage='25')
# 获取标的的最新价
data = order.get_candlesticks(symbol=symbol, interval='15m', limit=str(RSI_PERIODS + 1))
close = data['close'].values
# 计算RSI
rsi_vals = talib.RSI(close, timeperiod=RSI_PERIODS)
# RSI策略
# RSI值上穿超卖阈值,以市价做多
if (rsi_vals.iloc[-2] < RSI_OVER_SOLD_THRESH) and (rsi_vals.iloc[-1] >= RSI_OVER_SOLD_THRESH):
order.up_cross_order(symbol, 'RSI值上穿超卖阈值,以市价做多')
# RSI值下穿超买阈值,以市价做空
elif (rsi_vals.iloc[-2] > RSI_OVER_BOUGHT_THRESH) and (rsi_vals.iloc[-1] <= RSI_OVER_BOUGHT_THRESH):
order.down_cross_order(symbol, 'RSI值下穿超买阈值,以市价做空')

time.sleep(5)

print("任务结束时间：", time.strftime('%Y-%m-%d %H:%M:%S', time.localtime(time.time())))


if __name__ == '__main__':
main()