6 个版本 (重大变更)
| 0.6.0 | 2021 年 2 月 19 日 |
|---|---|
| 0.5.0 | 2021 年 1 月 30 日 |
| 0.4.0 | 2021 年 1 月 16 日 |
| 0.3.0 | 2020 年 12 月 15 日 |
| 0.1.0 | 2020 年 10 月 2 日 |
#9 在 #control-plane
每月 29 次下载
用于 5 个包 (直接使用 2 个)
495KB
13K SLoC
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 云中心进行分发。
对多语言开发接口支持的量有一些限制。虽然可以为与 wasm 兼容的语言生成绑定，但这种方法存在一些问题。我们有一个更好的解决方案，即使用 WebAssembly 组件模型实现的有状态服务开发套件。在即将推出的版本中，我们将能够原生支持所有与 wasm 兼容的编程语言。
- 有状态服务开发套件文档 - 即将推出 即将推出 请求开发者预览邀请
在 InfinyOn 云上尝试工作流
InfinyOn 云是托管服务中的 Fluvio。所有新用户都获得价值 3000 美元的信用额度，用于在 InfinyOn 云上构建数据流。
客户端
语言特定 API 文档
社区维护
贡献
如果您想为项目做出贡献，请阅读我们的贡献指南。
贡献者是棒极了
由 contrib.rocks 制作。
许可证
此项目根据Apache 许可证授权。
依赖项
~5.5MB
~110K SLoC