fluvio

<div align="center"> <h1>Fluvio</h1> <a href="https://fluvio.io" target="_blank"> <strong>可组合、声明式、有状态的数据流系统</strong> </a> <br> <br>

<br>

<br> <br> </div>

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 等的实验性构建。

使用连接器开发套件，我们在短短几天内就构建了现有的连接器。查看文档，如果你需要构建任何连接器，请告诉我们。

• 连接器文档
• 连接器开发套件（cdk）文档

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

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

• 智能模块文档
• 智能模块开发套件（smdk）文档

多语言开发接口支持的数量存在一些限制。虽然可以为 wasm 兼容语言生成绑定，但这种方法存在一些怪异之处。我们有一个更好的解决方案，即有状态服务开发套件，我们正在使用 Web Assembly 组件模型实现它。在即将发布的版本中，我们将能够原生支持所有 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 文档

贡献

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

贡献者都是很棒的

<a href="https://github.com/infinyon/fluvio/graphs/contributors"> <img src="https://contrib.rocks/image?repo=infinyon/fluvio" /> </a>

使用 contrib.rocks 制作。

许可证

本项目采用 Apache 许可证 授权。