⚡
极致写入性能
子表级无锁并发写入，双 MemTable + WAL 批量刷盘，gRPC Streaming 实现 175 万行/秒吞吐。
AstraFaber高性能实时数据库
基于 Apache Arrow 构建，面向 IoT 与边缘计算的列式存储引擎。gRPC Streaming 通信，设备孪生，毫秒级响应。
Skip to content
核心性能指标
实测数据 · Intel i7 / 32GB RAM / SSD
175万
行/秒 写入
gRPC Streaming · 100 设备
207万
QPS 查询
Streaming · 100 连接 · 48μs 延迟
73.5万
行/秒 大规模写入
gRPC Streaming · 10 万设备
快速开始
1. 启动服务器
bash
cargo run --release
# AstraFaber Server listening on 127.0.0.1:500512. 连接并写入数据
rust
use astra_faber_client::{Client, SchemaBuilder, Table, int32_type, string_type};
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
// 连接服务器
let mut client = Client::connect("http://127.0.0.1:50051").await?;
// 定义 Schema
let schema = SchemaBuilder::new()
.add_field("id", int32_type(), None)
.add_field("name", string_type(), None)
.build();
// 创建表
client.create_table("users", schema.fields).await?;
// 插入数据
let table = Table::new("users")
.with_schema(schema)
.add_row(astra_faber_client::row![1i32, "Alice"])?
.add_row(astra_faber_client::row![2i32, "Bob"])?
.build()?;
client.insert_table(table).await?;
Ok(())
}