事件流处理

读取和写入事件，例如 Kafka® 事件

当您安装 Streaming Data Framework for MATLAB® Production Server™，您可以：

  • 从事件流平台（例如 Kafka）读取和写入事件流。

  • 模拟生产环境来测试您的流分析算法。（需要 MATLAB Compiler SDK™）

  • 通过部署来扩展您的流分析算法。（需要 MATLAB Production Server）

从 MATLAB 附加功能资源管理器安装 Streaming Data Framework for MATLAB Production Server 支持包。有关安装附加功能的信息，请参阅获取和管理附加功能 (MATLAB)。

函数

全部展开

kafkaStream创建与 Kafka 主题中的事件流的连接 (自 R2022b 起)
inMemoryStream创建与 MATLAB 托管的事件流的连接，不应用架构处理 (自 R2022b 起)
testStream创建与 MATLAB 托管的事件流的连接并应用架构处理 (自 R2022b 起)

基本导入和导出

readtimetable从事件流读取时间表 (自 R2022b 起)
writetimetable将时间表写入事件流 (自 R2022b 起)
seek在事件流中设置读取位置 (自 R2022b 起)
preview预览事件流中的事件子集 (自 R2022b 起)
identifyingName事件流名称 (自 R2022b 起)

导入和导出选项

detectImportOptions根据事件流内容创建导入选项 (自 R2022b 起)
eventStreamImportOptions创建将事件从流导入 MATLAB 的选项 (自 R2022b 起)
ImportOptions事件流的导入选项 (自 R2022b 起)
getvartype用于将变量导出到流的数据类型 (自 R2022b 起)
setvartype设置用于将变量导入和导出到流的数据类型 (自 R2022b 起)
detectExportOptions根据事件流内容创建导出选项 (自 R2022b 起)
ExportOptions事件流的导出选项 (自 R2022b 起)
readevents从 Kafka 流中读取原始事件，无需应用架构处理 (自 R2022b 起)
flush重置读取窗口边界 (自 R2022b 起)
stop停止处理来自 Kafka 主题的事件流 (自 R2022b 起)
createTopic在 Kafka 集群中创建主题 (自 R2022b 起)
deleteTopic从 Kafka 集群中删除主题 (自 R2022b 起)
loggederrorKafka 流操作的错误信息 (自 R2022b 起)
categoryListKafka 流提供程序属性列表 (自 R2022b 起)
getProviderPropertiesKafka 流配置属性数据 (自 R2022b 起)
setProviderProperties设置特定于 Kafka 配置的属性 (自 R2022b 起)
isProperty确定是否设置了 Kafka 流提供程序属性 (自 R2022b 起)
eventStreamProcessor将流分析函数应用于事件流 (自 R2022b 起)
execute在特定数量的事件窗口上执行事件流处理函数 (自 R2022b 起)
package将流处理函数打包到 EventStreamProcessor 配置的可部署存档中 (自 R2022b 起)
seek设置事件流中的位置以开始处理事件 (自 R2022b 起)
start开始使用本地测试服务器处理事件流 (自 R2022b 起)
startServer启动本地测试服务器 (自 R2022b 起)
stop停止使用本地测试服务器处理事件流 (自 R2022b 起)
stopServer关闭本地测试服务器 (自 R2022b 起)
streamingDataCompiler将流处理函数打包成可部署的存档 (自 R2022b 起)

主题

处理事件流

测试并部署流分析功能

疑难解答

获取 Kafka 事件流日志文件

找到事件流日志文件以帮助调试问题。