主要内容

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

streamingDataCompiler

将流处理函数打包成可部署的存档

自 R2022b 起

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

    说明

    filePath = streamingDataCompiler(streamFcn,inStream,outStream) 创建一个 MATLAB Compiler SDK 工程文件并打开 Production Server Compiler (MATLAB Compiler SDK)。使用此应用程序将流处理函数打包到 MATLAB Production Server 的可部署存档中。

    streamingDataCompiler 返回工程文件的完整路径。

    filePath = streamingDataCompiler(streamFcn,inStream,outStream,Name=Value) 设置用于打包函数的附加选项。

    例如,如果您指定 OutputType="Archive",则 streamingDataCompiler 函数将返回可部署的存档(CTF 文件)而不是工程文件。

    示例

    示例

    全部折叠

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

    还假设您有一个流处理分析函数 recamanSum 和一个函数 initRecamanSum 来初始化持久状态。

    创建一个连接到 RecamanSequence 主题的 KafkaStream 对象。

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

    创建另一个 KafkaStream 对象,将流处理分析函数的结果写入名为 RecamanSequenceResults 的不同主题。

    outks = kafkaStream("kafka.host.com",9092,"RecamanSequenceResults");

    将流处理分析函数 recamanSum 打包成可部署的存档。由于解析函数使用状态初始化函数 initRecamanSum,因此还指定 StateStore 属性作为输入参量。

    file = streamingDataCompiler(@recamanSum,ks,outKS, ...
        StateStore="KVStore",InitialState=@initRecamanSum)
    file = 
    
        "J:\recamanSum.prj"

    package 函数根据 eventStreamProcessor 对象生成 MATLAB 工程文件,并返回此文件的路径,并使用 Production Server Compiler (MATLAB Compiler SDK) 打开此工程文件。工程文件包含以下值:

    • 流处理分析函数 recamanSum.m

    • 入口点函数,streamfcn.m

    • 可部署存档,RecamanSum.ctf

    要修改部署的函数列表或生成的存档的名称,请参阅自定义应用程序及其外观 (MATLAB Compiler SDK)

    Production Server Compiler app UI with default values for streaming function and archive name.

    Production Server Compiler 中,点击 Package 生成可部署的存档。您可以将生成的存档部署到 MATLAB Production Server。有关部署到 MATLAB Production Server 的更多信息,请参阅将存档部署至 MATLAB Production Server

    输入参数

    全部折叠

    流分析函数,指定为函数句柄、字符串或字符向量。

    数据类型: function_handle | string | char

    流处理分析函数从中读取事件的事件流,指定为流连接器对象,例如 KafkaStreamTestStream

    流处理分析函数从中读取事件的事件流,指定为流连接器对象,例如 KafkaStreamTestStream。不支持 InMemoryStream 对象。

    名称-值参数

    全部展开

    Name1=Value1,...,NameN=ValueN 的形式指定可选参量对组,其中 Name 是参量名称,Value 是对应的值。名称-值参量必须出现在其他参量之后,但对各个参量对组的顺序没有要求。

    示例: streamingDataCompiler(streamFcn,inStream,outStream,OutputFolder='J:\')

    编译配置选项

    全部展开

    生成的可部署存档的名称,指定为字符串或字符向量。

    数据类型: char | string

    由 streamingDataCompiler 函数创建的文件类型,指定为以下值之一。

    • Project - 创建 productionServerCompiler 工程文件并启动 Production Server Compiler。您可以使用 Production Server Compiler 创建 CTF 文件。

    • Archive - 创建一个 CTF 文件。

    数据类型: char | string

    要包含在生成的存档中的附加文件,对于单个文件指定为字符向量或字符串标量,对于多个文件指定为字符串数组。

    示例: ExtraFiles=["data.mat","/schema/registry/schema.json"] 在生成的可部署存档中包含文件 data.matschema.json

    数据类型: char | string

    生成文件的位置,指定为字符串或字符向量。

    示例: OutputFolder='J:\' 将生成的文件保存在 J:\ 中。

    数据类型: string | char

    标志自动在 MATLAB 中打开工程,指定为逻辑 truefalse。此属性与 OutputType="Archive" 不兼容。

    数据类型: logical

    执行配置选项

    全部展开

    为流处理分析函数创建初始状态的函数,指定为函数句柄、字符串或字符向量。

    数据类型: function_handle | char | string

    持久存储连接名称,指定为字符串或字符向量。当使用 InitialState 或使用有状态流函数时,必须指定 StateStore。将部署存档的 MATLAB Production Server 实例必须知道该连接名称。有关使用数据缓存进行持久存储的更多信息,请参阅 数据缓存基础知识

    数据类型: char | string

    标志用于使用具有相同键的事件来调用流处理函数,指定为逻辑 truefalse。将此标志设置为 true 会将事件窗口拆分为具有同类键的子窗口,并每个子窗口调用一次流处理函数。

    数据类型: logical

    版本历史记录

    在 R2022b 中推出