Rust client for Timeplus Proton.
Proton is a streaming SQL engine, a fast and lightweight alternative to Apache Flink, 🚀 powered by ClickHouse. It enables developers to solve streaming data processing, routing and analytics challenges from Apache Kafka, Redpanda and more sources, and send aggregated data to the downstream systems. Proton is the core engine of Timeplus, which is a cloud native streaming analytics platform.
The initial version(0.1.0) of the client was written by Marvin Hansen. Thanks for the contribution.
This client uses https://crates.io/crates/clickhouse as a dependency.
Please install Proton as a standalone server or via Docker. Make sure either port 8123 or 3218 is exposed for pront-rust-client to connect and run SQL.
- 8123 is the port to run DDL and queries in historical mode
- 3218 is the port to run DDL and quries in streaming mode by default. You can still wrap the stream with
table(..)function to query them in historical mode.
Learn more
On Linux or Mac, you can install it via curl https://install.timeplus.com | sh
On Mac, you can also install it via brew install proton
After you get the proton binary, you can start the Proton server via proton server start
In a separate terminal, connect to the server via proton client (Note: If you encounter a 'connection refused' error, use: proton client --host 127.0.0.1)
docker run -d --pull always --name proton -p 8123:8123 -p 8463:8463 ghcr.io/timeplus-io/proton:latest
Proton is automatically started with port 8123 and 8463 exposed. Open the terminal of the container, and run proton client
For detailed usage and more information, check out the documentation: https://docs.timeplus.com/proton
Add the proton client to your project by running in a terminal:
cargo add proton_client
or by adding the following to your Cargo.toml:
[dependencies]
proton_client = { version = "0.1.0"}
use proton_client::prelude::{ProtonClient, Result};
const FN_NAME: &str = "[prepare]:";
#[tokio::main]
async fn main() -> Result<()> {
println!("{}Start", FN_NAME);
println!("{}Build client", FN_NAME);
let client = ProtonClient::new("http://localhost:8123");
println!("{}Create stream if not exists", FN_NAME);
create_stream(&client)
.await
.expect("[main]: Failed to create Stream");
println!("{}Stop", FN_NAME);
Ok(())
}
pub async fn create_stream(client: &ProtonClient) -> Result<()> {
client
.execute_query("CREATE STREAM IF NOT EXISTS test_stream(no uint32, name string) ORDER BY no")
.await
}
make example
Which shows:
-----------------------------------------
Select the number of the example to run:
-----------------------------------------
1) prepare: Prepare Proton for the examples: create table & load data
2) query: Query Proton with sample queries
3) remove: Cleanup Proton and delete streams
4) quit: Exit
-----------------------------------------
Make sure Proton is running
-----------------------------------------
Please select the number of the example to run. Also, first run the prepare example to prepare Proton for the query example. See the code of all examples here.
To see more examples of using Proton, check out the examples folder in Proton repo.
Please note, by default the SQL queries are in streaming mode. Learn more about SQL syntax at Proton Documentation.
You find the full documentation for Proton at docs.timeplus.com alongside documentation for the Timeplus (Cloud and BYOC) platform.
We welcome your contributions!
Join our Timeplus Community Slack to connect with Timeplus engineers and other Proton users.
For filing bugs, suggesting improvements, or requesting new features, see the open issues here on GitHub.
Proton Rust Client uses Apache License 2.0. See details in the LICENSE.
3.7k Jan 2, 2023
7.6k Dec 31, 2022
111 Dec 15, 2022
100 Nov 11, 2022
108 Dec 7, 2022
10 Dec 25, 2022
7 Jun 15, 2022
525 Dec 23, 2022
45 Dec 21, 2022
4.7k Jan 8, 2023
52 Nov 16, 2022
4 May 20, 2023
75 Jun 12, 2023
4 Jun 12, 2023
16 Dec 24, 2022
7 Dec 15, 2022
27 Dec 7, 2022
37 Dec 18, 2022