I would like to add a minio sink . How to correctly update and install from source ? #361
PaulMatencio
started this conversation in
Ideas
Replies: 1 comment
-
cargo install --path . --features=aws The compilation is ok now and it works but I have to parse the block. Why not to pimplemet an minio sink to act like it is for Kafka or logs ? One object per event would be great. The object key could be the fingerprint that Oura creates when sinking to logs ? |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
**First it should be noted I am totally new to rust **
Here are the installation steps taken from the oura documentation
oura installation from source
mkdir -p rust/oura
git clone https://github.com/txpipe/oura.git
cd oura
cargo install --path .
The installation was sucessfully completed but
Here are the update that I would like to test if it works but I could not installed it
I would like add a new minio sink. Just for testing, I have updated the awss3 sink with the following hard coded region and endpoint , but I could not install the updated oura. The oura module installed for source is much smaller . as you can see above.
The installation was completed, the module was installed in .cargo/bin . Is there another step that I am missing ?
use aws_sdk_s3::{Client, Region, RetryConfig, Endpoint};
use http::Uri;
....
let explicit_region = Region::new("us-east-1"); <<<<<
let ep = Endpoint::immutable(Uri::from_static("http://localhost:9000")); <<<<<
let aws_config = tokio::runtime::Builder::new_current_thread()
.build()?
.block_on(
aws_config::from_env()
.load(),
);
....
let s3_config = aws_sdk_s3::config::Builder::from(&aws_config)
.retry_config(retry_config)
.endpoint_resolver(ep) <<<<<<
.region(region) <<<<<<
.build();
Beta Was this translation helpful? Give feedback.
All reactions