StreamNative
由Apache Pulsar的原始创建者创立，StreamNative提供基于Apache Pulsar的云原生、可扩展、安全的消息和事件流解决方案。StreamNative Cloud通过提供完全托管、灵活的Pulsar®-as-a-Service服务，使团队能够简化操作。
丰富您的流数据
StreamNative和InfluxData
StreamNative通过本地的Apache Pulsar连接器和MQTT Telegraf输入插件，使将大量流数据源轻松导入InfluxDB变得简单。StreamNative和InfluxDB联合使用，可以将任何流源（包括日志、传感器和事件）路由、缓冲、聚合、多路复用、转换和过滤到InfluxDB，同时还可以填充任意数量的其他企业数据存储。
将Apache Pulsar与InfluxDB集成
StreamNative的Pulsar到InfluxDB开源连接器从Apache Pulsar集群中流式传输数据。它创建了一个快速、可扩展的数据管道到InfluxDB桶。FLiP-InfluxDB连接器是一个零代码解决方案来发送数据。InfluxDB接收连接器从Pulsar主题中拉取消息，并将消息持久化到InfluxDB。
要将Apache Pulsar与InfluxDB集成，您只需将InfluxDB连接器下载到您的Pulsar节点即可。
步骤
- 下载Pulsar到InfluxDB连接器.
- 将nar复制到连接器目录。
- 创建一个Influx令牌。
- 构建一个配置文件。
- 使用REST端点或命令行界面创建指向nar和配置文件的influxdb接收器。
- 发送数据。
- 在InfluxDB Cloud中可视化。
有关如何从Apache Pulsar过滤和丰富数据到InfluxDB的演示，请查看这个Pulsar函数，它输出行协议数据。
关键资源
- 视频：使用FLaNK在InfluxDB上进行边缘AI IoT大规模集成
- 集成：FLiP-InfluxDB
- 网络研讨会：使用FLiP在InfluxDB上进行边缘AI IoT大规模集成
- 文档：使用无代码技术写入数据
- 集成：InfluxDB接收连接器
- 文档：Pulsar函数
统一消息和流到InfluxDB
StreamNative提供了一种平台，可以从各种来源摄取数据，实时过滤、路由和转换它们，通过其无代码数据接收器将它们喂送到InfluxDB。
StreamNative还可以作为InfluxDB的源，通过MQTT协议使用Telegraf进行无缝物联网集成。
StreamNative和Apache Pulsar通常用于摄取、路由、转换和丰富设备、数据库、事件、日志、传感器和REST端点的数据流。根据客户端的需求，这些数据可以逐个事件或批量流式传输到InfluxDB。
典型仪表板
视频
在InfluxDB上使用FLiPN进行大规模EdgeAI物联网 | InfluxDays NA 2021
StreamNative的Timothy Spann带领这个视频教程，介绍他的团队如何运行深度学习模型，并在边缘设备上捕获实时GPS和传感器数据。他们使用了Pulsar、Apache NiFi + Edge Flow Manager + MiniFi Agents以及Apache MXNet、OpenVino、TensorFlow Lite和其他深度学习库，包括搭载了Movidius 2的树莓派、Google Coral TPU和NVIDIA Jetson Nano等边缘设备。他们的低代码物联网应用程序提供了简单的边缘路由、转换、数据采集和警报功能，在决定将哪些数据实时传输到数据空间之前。这些边缘应用程序在边缘实时分类图像和传感器读数，然后将深度学习结果发送到Flink SQL和Apache NiFi进行转换、解析、丰富、查询、过滤和合并数据到InfluxDB。
接下来是什么？
有问题？获取答案
