イベントストリーム処理

Kafka^® イベントなどのイベントの読み取りと書き込み

Streaming Data Framework for MATLAB^® Production Server™ をインストールすると、次のことが可能です。

MATLAB アドオンエクスプローラーから Streaming Data Framework for MATLAB Production Server サポートパッケージをインストールします。アドオンのインストールの詳細については、アドオンの取得と管理 (MATLAB)を参照してください。

関数

`kafkaStream`	Create connection to event stream in Kafka topic (R2022b 以降)
`inMemoryStream`	Create connection to event stream hosted by MATLAB without schema processing applied (R2022b 以降)
`testStream`	Create connection to event stream hosted by MATLAB with schema processing applied (R2022b 以降)

`readtimetable`	Read timetable from event stream (R2022b 以降)
`writetimetable`	Write timetable to event stream (R2022b 以降)
`seek`	Set read position in event stream (R2022b 以降)
`preview`	Preview subset of events from event stream (R2022b 以降)
`identifyingName`	Event stream name (R2022b 以降)

`detectImportOptions`	Create import options based on event stream content (R2022b 以降)
`eventStreamImportOptions`	Create options for importing events from stream into MATLAB (R2022b 以降)
`ImportOptions`	Import options for event stream (R2022b 以降)
`getvartype`	Data types used to export variables to stream (R2022b 以降)
`setvartype`	Set data types used to import and export variables to stream (R2022b 以降)
`detectExportOptions`	Create export options based on event stream content (R2022b 以降)
`ExportOptions`	Export options for event stream (R2022b 以降)

`readevents`	Read raw events from Kafka stream without schema processing applied (R2022b 以降)
`flush`	Reset read window boundaries (R2022b 以降)
`stop`	Stop processing event streams from Kafka topic (R2022b 以降)
`createTopic`	Create topic in Kafka cluster (R2022b 以降)
`deleteTopic`	Remove topic from Kafka cluster (R2022b 以降)
`loggederror`	Error information for Kafka stream operation (R2022b 以降)

`categoryList`	Kafka stream provider property list (R2022b 以降)
`getProviderProperties`	Kafka stream configuration property data (R2022b 以降)
`setProviderProperties`	Set properties specific to Kafka configuration (R2022b 以降)
`isProperty`	Determine if Kafka stream provider property is set (R2022b 以降)

`eventStreamProcessor`	Apply stream analytic function to event stream (R2022b 以降)
`execute`	Execute event stream processing function on specific number of event windows (R2022b 以降)
`package`	Package stream processing function into deployable archive configured by `EventStreamProcessor` (R2022b 以降)
`seek`	Set position in event stream to begin processing events (R2022b 以降)
`start`	Start processing event streams using local test server (R2022b 以降)
`startServer`	Start local test server (R2022b 以降)
`stop`	Stop processing event streams using local test server (R2022b 以降)
`stopServer`	Shut down local test server (R2022b 以降)

streamingDataCompiler Package stream processing function into deployable archive (R2022b 以降)

Streaming Data Framework for MATLAB Production Server Basics
Use Streaming Data Framework for MATLAB Production Server to read from and write to event streaming platforms, such as Kafka.
Process Kafka Events Using MATLAB
Process events from a Kafka stream using a streaming analytic function.
Connect to Secure Kafka Cluster
Set Kafka provider properties during stream object creation.

Test Streaming Analytic Function Using Local Test Server
Use the development version of MATLAB Production Server to test a streaming analytic function before deployment to MATLAB Production Server.
Deploy Streaming Analytic Function to MATLAB Production Server
Package a streaming analytic function and deploy to server.