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 CLI 文档主页
• Fluvio 架构

学习如何构建自定义连接器

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

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

Fluvio自带http、webhook、mqtt、kafka等入站连接器。在出站连接器方面，Fluvio自带支持SQL、DuckDB、Graphite、Redis、S3等实验性构建的连接器。

使用连接器开发套件，我们只需几天时间就构建了现有的连接器。查看文档，如果需要帮助构建任何连接器，请告知我们。

• 连接器文档
• 连接器开发套件文档

学习如何构建自定义智能模块

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

• 智能模块文档
• 智能模块开发套件文档

对多语言开发接口支持存在一些限制。虽然可以为wasm兼容语言生成绑定，但这种方法存在一些问题。我们有一个更好的解决方案，即使用WebAssembly组件模型实现的Stateful Service开发套件。在未来的版本中，我们将能够原生支持所有wasm兼容编程语言。

• 状态服务开发套件文档- 即将推出 请求开发者预览邀请

在InfinyOn Cloud上尝试工作流程

InfinyOn Cloud是作为托管服务的Fluvio云服务。所有新用户都可以获得价值3000美元的信用额度，用于在InfinyOn Cloud上构建数据流。

• 查看InfinyOn Cloud指南
• 查看InfinyOn Labs存储库上的实验性数据流

客户端

• Fluvio客户端API文档首页

语言特定API文档

• Rust API文档
• Python API文档
• JavaScript API文档
• Java API文档

社区维护

• Go API文档
• Java API文档
• Elixir API文档

贡献

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

贡献者很棒

由contrib.rocks制作。

许可

本项目采用Apache许可证。

lib.rs:

读取Fluvio包索引的数据结构和域逻辑。

此crate由插件安装程序和自更新器使用。它能够读取Fluvio包注册表中的索引文件，以找到各种组件的最新版本。

这两个主要用例是允许CLI安装插件，例如通过fluvio install fluvio-cloud，以及使CLI能够看到自身和插件的最新版本。