日期时间命名空间 / expr.py
dt.minute
日期时间命名空间,处理 date/time/hour/year/month 等字段。
可执行示例returns: Exprdt
输入 / 输出
输入
按下表列名和类型准备输入。
| 输入项 | 类型 | 示例 |
|---|---|---|
datetime | Datetime | 2026-01-01 09:30:00 |
输出
| 项目 | 说明 |
|---|---|
| 返回类型 | Expr |
| 输出对象 | Expr;执行后得到 Polars DataFrame |
| 输出语义 | 输出列由算子、alias 或底层实现决定;需要稳定列名时显式使用 alias。 |
| 执行方式 | 用 col(...).runtime() 或 col.with_cols(...).runtime() 创建执行计划后 calc_data。 |
| 核心调用 | col("datetime").dt.minute() |
打印输入 / 打印输出
下面内容来自本页示例代码真实执行后的 stdout,不是手写占位。
打印输入
shape: (20, 1) ┌─────────────────────┐ │ datetime │ │ --- │ │ datetime[μs] │ ╞═════════════════════╡ │ 2026-01-01 09:30:00 │ │ 2026-01-01 09:31:00 │ │ 2026-01-01 09:32:00 │ │ 2026-01-01 09:33:00 │ │ 2026-01-01 09:34:00 │ │ … │ │ 2026-01-01 09:45:00 │ │ 2026-01-01 09:46:00 │ │ 2026-01-01 09:47:00 │ │ 2026-01-01 09:48:00 │ │ 2026-01-01 09:49:00 │ └─────────────────────┘
打印输出
shape: (20, 1) ┌──────────┐ │ datetime │ │ --- │ │ i8 │ ╞══════════╡ │ 30 │ │ 31 │ │ 32 │ │ 33 │ │ 34 │ │ … │ │ 45 │ │ 46 │ │ 47 │ │ 48 │ │ 49 │ └──────────┘
调用
col("datetime").dt.minute()无显式参数;输入来自当前表达式、绑定对象或命名空间。
完整代码
本页完整例子会执行真实的
calc_data 或对象调用。展开可复制完整代码
import datetime as dt
import polars as pl
import qust as qs
from qust import col, pms
data = pl.DataFrame(
{
"datetime": ['2026-01-01 09:30:00', '2026-01-01 09:31:00', '2026-01-01 09:32:00', '2026-01-01 09:33:00', '2026-01-01 09:34:00', '2026-01-01 09:35:00', '2026-01-01 09:36:00', '2026-01-01 09:37:00', '2026-01-01 09:38:00', '2026-01-01 09:39:00', '2026-01-01 09:40:00', '2026-01-01 09:41:00', '2026-01-01 09:42:00', '2026-01-01 09:43:00', '2026-01-01 09:44:00', '2026-01-01 09:45:00', '2026-01-01 09:46:00', '2026-01-01 09:47:00', '2026-01-01 09:48:00', '2026-01-01 09:49:00'],
}
).with_columns(pl.col("datetime").str.to_datetime())
print("算子:")
print('dt.minute')
print("场景:")
print('日期时间:从 datetime 列抽取 date/time/hour/year 等字段。')
print("模式:")
print('可执行示例:构造表达式并运行 calc_data。')
print("输入列:")
print('datetime')
print("调用:")
print('col("datetime").dt.minute()')
print("输入数据:")
print(data)
expr = col("datetime").dt.minute()
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的链式层级。
来源
| 项目 | 位置 |
|---|---|
| 源码文件 | expr.py |
| 类/对象 | _DtNamespace |