Qust Docs

策略命名空间 / future.py

stra.to_hold_two_sides

行算子,通过两组开平仓信号,生成持仓 输入输出 col(a, b, c, d): a: 开仓信号, bool, b: 对a的平仓信号,bool,c: 开仓信号,d:对c的平仓信号 a 出现了true,并且对b没有持仓,则生成target_lo的持仓,直到b踹向那true,平a的持仓,对b,c同理 写法 作用 ✅ - 该方法用于执行 `to_hold_two_

接口示例returns: Exprstra

输入 / 输出

输入

- 函数签名:`to_hold_two_sides(target_lo: float | Params = 1.0, target_sh: float | Params = -1.0)` - 参数约束和边界条件以上文描述为准;如无上文说明,按类型注解/默认值执行。

输入项类型示例
openFloat649.9
highFloat6410.25
lowFloat649.68
closeFloat6410.0

输出

项目说明
返回类型Expr
输出对象表达式/执行计划/配置对象
输出语义输出列由算子、alias 或底层实现决定;需要稳定列名时显式使用 alias。
执行方式先构造对象,再放入 DataSet、Monitor、UDF 或真实执行上下文。
核心调用col('open', 'high', 'low', 'close').stra.to_hold_two_sides(1.0, -1.0)

打印输入 / 打印输出

下面内容来自本页示例代码真实执行后的 stdout,不是手写占位。

调用

Python
col('open', 'high', 'low', 'close').stra.to_hold_two_sides(1.0, -1.0)
参数类型默认值说明
target_lofloat | Params1.0位置参数
target_shfloat | Params-1.0位置参数

完整代码

这个算子页使用接口示例:不伪造计算结果。需要真实上下文、多输入源、Monitor session、UDF 回调、策略状态,或当前底层实现之后再执行。
展开可复制完整代码
Python
import datetime as dt
import polars as pl
import qust as qs
from qust import col, pms

data = pl.DataFrame(
    {
        "open": [9.9, 10.3, 10.0, 10.6, 10.6, 10.5, 10.8, 11.2, 10.7, 11.4, 11.5, 11.5, 11.8, 12.2, 11.7, 12.5, 12.1, 12.8, 12.8, 13.2],
        "high": [10.25, 10.55, 10.35, 10.85, 10.95, 10.75, 11.15, 11.45, 11.05, 11.65, 11.85, 11.75, 12.15, 12.45, 12.05, 12.75, 12.45, 13.05, 13.15, 13.45],
        "low": [9.68, 9.98, 9.78, 10.28, 10.38, 10.18, 10.58, 10.88, 10.48, 11.08, 11.28, 11.18, 11.58, 11.88, 11.48, 12.18, 11.88, 12.48, 12.58, 12.88],
        "close": [10.0, 10.2, 10.1, 10.5, 10.7, 10.4, 10.9, 11.1, 10.8, 11.3, 11.6, 11.4, 11.9, 12.1, 11.8, 12.4, 12.2, 12.7, 12.9, 13.1],
    }
)

pool = qs.DataPool("doc_pool")
monitor = qs.Monitor()
right = qs.DataSource("right")
schema = [("x", qs.dt.Float64)]
plot_expr = col("x")
df = col("x").runtime()

print("算子:")
print('stra.to_hold_two_sides')
print("场景:")
print('策略信号:把开平仓信号、价格和状态转成交易状态表达式。')
print("模式:")
print('接口示例:只构造表达式或对象,不伪造计算结果。')
print("输入列:")
print('open, high, low, close')
print("调用:")
print("col('open', 'high', 'low', 'close').stra.to_hold_two_sides(1.0, -1.0)")
print("输入数据模板:")
print(data)
try:
    result = col('open', 'high', 'low', 'close').stra.to_hold_two_sides(1.0, -1.0)
except BaseException as err:
    out = pl.DataFrame({
        "项目": ["调用", "状态", "错误类型", "错误信息"],
        "内容": ["col('open', 'high', 'low', 'close').stra.to_hold_two_sides(1.0, -1.0)", "未执行成数据表", type(err).__name__, str(err)[:200]],
    })
    print("输出:")
    print(out)
else:
    out = pl.DataFrame({
        "项目": ["调用", "返回类型", "状态", "怎么得到业务表"],
        "内容": ["col('open', 'high', 'low', 'close').stra.to_hold_two_sides(1.0, -1.0)", type(result).__name__, "表达式构造完成", "放进 col(...).runtime().calc_data(data)、col.with_cols(...).runtime().calc_data(data),或对应 Monitor/DataSet 运行上下文。"],
    })
    print("输出:")
    print(out)

改成业务代码

改哪里怎么改
列名把示例 DataFrame 里的列名换成你的真实列名,列顺序保持和用法一致。
参数只改函数括号里的参数;不要随意改变 rolling/over/batch/select 的链式层级。
输出名需要稳定输出列名时,在表达式尾部加 .alias("name")
调试先打印输入数据和调用字符串,再执行 calc_data;报 schema 错时先检查列数和 dtype。

注意事项

- 参数类型与预期不一致会导致运行时报错或返回空值。

来源

项目位置
源码文件future.py
类/对象Stra