Qust Docs

技术指标命名空间 / ta.py

ta.cdlunique3river

CDLUNIQUE3RIVER 形态指标。

可执行示例returns: Exprta

输入 / 输出

输入

open, high, low, close

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

输出

项目说明
返回类型Expr
输出对象Expr；执行后得到 Polars DataFrame
输出语义输出列由算子、alias 或底层实现决定；需要稳定列名时显式使用 alias。
执行方式用 col(...).runtime() 或 col.with_cols(...).runtime() 创建执行计划后 calc_data。
核心调用col('open', 'high', 'low', 'close').ta.cdlunique3river()

打印输入 / 打印输出

下面内容来自本页示例代码真实执行后的 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: (20, 1)
┌─────────────────┐
│ cdlunique3river │
│ ---             │
│ i32             │
╞═════════════════╡
│ 0               │
│ 0               │
│ 0               │
│ 0               │
│ 0               │
│ …               │
│ 0               │
│ 0               │
│ 0               │
│ 0               │
│ 0               │
└─────────────────┘

调用

Python
col('open', 'high', 'low', 'close').ta.cdlunique3river()

无显式参数；输入来自当前表达式、绑定对象或命名空间。

完整代码

本页完整例子会执行真实的 calc_data 或对象调用。
展开可复制完整代码
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],
    }
)

print("算子:")
print('ta.cdlunique3river')
print("场景:")
print('技术指标：用行情列生成 RSI、均线、K 线形态等指标。')
print("模式:")
print('可执行示例：构造表达式并运行 calc_data。')
print("输入列:")
print('open, high, low, close')
print("调用:")
print("col('open', 'high', 'low', 'close').ta.cdlunique3river()")
print("输入数据:")
print(data)
expr = col('open', 'high', 'low', 'close').ta.cdlunique3river()
df = col(expr).runtime()
out = df.calc_data(data)
print("输出:")
print(out)

改成业务代码

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

注意事项

  • 先确认输入列名、顺序、类型和本页一致。
  • 输出列名不符合业务语义时，显式追加 .alias(...)。
  • 窗口和分组类算子要确认 rolling/expanding/over/batch 的链式层级。

来源

项目位置
源码文件ta.py
类/对象Ta