本页采用了机器翻译。点击此处可查看最新英文版本。

writetimetable

将时间表写入事件流

自 R2022b 起

全页折叠

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

    语法

    writetimetable(stream,tt)
    writetimetable(ks,tt,MissingTopic=action)

    说明

    writetimetable(stream,tt) 将时间表 tt 写入事件流 stream 的末尾。

    writetimetable 将时间表的行转换为事件流中的事件，其中：

    • 时间表中的列名成为事件主体中的变量名。

    • 每个事件行中的值成为这些变量的值。

    • 行时间戳成为事件时间戳。

    您可以追加到流，但不能修改已写入流的数据。

    示例

    writetimetable(ks,tt,MissingTopic=action) 指定在将时间表写入 Kafka® 托管的事件流时是否创建主题，或者在缺少主题时写入操作失败。如果您正在写入的 Kafka 集群配置为自动创建主题，则指定 action 不起作用。

    示例

    示例

    全部折叠

    将空气质量数据和天气测量数据加载到时间表中。

    load indoors

    创建一个 InMemoryStream 对象来连接到由 MATLAB 托管的事件流。

    i = inMemoryStream;

    将时间表写入事件流。

    writetimetable(i,indoors)

    预览事件流中的数据。

    preview(i)
    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

    将空气质量数据和天气测量数据加载到时间表中。

    load indoors

    假设您有一个在网络地址 kafka.host.com:9092 上运行的 Kafka 主机。创建一个 KafkaStream 对象，一次处理 10 个流事件。

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

    创建 IndoorTemp 主题并将时间表写入其中。

    writetimetable(ks,indoors)

    从流中读取前 10 个事件。

    tt1 = readtimetable(ks)
    tt1 =

  10×3 timetable

         timestamp          Humidity    AirQuality    key
    ____________________    ________    __________    ___

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

    从流中读取接下来的 10 个事件。

    tt2 = readtimetable(ks)
    tt2 =

  10×3 timetable

         timestamp          Humidity    AirQuality    key
    ____________________    ________    __________    ___

    16-Nov-2015 00:24:22       36           81        "" 
    16-Nov-2015 01:37:34       37           80        "" 
    16-Nov-2015 02:50:46       36           79        "" 
    16-Nov-2015 04:03:58       37           80        "" 
    16-Nov-2015 05:17:09       37           81        "" 
    16-Nov-2015 06:30:21       36           79        "" 
    16-Nov-2015 07:43:33       37           79        "" 
    16-Nov-2015 08:56:45       37           79        "" 
    16-Nov-2015 10:09:57       37           85        "" 
    16-Nov-2015 11:23:09       37           80        ""

    输入参数

    全部折叠

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

    输入时间表。

    连接到 Kafka 流主题的对象，指定为 KafkaStream 对象。

    如果要写入时间表的主题不存在则要采取的措施，指定为以下值之一：

    • "create" - 如果您在 Kafka 主机上拥有所需的权限，则创建新主题。

    • "fail" - 不创建新主题，并且写入操作失败。

    数据类型: char | string

    版本历史记录

    在 R2022b 中推出

    另请参阅

    | | |

    主题