高频量化合约对冲交易机器人开发部署代码详情

简介: 高频量化合约对冲交易机器人开发部署代码详情,线上运营案例

量化合约指的是目标或任务具体明确,可以清晰度量。根据不同情况,表现为数量多少,具体的统计数字,范围衡量,时间长度等等。所谓量化就是把经过抽样得到的瞬时值将其幅度离散,即用一组规定的电平,把瞬时抽样值用最接近的电平值来表示。经过抽样的图像,只是在空间上被离散成为像素(样本)的阵列。而每个样本灰度值还是一个由无穷多个取值的连续变化量,必须将其转化为有限个离散值,赋予不同码字才能真正成为数字图像。这种转化称为量化。
量化合约策略部署代码参考如下:

coding=utf-8

from future import print_function, absolute_import, unicode_literals
import numpy as np
import pandas as pd
from gm.api import *
'''
本策略标的为:SHFE.rb1901
价格中枢设定为:前一交易日的收盘价
从阻力位到压力位分别为:1.03 open、1.02 open、1.01 open、open、0.99 open、0.98 open、0.97 open
每变动一个网格,交易量变化100个单位
回测数据为:SHFE.rb1901的1min数据
回测时间为:2017-07-01 08:00:00到2017-10-01 16:00:00
'''
def init(context):

# 策略标的为SHFE.rb1901
context.symbol = 'SHFE.rb1901'
# 订阅SHFE.rb1901, bar频率为1min
subscribe(symbols = context.symbol, frequency='60s')
# 设置每变动一格,增减的数量
context.volume = 1
# 储存前一个网格所处区间,用来和最新网格所处区间作比较
context.last_grid = 0
# 以前一日的收盘价为中枢价格
context.center = history_n(symbol= context.symbol,frequency='1d',end_time=context.now,count = 1,fields = 'close')[0]['close']
# 记录上一次交易时网格范围的变化情况(例如从4区到5区,记为4,5)
context.grid_change_last = [0,0]

def on_bar(context, bars):

bar = bars[0]
# 获取多仓仓位
position_long = context.account().position(symbol=context.symbol, side=PositionSide_Long)
# 获取空仓仓位
position_short = context.account().position(symbol=context.symbol, side=PositionSide_Short)
# 设置网格和当前价格所处的网格区域
context.band = np.array([0.97, 0.98, 0.99, 1, 1.01, 1.02, 1.03]) * context.center
grid = pd.cut([bar.close], context.band, labels=[1, 2, 3, 4, 5, 6])[0]
# 如果价格超出网格设置范围,则提示调节网格宽度和数量
if np.isnan(grid):
    print('价格波动超过网格范围,可适当调节网格宽度和数量')
# 如果新的价格所处网格区间和前一个价格所处的网格区间不同,说明触碰到了网格线,需要进行交易
# 如果新网格大于前一天的网格,做空或平多
if context.last_grid < grid:
    # 记录新旧格子范围(按照大小排序)
    grid_change_new = [context.last_grid,grid]
    # 几种例外:
    # 当last_grid = 0 时是初始阶段,不构成信号
    # 如果此时grid = 3,说明当前价格仅在开盘价之下的3区域中,没有突破网格线
    # 如果此时grid = 4,说明当前价格仅在开盘价之上的4区域中,没有突破网格线
    if context.last_grid == 0:
        context.last_grid = grid
        return
    if context.last_grid != 0:
        # 如果前一次开仓是4-5,这一次是5-4,算是没有突破,不成交
        if grid_change_new != context.grid_change_last:
            # 更新前一次的数据
            context.last_grid = grid
            context.grid_change_last = grid_change_new
            # 如果有多仓,平多
            if position_long:
                order_volume(symbol=context.symbol, volume=context.volume, side=OrderSide_Sell, order_type=OrderType_Market,
                             position_effect=PositionEffect_Close)
                print('以市价单平多仓{}手'.format(context.volume))
            # 否则,做空
            if not position_long:
                order_volume(symbol=context.symbol, volume=context.volume, side=OrderSide_Sell, order_type=OrderType_Market,
                             position_effect=PositionEffect_Open)
                print('以市价单开空{}手'.format(context.volume))
