matlab图像相嵌代码-matlab-apache-kafka:适用于ApacheKafka的MATLAB接口

  • n4_810792
    了解作者
  • 547.6KB
    文件大小
  • zip
    文件格式
  • 0
    收藏次数
  • VIP专享
    资源类型
  • 0
    下载次数
  • 2022-04-17 01:57
    上传日期
matlab图像相嵌代码适用于Apache Kafka的MATLAB接口 适用于ApacheKafka:registered:的MATLAB:registered:接口。 该软件包提供了用于MATLAB,Simulink和Embedded Coder的Kafka客户端。 Kafka:registered:用于构建实时数据管道和流应用程序。 它是水平可伸缩的,容错的,快速的并且被广泛使用。 要求 需要MATLAB版本R2018a或更高版本。 使用Kafka Client块时还需要Simulink。 目前仅Windows和Linux支持该软件包。 嵌入式编码器解决方案仅在Linux上受支持。 MathWorks产品() 的MATLAB [可选] Simulink [可选] MATLAB Coder [可选] Simulink编码器 [可选]嵌入式编码器 第三方产品 用于构建mex函数和S函数。 符合您的平台的AC / C ++编译器。 ,版本1.0或更高版本 如librdkafka的安装中所声明的其他一些库。 [可选] JSON库(如果您正在使用Simulink JSON-Converter)。 介绍 是一个社区分布式事件流平台,能够每天处理数万亿个事件
matlab-apache-kafka-master.zip
内容介绍
# MATLAB Interface *for Apache Kafka* MATLAB® interface for Apache Kafka®. This package provides Kafka clients for MATLAB, Simulink and Embedded Coder. Kafka® is used for building real-time data pipelines and streaming apps. It is horizontally scalable, fault-tolerant, fast and widely used. ## Requirements Requires MATLAB release R2018a or later. Also requires Simulink when using the Kafka Client blocks. The package is currently only supported for Windows and Linux. The Embedded Coder solution is only supported on Linux. ### MathWorks Products (http://www.mathworks.com) * MATLAB * [Optional] Simulink * [Optional] MATLAB Coder * [Optional] Simulink Coder * [Optional] Embedded Coder ### 3rd Party Products For building the mex functions and S-functions. * A C/C++ compiler for your platform, in accordance with [MATLAB supported compilers](https://www.mathworks.com/support/requirements/supported-compilers.html). * [librdkafka](https://github.com/edenhill/librdkafka), version 1.0 or higher * Some other libraries, as declared in the installation of librdkafka. * [Optional] [jansson](http://www.digip.org/jansson/) JSON library, if you're using the Simulink JSON-Converter. ## Introduction [Apache Kafka®](http://kafka.apache.org/) is a community distributed event streaming platform capable of handling trillions of events a day. Initially conceived as a messaging queue, Kafka is based on an abstraction of a distributed commit log. Since being created and open sourced by LinkedIn in 2011, Kafka has quickly evolved from messaging queue to a full-fledged event streaming platform. This project contains C/C++-based Kafka Clients, producers and consumers, for both MATLAB and Simulink. In Simulink, code generation with Embedded Coder is also supported. The usage in MATLAB is for prototyping, and if you want to use it in a production system, we recommend compiling your code for *MATLAB Production Server*. For usage in Simulink, this is also prototyping. Generate C code using Embedded Coder to use in a production environment. ## Installation First install *librdkafka*, and optionally *jansson*, see [the documentation](Documentation/Installation.md). To install the MATLAB part, just do ```matlab cd Software/MATLAB startup ``` This will add the needed paths. If you want them to be saved for future sessions, run ```matlab savepath ``` You will need to compile the Mex function and optionally the S-functions. This is done with the two commands: ```matlab kafka_build_mex kafka_build_sfuns ``` If you intend to generate dockerfiles too, you need to build the base images before you can build from these dockerfiles. To build the base images, run ```matlab kafka_build_dockerfiles ``` For help refer to [the documentation](Documentation/Installation.md). ## Usage ### MATLAB Kafka Producer Using the Kafka producer is straightforward. ```matlab P = kafka.Producer('<mybroker>', '<mytopic>'); P.publish('mykey', 'my message'); ``` The same producer can, and should be used for sending several messages to the same topic. The key and message arguments should be in a form that can automatically be converted to ```int8```. If you have a structure, you should first convert it to JSON. ```matlab >> S = struct('item', '3422', 'value', [3,4,5]) S = struct with fields: item: '3422' value: [3 4 5] >> jsstr = jsonencode(S) jsstr = '{"item":"3422","value":[3,4,5]}' ``` The Kafka consumer is similar. ```matlab C = kafka.Consumer(brokers, topic, group); [key, val, errMsg] = C.consume(timeoutMillis); ``` Please see the [documentation](Documentation/README.md) for more information. ### Simulink blocks The current version contains 3 blocks for Kafka communication. A consumer block, a producer block, and a very simple block to convert flat JSON structures. The Kafka functionality works both for simulation and code generation. Read more in the [corresponding documentation ](Documentation/BasicUsage.md#simulink-clients) ### Embedded Coder This repository also contains an Embedded Coder target for use with Kafka. It will generate code from the Simulink model and the Kafka blocks. This code can also be dockerized, with the use of a Dockerfile that is generated with the code. Read more in the [corresponding documentation](Documentation/BasicUsage.md#embedded-coder-target) ## Documentation See [documentation](Documentation/README.md) for more information. ## License The license for the MATLAB Interface *for Apache Kafka* is available in the [LICENSE.md](LICENSE.md) file in this GitHub repository. This package uses certain third-party content which is licensed under separate license agreements. See the 3rd party packages for the respective license details. ## Enhancement Request Provide suggestions for additional features or capabilities using the following link: https://www.mathworks.com/products/reference-architectures/request-new-reference-architectures.html ## Support Email: `mwlab@mathworks.com`
评论
    相关推荐
    • ApacheCxf提供Json格式接口服务demo
      ApacheCxf提供Json格式接口服务demo,代码可执行。
    • apache json解析开源项目
      apachejson解析工具类,非常方便实用,如果编写java项目可以直接使用它来解析json数据。
    • JSON包下载
      JSON相关JAR包和文档 1、commons-beanutils-1.7.0.jar 2、commons-collections-3.2.jar 3、commons-lang-2.3....org/apache/commons/collections/map/ListOrderedMap这个异常。 把这些JAR包导入到工程就可以直接使用了
    • apache-jmeter-5.zip
      jmeter5.0 核心改进 在许多领域,休息支持得到了改善 多部分/表单数据请求现在适用于PUT,DELETE ...... 现在也可以发送带附加文件的JSON Body 在“参数”选项卡中输入的参数现在在正文中使用,而不是被忽略
    • 使用json常用到的6个包
      使用json常用到的6个包,解决报org.apache.commons.collections.map.ListOrderedMap和org.apache.commons.lang.exception.NestableRuntimeException错误
    • apache的dbutil的改进版
      apache的dbutil包的改进,改善了代码结构,增加了直接对resultset输出json的支持
    • json2parquet:将JSON文件转换为Apache Parquet
      JSON文件转换为Apache Parquet。 您可能也对 , 或。 安装 下载预编译的二进制文件 您可以从获取最新版本。 带货物 cargo install json2parquet 用法 USAGE: json2parquet [FLAGS] [OPTIONS] <JSON> ARGS: ...
    • apache-jmeter-2.1.3 含json插件
      完整的jmeter 2.1.3包,解压可用,内含json插件和一个http 并发测试的例子。 jmeter是一个http/tcp 并发测试的工具,轻便易用。 中文语言。
    • pig-json:用于 Apache Pig 的 Mortar JSON 工具
      用于 Apache Pig 的 Mortar JSON 工具。 里面有什么 此回购中包括: JsonLoader :用于任意 JSON 文件的 Pig 加载函数(不仅仅是 JsonStorage 生成的文件) FromJsonInferSchema :包装 JsonLoader 以将字符数组...
    • json包(非apache)和jsoup包
      共2个包,一个json,一个jsoup,json包非apache的,所以只用引这一个包就可以用了,推荐使用。