MindFlavor
commented
4 years ago No worries, I tested your code and indeed does not proceed. My guess is the error is in the use of block_on(f). You should await the future instead.
This is the slightly modified code:
use azure_sdk_cosmos::prelude::*;
use serde::{Deserialize, Serialize};
use warp::{reject, Filter};
#[derive(Serialize, Deserialize, Debug)]
struct MySampleStruct {
id: String,
name: String,
}
#[tokio::main]
async fn main() {
let mincase = warp::path("mincase")
.and(warp::path::end())
.and(warp::get())
.and_then(mincase);
warp::serve(mincase).run(([127, 0, 0, 1], 3030)).await
}
pub async fn mincase() -> Result<impl warp::Reply, warp::Rejection> {
let master_key =
std::env::var("COSMOS_MASTER_KEY").expect("Set env variable COSMOS_MASTER_KEY first!");
let account = std::env::var("COSMOS_ACCOUNT").expect("Set env variable COSMOS_ACCOUNT first!");
let database =
std::env::var("COSMOS_DATABASE").expect("Set env variable COSMOS_DATABASE first!");
let collection_name =
std::env::var("COSMOS_COLLECTION").expect("Set env variable COSMOS_COLLECTION first!");
let u = MySampleStruct {
id: String::from("test"),
name: String::from("test"),
};
// Create cosmos partition key.
let mut pk = PartitionKeys::new();
let pk = match pk.push(&u.name) {
Ok(pk) => pk,
Err(_) => {
return Err(reject::reject());
}
};
// Prepare document for inserting.
let document_to_insert = Document::new(&u);
let authorization_token = match AuthorizationToken::new_master(&master_key) {
Ok(t) => t,
Err(_) => {
return Err(reject::reject());
}
};
let client = match ClientBuilder::new(account, authorization_token) {
Ok(c) => c,
Err(_) => {
return Err(reject::reject());
}
};
let database_client = client.with_database_client(database);
let collection_client = database_client.with_collection_client(collection_name);
let c = collection_client
.create_document()
.with_partition_keys(pk)
.with_is_upsert(true);
let f = c.execute_with_document(&document_to_insert).await;
match f {
Ok(_) => {
println!("ALPHA");
}
Err(error) => {
println!("BRAVO {}.", error);
}
}
Ok(warp::reply::json(&u))
}Notice how I replaced block_on with await. You can test the example in the issue/291/cosmos_warp_does_not_complete branch (see examples/warp.rs execute with cargo run --example warp) (I will leave it there for a bit even if I don't plan to merge it).
ayngling
My apologies if this question should be posted on stackoverflow instead. Let me know and I will move it there.
I am using warp and trying to use azure_sdk_cosmos for inserting. The example found in AzureSDKForRust readme works fine for inserting in the same database (without warp), with the same struct I am using, but inside warp execute_with_document never completes.
I have made a fairly minimum reproducible case below. The code hangs after the
println!("HANGS HERE");statement, and no document is inserted into cosmos db.Cargo.toml dependencies:
main.rs:
I am hoping someone can tell me if I am doing something wrong, or if the sdk is.