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