32 个版本

新版本 0.13.4	2024 年 8 月 6 日
0.13.3	2024 年 7 月 22 日
0.13.2	2024 年 5 月 7 日
0.13.1	2024 年 1 月 15 日
0.2.0	2020 年 10 月 28 日

#239 in WebAssembly

330 每月下载量
用于 5 个包（2 个直接使用）

Apache-2.0

235KB
5.5K SLoC

Fluvio

可组合、声明式、有状态的数据流系统

Fluvio 是一个用 Rust 和 Web Assembly 编写的轻量级高性能分布式数据流系统。

快速入门 - 在 2 分钟或更短时间内开始使用 Fluvio！

步骤 1. 下载 Fluvio 版本管理器

在终端运行

curl -fsS https://hub.infinyon.cloud/install/install.sh | bash

按照说明，并将 bin 目录的路径复制粘贴到启动脚本文件中。

Fluvio 版本管理器将为您提供下载 Fluvio 不同版本的能力

包括我们的只读边缘集群，具有内置压缩、缓存和镜像功能，即使在长时间停机期间也不会丢失数据。
或者我们的状态流开发者预览版，我们正在使用 Web Assembly 组件模型构建，以支持所有 Web Assembly 兼容语言。

步骤 2. 启动本地集群

以下命令将默认启动本地集群

fluvio cluster start

步骤 3. 创建主题

以下命令将创建一个名为 hello-fluvio 的主题

fluvio topic create hello-fluvio

步骤 4. 向主题生产，从主题消费

向您的主题生产数据。首先运行命令，然后输入一些消息

fluvio produce hello-fluvio
> hello fluvio
Ok!
> test message
Ok!

从主题消费数据，在另一个终端中运行以下命令

fluvio consume hello-fluvio -B -d

就这样！您已经有一个本地集群正在运行。

使用预构建的 Fluvio 版本

您可能希望选择比最新稳定版本以外的其他 Fluvio 版本。您可以通过指定环境变量 VERSION 来实现这一点。

安装最新版本（截至 master 分支）

$ curl -fsS https://hub.infinyon.cloud/install/install.sh | VERSION=latest bash

安装特定版本

$ curl -fsS https://hub.infinyon.cloud/install/install.sh | VERSION=x.y.z bash

下一步

现在您已经有一个集群正在运行，您可以尝试以不同的范式构建数据流。

查看 Fluvio 核心文档

Fluvio 文档将提供有关如何使用 Fluvio 集群、CLI、客户端和开发套件的额外信息。

了解如何构建自定义连接器

Fluvio 可以连接到您能想到的几乎所有系统。

对于第一方系统，Fluvio 客户端可以与边缘系统或应用程序集成以获取数据。
对于第三方系统，Fluvio 连接器在协议级别连接，并将数据收集到 Fluvio 主题中。

默认情况下，Fluvio 具有本地的 http、webhook、mqtt、kafka 入站连接器。在出站连接器方面，默认情况下 Fluvio 支持SQL、DuckDB、Graphite、Redis等实验性构建版本、S3等。

使用连接器开发工具包，我们几天内就构建了我们现有的连接器。查看文档，并告诉我们是否需要帮助构建任何连接器。

了解如何构建自定义智能模块

Fluvio 应用基于 wasm 的流处理和数据转换。我们称这些可重用转换函数为智能模块。可重用智能模块使用智能模块开发工具包构建，并可以使用 InfinyOn Cloud 中心进行分发。

在支持多语言开发接口的数量上存在一些限制。虽然可以为与 wasm 兼容的语言生成绑定，但这种方法存在一些问题。我们有一个更好的解决方案，即状态服务开发工具包，我们正在使用 WebAssembly 组件模型来实现它。在即将发布的版本中，我们将能够原生支持所有与 wasm 兼容的编程语言。

状态服务开发工具包文档 - 即将推出 请求开发者预览邀请

在 InfinyOn Cloud 上尝试工作流

InfinyOn Cloud 是 Fluvio 在云端的托管服务。所有新用户都获得价值 3000 美元的积分，以在 InfinyOn Cloud 上构建数据流。

客户端

Fluvio 客户端 API 文档首页

语言特定 API 文档

社区维护

贡献

如果您想为项目做出贡献，请阅读我们的贡献指南。

贡献者是了不起的

由contrib.rocks创建。

许可证

此项目采用Apache 许可证。

依赖关系

~8–21MB
~299K SLoC