# 如果新网格小于前一天的网格,做多或平空
if context.last_grid > grid:
    # 记录新旧格子范围(按照大小排序)
    grid_change_new = [grid,context.last_grid]
    # 几种例外:
    # 当last_grid = 0 时是初始阶段,不构成信号
    # 如果此时grid = 3,说明当前价格仅在开盘价之下的3区域中,没有突破网格线
    # 如果此时grid = 4,说明当前价格仅在开盘价之上的4区域中,没有突破网格线
    if context.last_grid == 0:
        context.last_grid = grid
        return
    if context.last_grid != 0:
        # 如果前一次开仓是4-5,这一次是5-4,算是没有突破,不成交
        if grid_change_new != context.grid_change_last:
            # 更新前一次的数据
            context.last_grid = grid
            context.grid_change_last = grid_change_new
            # 如果有空仓,平空
            if position_short:
                order_volume(symbol=context.symbol, volume=context.volume, side=OrderSide_Buy,
                             order_type=OrderType_Market,
                             position_effect=PositionEffect_Close)
                print('以市价单平空仓{}手'.format(context.volume))
            # 否则,做多
            if not position_short:
                order_volume(symbol=context.symbol, volume=context.volume, side=OrderSide_Buy,
                             order_type=OrderType_Market,
                             position_effect=PositionEffect_Open)
                print('以市价单开多{}手'.format(context.volume))
# 设计一个止损条件:当持仓量达到10手,全部平仓
if position_short == 10 or position_long == 10:
    order_close_all()
    print('触发止损,全部平仓')

if name == '__main__':

'''
strategy_id策略ID,由系统生成
filename文件名,请与本文件名保持一致
mode实时模式:MODE_LIVE回测模式:MODE_BACKTEST
token绑定计算机的ID,可在系统设置-密钥管理中生成
backtest_start_time回测开始时间
backtest_end_time回测结束时间
backtest_adjust股票复权方式不复权:ADJUST_NONE前复权:ADJUST_PREV后复权:ADJUST_POST
backtest_initial_cash回测初始资金
backtest_commission_ratio回测佣金比例
backtest_slippage_ratio回测滑点比例
'''
run(strategy_id='strategy_id',
    filename='main.py',
    mode=MODE_BACKTEST,
    token='token_id',
    backtest_start_time='2018-07-01 08:00:00',
    backtest_end_time='2018-10-01 16:00:00',
    backtest_adjust=ADJUST_PREV,
    backtest_initial_cash=100000,
    backtest_commission_ratio=0.0001,
    backtest_slippage_ratio=0.0001)

相关文章
|
2月前
|
机器学习/深度学习 数据采集 监控
量化交易机器人开发风控模型对比分析与落地要点
本文系统对比规则止损、统计模型、机器学习及组合式风控方案,从成本、鲁棒性、可解释性等维度评估其在合约量化场景的适用性,结合落地实操建议,为不同阶段的交易系统提供选型参考。
|
3月前
|
算法 机器人 Serverless
【机器人路径规划】基于6种算法(黑翅鸢优化算法BKA、SSA、MSA、RTH、TROA、COA)求解机器人路径规划研究(Matlab代码实现)
【机器人路径规划】基于6种算法(黑翅鸢优化算法BKA、SSA、MSA、RTH、TROA、COA)求解机器人路径规划研究(Matlab代码实现)
480 2
|
3月前
|
机器学习/深度学习 编解码 算法
【机器人路径规划】基于迪杰斯特拉算法(Dijkstra)的机器人路径规划(Python代码实现)
【机器人路径规划】基于迪杰斯特拉算法(Dijkstra)的机器人路径规划(Python代码实现)
366 4
|
3月前
|
机器学习/深度学习 算法 机器人
【机器人路径规划】基于A*算法的机器人路径规划研究(Python代码实现)
【机器人路径规划】基于A*算法的机器人路径规划研究(Python代码实现)
534 4
|
3月前
|
机器学习/深度学习 算法 机器人
【机器人路径规划】基于深度优先搜索(Depth-First-Search,DFS)算法的机器人路径规划(Python代码实现)
【机器人路径规划】基于深度优先搜索(Depth-First-Search,DFS)算法的机器人路径规划(Python代码实现)
269 3
|
3月前
|
机器学习/深度学习 存储 算法
【水下机器人建模】基于QLearning自适应强化学习PID控制器在AUV中的应用研究(Matlab代码实现)
【水下机器人建模】基于QLearning自适应强化学习PID控制器在AUV中的应用研究(Matlab代码实现)
328 0
|
3月前
|
机器学习/深度学习 算法 机器人
【机器人路径规划】基于D*算法的机器人路径规划(Python代码实现)
【机器人路径规划】基于D*算法的机器人路径规划(Python代码实现)
214 0
|
3月前
|
机器学习/深度学习 算法 机器人
【机器人路径规划】基于改进型A*算法的机器人路径规划(Python代码实现)
【机器人路径规划】基于改进型A*算法的机器人路径规划(Python代码实现)
257 0
|
3月前
|
数据采集 自动驾驶 机器人
数据喂得好,机器人才能学得快:大数据对智能机器人训练的真正影响
数据喂得好,机器人才能学得快:大数据对智能机器人训练的真正影响
244 1
|
9月前
|
人工智能 自然语言处理 机器人
9.9K star!大模型原生即时通信机器人平台,这个开源项目让AI对话更智能!
"😎高稳定、🧩支持插件、🦄多模态 - 大模型原生即时通信机器人平台"
317 0

热门文章

最新文章