可以尝试一下这种方法:
dbName = "dfs://SH_TSDB_snapshot_MultiColumn" tbName = "snapshot" pt = loadTable(dbName, tbName) replayDate = 2021.12.01 ds = sqlDS(<select DateTime,SecurityID from pt where date(DateTime)=replayDate, time(DateTime)>=09:30:00.000>) def disctcode(t){ r1 = select distinct(DateTime) as SecurityID from t r2 = select distinct(SecurityID) as SecurityID from t return r1,r2 } a1,a2=mr(ds, disctcode, ,) b1 = unionAll(a1,0,0) b2 = unionAll(a2,0,0)