preview

预览事件流中的事件子集

自 R2022b 起

全页折叠

此函数需要 Streaming Data Framework for MATLAB^® Production Server™。

语法

tt = preview(stream)

tt = preview(stream,ReadLimit="Time",RequestTimeout=rt)

说明

tt = preview(stream) 返回一个时间表，其中包含事件流中的前八个事件，但不推进读取位置。多次调用 preview 会返回同一组事件。

示例

tt = preview(stream,ReadLimit="Time",RequestTimeout=rt) 指定在事件流中预览数据时的请求超时值 rt。此语法仅对 KafkaStream 对象有效。

示例

全部折叠

预览事件数据

创建一个 inMemoryStream 对象来读取和写入事件到由 MATLAB 托管的事件流。

is = inMemoryStream;

将时间表数据写入事件流。

load indoors
writetimetable(is,indoors)

预览流中的前 8 个事件。

preview(is)

ans =

  8×2 timetable

           Time            Humidity    AirQuality
    ___________________    ________    __________

    2015-11-15 00:00:24       36           80    
    2015-11-15 01:13:35       36           80    
    2015-11-15 02:26:47       37           79    
    2015-11-15 03:39:59       37           82    
    2015-11-15 04:53:11       36           80    
    2015-11-15 06:06:23       36           80    
    2015-11-15 07:19:35       36           80    
    2015-11-15 08:32:47       37           80

预览 Kafka 事件数据时设置超时

假设您有一个在网络地址 kafka.host.com:9092 上运行的 Kafka^® 服务器，该服务器有一个主题 IndoorTemp。

创建一个 KafkaStream 对象，用于读取和写入 IndoorTemp 主题。

ks = kafkaStream("kafka.host.com",9092,"IndoorTemp");

将时间表数据写入事件流。

load indoors
writetimetable(ks,indoors)

预览前 8 个事件时设置 30 秒的超时值。

preview(ks,ReadLimit="Time",RequestTimeout=30)

ans =

  8×2 timetable

           Time            Humidity    AirQuality
    ___________________    ________    __________

    2015-11-15 00:00:24       36           80    
    2015-11-15 01:13:35       36           80    
    2015-11-15 02:26:47       37           79    
    2015-11-15 03:39:59       37           82    
    2015-11-15 04:53:11       36           80    
    2015-11-15 06:06:23       36           80    
    2015-11-15 07:19:35       36           80    
    2015-11-15 08:32:47       37           80

输入参数

全部折叠

`stream` — 连接到事件流的对象
`KafkaStream` 对象 | `InMemoryStream` 对象 | `TestStream` 对象

连接到事件流的对象，指定为 KafkaStream、InMemoryStream 或 TestStream 对象。

`rt` — 终止请求前等待的秒数
61 (默认) | 正整数

终止尚未开始传输数据的请求之前等待的秒数，指定为正整数。

如果流提供程序是 Kafka，则等待时间包括连接到 Kafka 主机以及 Kafka 主机和客户端之间的数据传输。

版本历史记录

在 R2022b 中推出

另请参阅

readtimetable | kafkaStream | inMemoryStream | testStream | seek