策略命名空间 / future.py

stra.t06_ama_band

行算子，按 T06 源逻辑计算 `ama` 与 `ifilter` 双状态列 🚀 作用 ✅ 输入一列 `close`，输出两列： 1.

接口示例returns: Exprstra

输入 / 输出

输入

输入是 `col(close)`，顺序固定 1 列： 1. `close`: `f64 | None`

输入项	类型	示例
`open`	`Float64`	9.9
`high`	`Float64`	10.25
`low`	`Float64`	9.68
`close`	`Float64`	10.0

输出

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

打印输入 / 打印输出

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

打印输入

print(data)

shape: (20, 4)
┌──────┬───────┬───────┬───────┐
│ open ┆ high  ┆ low   ┆ close │
│ ---  ┆ ---   ┆ ---   ┆ ---   │
│ f64  ┆ f64   ┆ f64   ┆ f64   │
╞══════╪═══════╪═══════╪═══════╡
│ 9.9  ┆ 10.25 ┆ 9.68  ┆ 10.0  │
│ 10.3 ┆ 10.55 ┆ 9.98  ┆ 10.2  │
│ 10.0 ┆ 10.35 ┆ 9.78  ┆ 10.1  │
│ 10.6 ┆ 10.85 ┆ 10.28 ┆ 10.5  │
│ 10.6 ┆ 10.95 ┆ 10.38 ┆ 10.7  │
│ …    ┆ …     ┆ …     ┆ …     │
│ 12.5 ┆ 12.75 ┆ 12.18 ┆ 12.4  │
│ 12.1 ┆ 12.45 ┆ 11.88 ┆ 12.2  │
│ 12.8 ┆ 13.05 ┆ 12.48 ┆ 12.7  │
│ 12.8 ┆ 13.15 ┆ 12.58 ┆ 12.9  │
│ 13.2 ┆ 13.45 ┆ 12.88 ┆ 13.1  │
└──────┴───────┴───────┴───────┘

打印输出

print(out)

shape: (4, 2)
┌────────────────┬─────────────────────────────────┐
│ 项目           ┆ 内容                            │
│ ---            ┆ ---                             │
│ str            ┆ str                             │
╞════════════════╪═════════════════════════════════╡
│ 调用           ┆ col('open', 'high', 'low', 'cl… │
│ 返回类型       ┆ Expr                            │
│ 状态           ┆ 表达式构造完成                  │
│ 怎么得到业务表 ┆ 放进                            │
│                ┆ col(...).runtime().calc_dat…    │
└────────────────┴─────────────────────────────────┘

调用

Python

col('open', 'high', 'low', 'close').stra.t06_ama_band(3, 3, 0.5, 3, 0.5, 0.5, 3)

参数	类型	默认值	说明
`period`	`int \| Params`	`必填`	位置参数
`period1`	`int \| Params`	`必填`	位置参数
`filt`	`float \| Params`	`必填`	位置参数
`filter_period`	`int \| Params`	`必填`	位置参数
`smooth_len`	`float \| Params`	`必填`	位置参数
`eff`	`float \| Params`	`必填`	位置参数
`dema_len`	`int \| Params`	`必填`	位置参数

源码参数说明

- `period`: 效率比主周期（最小按 2 处理）
- `period1`: 噪声/信号回看周期（最小按 2 处理）
- `filt`: 波动带宽系数
- `filter_period`: `ama` 差分标准差窗口（最小按 2 处理）
- `smooth_len`: 效率比平滑指数
- `eff`: 低效率阈值，`ef < eff` 时追加补偿
- `dema_len`: 双层均值窗口（最小按 2 处理）

完整代码

这个算子页使用接口示例：不伪造计算结果。需要真实上下文、多输入源、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.t06_ama_band')
print("场景:")
print('策略信号：把开平仓信号、价格和状态转成交易状态表达式。')
print("模式:")
print('接口示例：只构造表达式或对象，不伪造计算结果。')
print("输入列:")
print('open, high, low, close')
print("调用:")
print("col('open', 'high', 'low', 'close').stra.t06_ama_band(3, 3, 0.5, 3, 0.5, 0.5, 3)")
print("输入数据模板:")
print(data)
try:
    result = col('open', 'high', 'low', 'close').stra.t06_ama_band(3, 3, 0.5, 3, 0.5, 0.5, 3)
except BaseException as err:
    out = pl.DataFrame({
        "项目": ["调用", "状态", "错误类型", "错误信息"],
        "内容": ["col('open', 'high', 'low', 'close').stra.t06_ama_band(3, 3, 0.5, 3, 0.5, 0.5, 3)", "未执行成数据表", type(err).__name__, str(err)[:200]],
    })
    print("输出:")
    print(out)
else:
    out = pl.DataFrame({
        "项目": ["调用", "返回类型", "状态", "怎么得到业务表"],
        "内容": ["col('open', 'high', 'low', 'close').stra.t06_ama_band(3, 3, 0.5, 3, 0.5, 0.5, 3)", 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。

注意事项

- 输入列顺序错误：该算子按固定位置读取第 1 列
- 忘记接 `expanding()`：拿不到完整时序状态列
- 参数过小/过极端会导致信号抖动明显增大

来源

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