This commit is contained in:
Krishan 2024-01-18 21:04:35 +00:00 коммит произвёл GitHub
Родитель 4b28b5cf8b
Коммит ab17f7e279
Не найден ключ, соответствующий данной подписи
Идентификатор ключа GPG: B5690EEEBB952194
2 изменённых файлов: 1 добавлений и 9 удалений

Просмотреть файл

@ -19,7 +19,6 @@ rand = "0.8"
serde = { version = "1", features = ["serde_derive"] }
serde_json = "1"
thiserror = "1"
tracing = { version = "0.1", default-features = false, features = ["std"] }
url = "2"
uuid = { version = "1", features = ["v4", "serde"] }

Просмотреть файл

@ -3,7 +3,6 @@ use std::sync::Arc;
use crate::error::Result;
use azure_core::base64;
use azure_kusto_data::prelude::KustoClient;
use tracing::debug;
use crate::client_options::QueuedIngestClientOptions;
use crate::descriptors::BlobDescriptor;
@ -45,24 +44,18 @@ impl QueuedIngestClient {
ingestion_properties: IngestionProperties,
) -> Result<()> {
let queue_client = self.resource_manager.ingestion_queue().await?;
debug!("ingestion queues: {:#?}", queue_client);
let auth_context = self.resource_manager.authorization_context().await?;
debug!("auth_context: {:#?}\n", auth_context);
let message =
QueuedIngestionMessage::new(&blob_descriptor, &ingestion_properties, auth_context);
debug!("message: {:#?}\n", message);
let message = serde_json::to_string(&message)?;
debug!("message as string: {}\n", message);
// Base64 encode the ingestion message
let message = base64::encode(&message);
debug!("message as base64 encoded string: {}\n", message);
let resp = queue_client.put_message(message).await?;
debug!("resp: {:#?}\n", resp);
let _resp = queue_client.put_message(message).await?;
Ok(())
}