查询持久化共享流表的数据

hugo
2024-11-04

获取持久化共享流表在硬盘中的数据或完整数据仅能通过再次订阅获取。这里提供一个案例

```python

// 持久化的共享流表名为SignalTB，这里创建一个与其结果一样的表用于储存
def createTB(){
   schema = SignalTable.schema().colDefs;
   return table(600000:0,schema['name'],schema['typeString'])
};


def saveToStreamf(mutable TB, msg){
   // 将数据添加到了TB
   TB.append!(select * from msg)
};

// 创建用于储存流表的表
tmpTB = createTB()

// 注意offset为0，数据会逐步添加到tmpTB中
try{unsubscribeTable(tableName='SignalTable', actionName='readSignalTable',removeOffset = false)}catch(ex){print(ex)};
subscribeTable(tableName='SignalTable', actionName='readSignalTable', offset=0, handler =saveToStreamf{tmpTB}, msgAsTable =true,persistOffset = true)

```