主要内容

startServer

启动本地测试服务器

    这个函数需要流数据框架的MATLAB®生产服务器™而且MATLAB编译SDK™

    描述

    例子

    startServer (esp的开发版本启动本地测试服务器MATLAB制作服务器),模拟生产环境,以便您可以测试事件处理。

    startServer生成一个MATLAB项目文件生产服务器编译器(MATLAB编译器SDK)除了在本地测试服务器上使用该文件模拟生产之外,您还可以使用生成的项目文件来创建一个CTF存档。

    startServer (espExtraFiles =文件在启动本地测试服务器时向CTF存档中添加其他文件。

    例子

    全部折叠

    假设你有一个卡夫卡®服务器在网络地址上运行kafka.host.com: 9092有一个主题RecamanSequence

    同时假设你有一个流分析函数recamanSum和一个函数initRecamanSum初始化持久状态。

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

    k = kafkaStream(“kafka.host.com”, 9092,“RecamanSequence”);

    创建一个EventStreamProcessor对象,该对象运行recamanSum函数初始化initRecamanSum函数。

    esp = eventStreamProcessor(ks,@recamanSum,@initRecamanSum);

    启动本地测试服务器,这还将打开生产服务器编译器(MATLAB编译器SDK)应用程序。

    请注意

    要使用测试服务器,您需要MATLAB编译器SDK

    startServer (esp);

    一旦应用程序打开,您必须手动启动测试服务器。

    若要从应用程序启动测试服务器,请单击测试客户端然后开始.有关如何使用该应用程序的示例,请参见用MATLAB测试客户端数据集成(MATLAB编译器SDK)

    导航回MATLAB命令提示符以开始处理事件。

    开始(esp);

    使用MATLAB编辑器,可以在recamanSum函数在启动服务器时检查传入的流数据。

    输入参数

    全部折叠

    对象来处理事件流,指定为EventStreamProcessor对象。

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

    只有当您计划使用生成的项目文件将CTF存档部署到其中时,才需要额外的文件MATLAB制作服务器.有关创建可部署归档的其他方法,请参见而且streamingDataCompiler功能。

    例子:archive = startServer(esp,"ExtraFiles"=["data. file])席”、“/模式/注册/ schema.json”)包括文件data.mat而且schema.json在生成的可部署归档文件中。

    数据类型:字符|字符串

    版本历史

    R2022b中引入

    Baidu
    map