25个版本
| 0.5.0 | 2024年7月22日 |
|---|---|
| 0.4.5 | 2024年3月4日 |
| 0.4.4 | 2023年9月28日 |
| 0.4.3 | 2023年7月29日 |
| 0.1.0 | 2020年10月2日 |
#93 in WebAssembly
2,413 每月下载量
在 22 个crate中使用 (16 个直接使用)
19KB
441 行代码
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 hub进行分发。
在多语言开发接口支持的量上存在一些限制。虽然可以为wasm兼容的语言生成绑定，但这种方法存在一些问题。我们有一个更好的解决方案，即使用Web Assembly组件模型实现的有状态服务开发套件。在即将发布的版本中，我们将能够原生支持所有wasm兼容的编程语言。
- 有状态服务开发套件文档- 即将推出 请求开发者预览邀请
在InfinyOn Cloud上尝试工作流程
InfinyOn Cloud是Fluvio作为托管服务在云上的实现。所有新用户都获得价值3000美元的信用额度，用于在InfinyOn Cloud上构建数据流。
客户端
语言特定API文档
社区维护
贡献
如果您想为该项目做出贡献，请阅读我们的贡献指南。
贡献者很棒
由contrib.rocks制作。
许可证
本项目受Apache许可证许可。
依赖关系
~2.7–3.5MB
~72K SLoC